Documentation
¶
Index ¶
- Variables
- func AdaptHCLog(log *logrus.Entry) hclog.Logger
- func NewClientPlugin(log *logrus.Entry) plugin.Plugin
- func NewServerPlugin(handler PublisherServer) plugin.Plugin
- func RegisterPublisherServer(s *grpc.Server, srv PublisherServer)
- type BeginOAuthFlowRequest
- func (*BeginOAuthFlowRequest) Descriptor() ([]byte, []int)
- func (m *BeginOAuthFlowRequest) GetConfiguration() *OAuthConfiguration
- func (m *BeginOAuthFlowRequest) GetRedirectUrl() string
- func (*BeginOAuthFlowRequest) ProtoMessage()
- func (m *BeginOAuthFlowRequest) Reset()
- func (m *BeginOAuthFlowRequest) String() string
- func (m *BeginOAuthFlowRequest) XXX_DiscardUnknown()
- func (m *BeginOAuthFlowRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *BeginOAuthFlowRequest) XXX_Merge(src proto.Message)
- func (m *BeginOAuthFlowRequest) XXX_Size() int
- func (m *BeginOAuthFlowRequest) XXX_Unmarshal(b []byte) error
- type BeginOAuthFlowResponse
- func (*BeginOAuthFlowResponse) Descriptor() ([]byte, []int)
- func (m *BeginOAuthFlowResponse) GetAuthorizationUrl() string
- func (*BeginOAuthFlowResponse) ProtoMessage()
- func (m *BeginOAuthFlowResponse) Reset()
- func (m *BeginOAuthFlowResponse) String() string
- func (m *BeginOAuthFlowResponse) XXX_DiscardUnknown()
- func (m *BeginOAuthFlowResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *BeginOAuthFlowResponse) XXX_Merge(src proto.Message)
- func (m *BeginOAuthFlowResponse) XXX_Size() int
- func (m *BeginOAuthFlowResponse) XXX_Unmarshal(b []byte) error
- type CompleteOAuthFlowRequest
- func (*CompleteOAuthFlowRequest) Descriptor() ([]byte, []int)
- func (m *CompleteOAuthFlowRequest) GetConfiguration() *OAuthConfiguration
- func (m *CompleteOAuthFlowRequest) GetRedirectBody() string
- func (m *CompleteOAuthFlowRequest) GetRedirectUrl() string
- func (*CompleteOAuthFlowRequest) ProtoMessage()
- func (m *CompleteOAuthFlowRequest) Reset()
- func (m *CompleteOAuthFlowRequest) String() string
- func (m *CompleteOAuthFlowRequest) XXX_DiscardUnknown()
- func (m *CompleteOAuthFlowRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *CompleteOAuthFlowRequest) XXX_Merge(src proto.Message)
- func (m *CompleteOAuthFlowRequest) XXX_Size() int
- func (m *CompleteOAuthFlowRequest) XXX_Unmarshal(b []byte) error
- type CompleteOAuthFlowResponse
- func (*CompleteOAuthFlowResponse) Descriptor() ([]byte, []int)
- func (m *CompleteOAuthFlowResponse) GetOauthStateJson() string
- func (*CompleteOAuthFlowResponse) ProtoMessage()
- func (m *CompleteOAuthFlowResponse) Reset()
- func (m *CompleteOAuthFlowResponse) String() string
- func (m *CompleteOAuthFlowResponse) XXX_DiscardUnknown()
- func (m *CompleteOAuthFlowResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *CompleteOAuthFlowResponse) XXX_Merge(src proto.Message)
- func (m *CompleteOAuthFlowResponse) XXX_Size() int
- func (m *CompleteOAuthFlowResponse) XXX_Unmarshal(b []byte) error
- type ConfigurationFormRequest
- func (*ConfigurationFormRequest) Descriptor() ([]byte, []int)
- func (m *ConfigurationFormRequest) GetDataJson() string
- func (m *ConfigurationFormRequest) GetStateJson() string
- func (*ConfigurationFormRequest) ProtoMessage()
- func (m *ConfigurationFormRequest) Reset()
- func (m *ConfigurationFormRequest) String() string
- func (m *ConfigurationFormRequest) XXX_DiscardUnknown()
- func (m *ConfigurationFormRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ConfigurationFormRequest) XXX_Merge(src proto.Message)
- func (m *ConfigurationFormRequest) XXX_Size() int
- func (m *ConfigurationFormRequest) XXX_Unmarshal(b []byte) error
- type ConfigurationFormResponse
- func (*ConfigurationFormResponse) Descriptor() ([]byte, []int)
- func (m *ConfigurationFormResponse) GetDataErrorsJson() string
- func (m *ConfigurationFormResponse) GetDataJson() string
- func (m *ConfigurationFormResponse) GetErrors() []string
- func (m *ConfigurationFormResponse) GetSchemaJson() string
- func (m *ConfigurationFormResponse) GetStateJson() string
- func (m *ConfigurationFormResponse) GetUiJson() string
- func (*ConfigurationFormResponse) ProtoMessage()
- func (m *ConfigurationFormResponse) Reset()
- func (m *ConfigurationFormResponse) String() string
- func (m *ConfigurationFormResponse) XXX_DiscardUnknown()
- func (m *ConfigurationFormResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ConfigurationFormResponse) XXX_Merge(src proto.Message)
- func (m *ConfigurationFormResponse) XXX_Size() int
- func (m *ConfigurationFormResponse) XXX_Unmarshal(b []byte) error
- type ConfigureConnectionRequest
- func (*ConfigureConnectionRequest) Descriptor() ([]byte, []int)
- func (m *ConfigureConnectionRequest) GetConnectRequest() *ConnectRequest
- func (m *ConfigureConnectionRequest) GetForm() *ConfigurationFormRequest
- func (*ConfigureConnectionRequest) ProtoMessage()
- func (m *ConfigureConnectionRequest) Reset()
- func (m *ConfigureConnectionRequest) String() string
- func (m *ConfigureConnectionRequest) XXX_DiscardUnknown()
- func (m *ConfigureConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ConfigureConnectionRequest) XXX_Merge(src proto.Message)
- func (m *ConfigureConnectionRequest) XXX_Size() int
- func (m *ConfigureConnectionRequest) XXX_Unmarshal(b []byte) error
- type ConfigureConnectionResponse
- func (*ConfigureConnectionResponse) Descriptor() ([]byte, []int)
- func (m *ConfigureConnectionResponse) GetConnectResponse() *ConnectResponse
- func (m *ConfigureConnectionResponse) GetForm() *ConfigurationFormResponse
- func (*ConfigureConnectionResponse) ProtoMessage()
- func (m *ConfigureConnectionResponse) Reset()
- func (m *ConfigureConnectionResponse) String() string
- func (m *ConfigureConnectionResponse) XXX_DiscardUnknown()
- func (m *ConfigureConnectionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ConfigureConnectionResponse) XXX_Merge(src proto.Message)
- func (m *ConfigureConnectionResponse) XXX_Size() int
- func (m *ConfigureConnectionResponse) XXX_Unmarshal(b []byte) error
- type ConfigureQueryRequest
- func (*ConfigureQueryRequest) Descriptor() ([]byte, []int)
- func (m *ConfigureQueryRequest) GetForm() *ConfigurationFormRequest
- func (*ConfigureQueryRequest) ProtoMessage()
- func (m *ConfigureQueryRequest) Reset()
- func (m *ConfigureQueryRequest) String() string
- func (m *ConfigureQueryRequest) XXX_DiscardUnknown()
- func (m *ConfigureQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ConfigureQueryRequest) XXX_Merge(src proto.Message)
- func (m *ConfigureQueryRequest) XXX_Size() int
- func (m *ConfigureQueryRequest) XXX_Unmarshal(b []byte) error
- type ConfigureQueryResponse
- func (*ConfigureQueryResponse) Descriptor() ([]byte, []int)
- func (m *ConfigureQueryResponse) GetForm() *ConfigurationFormResponse
- func (m *ConfigureQueryResponse) GetShape() *Shape
- func (*ConfigureQueryResponse) ProtoMessage()
- func (m *ConfigureQueryResponse) Reset()
- func (m *ConfigureQueryResponse) String() string
- func (m *ConfigureQueryResponse) XXX_DiscardUnknown()
- func (m *ConfigureQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ConfigureQueryResponse) XXX_Merge(src proto.Message)
- func (m *ConfigureQueryResponse) XXX_Size() int
- func (m *ConfigureQueryResponse) XXX_Unmarshal(b []byte) error
- type ConfigureRealTimeRequest
- func (*ConfigureRealTimeRequest) Descriptor() ([]byte, []int)
- func (m *ConfigureRealTimeRequest) GetForm() *ConfigurationFormRequest
- func (*ConfigureRealTimeRequest) ProtoMessage()
- func (m *ConfigureRealTimeRequest) Reset()
- func (m *ConfigureRealTimeRequest) String() string
- func (m *ConfigureRealTimeRequest) XXX_DiscardUnknown()
- func (m *ConfigureRealTimeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ConfigureRealTimeRequest) XXX_Merge(src proto.Message)
- func (m *ConfigureRealTimeRequest) XXX_Size() int
- func (m *ConfigureRealTimeRequest) XXX_Unmarshal(b []byte) error
- type ConfigureRealTimeResponse
- func (*ConfigureRealTimeResponse) Descriptor() ([]byte, []int)
- func (m *ConfigureRealTimeResponse) GetForm() *ConfigurationFormResponse
- func (*ConfigureRealTimeResponse) ProtoMessage()
- func (m *ConfigureRealTimeResponse) Reset()
- func (m *ConfigureRealTimeResponse) String() string
- func (m *ConfigureRealTimeResponse) XXX_DiscardUnknown()
- func (m *ConfigureRealTimeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ConfigureRealTimeResponse) XXX_Merge(src proto.Message)
- func (m *ConfigureRealTimeResponse) XXX_Size() int
- func (m *ConfigureRealTimeResponse) XXX_Unmarshal(b []byte) error
- type ConnectRequest
- func (*ConnectRequest) Descriptor() ([]byte, []int)
- func (m *ConnectRequest) GetOauthConfiguration() *OAuthConfiguration
- func (m *ConnectRequest) GetOauthStateJson() string
- func (m *ConnectRequest) GetSettingsJson() string
- func (*ConnectRequest) ProtoMessage()
- func (m *ConnectRequest) Reset()
- func (m *ConnectRequest) String() string
- func (m *ConnectRequest) XXX_DiscardUnknown()
- func (m *ConnectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ConnectRequest) XXX_Merge(src proto.Message)
- func (m *ConnectRequest) XXX_Size() int
- func (m *ConnectRequest) XXX_Unmarshal(b []byte) error
- type ConnectResponse
- func (*ConnectResponse) Descriptor() ([]byte, []int)
- func (m *ConnectResponse) GetConnectionError() string
- func (m *ConnectResponse) GetOauthError() string
- func (m *ConnectResponse) GetOauthStateJson() string
- func (m *ConnectResponse) GetSettingsError() string
- func (*ConnectResponse) ProtoMessage()
- func (m *ConnectResponse) Reset()
- func (m *ConnectResponse) String() string
- func (m *ConnectResponse) XXX_DiscardUnknown()
- func (m *ConnectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ConnectResponse) XXX_Merge(src proto.Message)
- func (m *ConnectResponse) XXX_Size() int
- func (m *ConnectResponse) XXX_Unmarshal(b []byte) error
- type Count
- func (*Count) Descriptor() ([]byte, []int)
- func (c *Count) Format() string
- func (m *Count) GetKind() Count_Kind
- func (m *Count) GetValue() int32
- func (*Count) ProtoMessage()
- func (m *Count) Reset()
- func (m *Count) String() string
- func (m *Count) XXX_DiscardUnknown()
- func (m *Count) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Count) XXX_Merge(src proto.Message)
- func (m *Count) XXX_Size() int
- func (m *Count) XXX_Unmarshal(b []byte) error
- type Count_Kind
- type DisconnectRequest
- func (*DisconnectRequest) Descriptor() ([]byte, []int)
- func (*DisconnectRequest) ProtoMessage()
- func (m *DisconnectRequest) Reset()
- func (m *DisconnectRequest) String() string
- func (m *DisconnectRequest) XXX_DiscardUnknown()
- func (m *DisconnectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DisconnectRequest) XXX_Merge(src proto.Message)
- func (m *DisconnectRequest) XXX_Size() int
- func (m *DisconnectRequest) XXX_Unmarshal(b []byte) error
- type DisconnectResponse
- func (*DisconnectResponse) Descriptor() ([]byte, []int)
- func (*DisconnectResponse) ProtoMessage()
- func (m *DisconnectResponse) Reset()
- func (m *DisconnectResponse) String() string
- func (m *DisconnectResponse) XXX_DiscardUnknown()
- func (m *DisconnectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DisconnectResponse) XXX_Merge(src proto.Message)
- func (m *DisconnectResponse) XXX_Size() int
- func (m *DisconnectResponse) XXX_Unmarshal(b []byte) error
- type DiscoverShapesRequest
- func (*DiscoverShapesRequest) Descriptor() ([]byte, []int)
- func (m *DiscoverShapesRequest) GetMode() DiscoverShapesRequest_Mode
- func (m *DiscoverShapesRequest) GetSampleSize() uint32
- func (m *DiscoverShapesRequest) GetToRefresh() []*Shape
- func (*DiscoverShapesRequest) ProtoMessage()
- func (m *DiscoverShapesRequest) Reset()
- func (m *DiscoverShapesRequest) String() string
- func (m *DiscoverShapesRequest) XXX_DiscardUnknown()
- func (m *DiscoverShapesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DiscoverShapesRequest) XXX_Merge(src proto.Message)
- func (m *DiscoverShapesRequest) XXX_Size() int
- func (m *DiscoverShapesRequest) XXX_Unmarshal(b []byte) error
- type DiscoverShapesRequest_Mode
- type DiscoverShapesResponse
- func (*DiscoverShapesResponse) Descriptor() ([]byte, []int)
- func (m *DiscoverShapesResponse) GetShapes() []*Shape
- func (*DiscoverShapesResponse) ProtoMessage()
- func (m *DiscoverShapesResponse) Reset()
- func (m *DiscoverShapesResponse) String() string
- func (m *DiscoverShapesResponse) XXX_DiscardUnknown()
- func (m *DiscoverShapesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DiscoverShapesResponse) XXX_Merge(src proto.Message)
- func (m *DiscoverShapesResponse) XXX_Size() int
- func (m *DiscoverShapesResponse) XXX_Unmarshal(b []byte) error
- type OAuthConfiguration
- func (*OAuthConfiguration) Descriptor() ([]byte, []int)
- func (m *OAuthConfiguration) GetClientId() string
- func (m *OAuthConfiguration) GetClientSecret() string
- func (m *OAuthConfiguration) GetConfigurationJson() string
- func (*OAuthConfiguration) ProtoMessage()
- func (m *OAuthConfiguration) Reset()
- func (m *OAuthConfiguration) String() string
- func (m *OAuthConfiguration) XXX_DiscardUnknown()
- func (m *OAuthConfiguration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *OAuthConfiguration) XXX_Merge(src proto.Message)
- func (m *OAuthConfiguration) XXX_Size() int
- func (m *OAuthConfiguration) XXX_Unmarshal(b []byte) error
- type Property
- func (*Property) Descriptor() ([]byte, []int)
- func (m *Property) GetDescription() string
- func (m *Property) GetId() string
- func (m *Property) GetIsCreateCounter() bool
- func (m *Property) GetIsKey() bool
- func (m *Property) GetIsNullable() bool
- func (m *Property) GetIsUpdateCounter() bool
- func (m *Property) GetName() string
- func (m *Property) GetPublisherMetaJson() string
- func (m *Property) GetType() PropertyType
- func (m *Property) GetTypeAtSource() string
- func (*Property) ProtoMessage()
- func (m *Property) Reset()
- func (m *Property) String() string
- func (m *Property) XXX_DiscardUnknown()
- func (m *Property) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Property) XXX_Merge(src proto.Message)
- func (m *Property) XXX_Size() int
- func (m *Property) XXX_Unmarshal(b []byte) error
- type PropertyType
- type PublishFilter
- func (*PublishFilter) Descriptor() ([]byte, []int)
- func (m *PublishFilter) GetKind() PublishFilter_Kind
- func (m *PublishFilter) GetPropertyId() string
- func (m *PublishFilter) GetValue() string
- func (*PublishFilter) ProtoMessage()
- func (m *PublishFilter) Reset()
- func (m *PublishFilter) String() string
- func (m *PublishFilter) XXX_DiscardUnknown()
- func (m *PublishFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *PublishFilter) XXX_Merge(src proto.Message)
- func (m *PublishFilter) XXX_Size() int
- func (m *PublishFilter) XXX_Unmarshal(b []byte) error
- type PublishFilter_Kind
- type PublishRequest
- func (*PublishRequest) Descriptor() ([]byte, []int)
- func (m *PublishRequest) GetConnectionSettingsJson() string
- func (m *PublishRequest) GetFilters() []*PublishFilter
- func (m *PublishRequest) GetLimit() uint32
- func (m *PublishRequest) GetRealTimeSettingsJson() string
- func (m *PublishRequest) GetRealTimeStateJson() string
- func (m *PublishRequest) GetShape() *Shape
- func (*PublishRequest) ProtoMessage()
- func (m *PublishRequest) Reset()
- func (m *PublishRequest) String() string
- func (m *PublishRequest) XXX_DiscardUnknown()
- func (m *PublishRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *PublishRequest) XXX_Merge(src proto.Message)
- func (m *PublishRequest) XXX_Size() int
- func (m *PublishRequest) XXX_Unmarshal(b []byte) error
- type PublisherClient
- type PublisherServer
- type Publisher_ConnectSessionClient
- type Publisher_ConnectSessionServer
- type Publisher_PublishStreamClient
- type Publisher_PublishStreamServer
- type Record
- func (*Record) Descriptor() ([]byte, []int)
- func (m *Record) GetAction() Record_Action
- func (m *Record) GetDataJson() string
- func (m *Record) GetRealTimeStateJson() string
- func (*Record) ProtoMessage()
- func (m *Record) Reset()
- func (m *Record) String() string
- func (m *Record) XXX_DiscardUnknown()
- func (m *Record) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Record) XXX_Merge(src proto.Message)
- func (m *Record) XXX_Size() int
- func (m *Record) XXX_Unmarshal(b []byte) error
- type Record_Action
- type Shape
- func (*Shape) Descriptor() ([]byte, []int)
- func (m *Shape) GetCount() *Count
- func (m *Shape) GetDescription() string
- func (m *Shape) GetErrors() []string
- func (m *Shape) GetId() string
- func (m *Shape) GetName() string
- func (m *Shape) GetProperties() []*Property
- func (m *Shape) GetPublisherMetaJson() string
- func (m *Shape) GetQuery() string
- func (m *Shape) GetSample() []*Record
- func (*Shape) ProtoMessage()
- func (m *Shape) Reset()
- func (m *Shape) String() string
- func (m *Shape) XXX_DiscardUnknown()
- func (m *Shape) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Shape) XXX_Merge(src proto.Message)
- func (m *Shape) XXX_Size() int
- func (m *Shape) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var Count_Kind_name = map[int32]string{
0: "UNAVAILABLE",
1: "ESTIMATE",
2: "EXACT",
}
View Source
var Count_Kind_value = map[string]int32{
"UNAVAILABLE": 0,
"ESTIMATE": 1,
"EXACT": 2,
}
View Source
var DiscoverShapesRequest_Mode_name = map[int32]string{
0: "ALL",
1: "REFRESH",
}
View Source
var DiscoverShapesRequest_Mode_value = map[string]int32{
"ALL": 0,
"REFRESH": 1,
}
View Source
var PropertyType_name = map[int32]string{
0: "STRING",
2: "BOOL",
3: "INTEGER",
4: "FLOAT",
5: "DECIMAL",
6: "DATE",
7: "TIME",
8: "DATETIME",
9: "TEXT",
10: "BLOB",
11: "JSON",
12: "XML",
}
View Source
var PropertyType_value = map[string]int32{
"STRING": 0,
"BOOL": 2,
"INTEGER": 3,
"FLOAT": 4,
"DECIMAL": 5,
"DATE": 6,
"TIME": 7,
"DATETIME": 8,
"TEXT": 9,
"BLOB": 10,
"JSON": 11,
"XML": 12,
}
View Source
var PublishFilter_Kind_name = map[int32]string{
0: "EQUALS",
1: "LESS_THAN",
2: "GREATER_THAN",
}
View Source
var PublishFilter_Kind_value = map[string]int32{
"EQUALS": 0,
"LESS_THAN": 1,
"GREATER_THAN": 2,
}
View Source
var Record_Action_name = map[int32]string{
0: "UPSERT",
1: "INSERT",
2: "UPDATE",
3: "DELETE",
4: "REAL_TIME_STATE_COMMIT",
}
View Source
var Record_Action_value = map[string]int32{
"UPSERT": 0,
"INSERT": 1,
"UPDATE": 2,
"DELETE": 3,
"REAL_TIME_STATE_COMMIT": 4,
}
Functions ¶
func NewClientPlugin ¶
NewClientPlugin returns a plugin.Plugin for use as a client. This is the method to call from the host when creating a new plugin.ClientConfig.
func NewServerPlugin ¶
func NewServerPlugin(handler PublisherServer) plugin.Plugin
NewServerPlugin returns a plugin.Plugin for use as a server. This is the method to call from the plugin implementation when creating a new plugin.ServeConfig.
func RegisterPublisherServer ¶
func RegisterPublisherServer(s *grpc.Server, srv PublisherServer)
Types ¶
type BeginOAuthFlowRequest ¶
type BeginOAuthFlowRequest struct {
Configuration *OAuthConfiguration `protobuf:"bytes,1,opt,name=configuration,proto3" json:"configuration,omitempty"`
// The URL that the auth server should send the authorization token to.
RedirectUrl string `protobuf:"bytes,2,opt,name=redirect_url,json=redirectUrl,proto3" json:"redirect_url,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*BeginOAuthFlowRequest) Descriptor ¶
func (*BeginOAuthFlowRequest) Descriptor() ([]byte, []int)
func (*BeginOAuthFlowRequest) GetConfiguration ¶
func (m *BeginOAuthFlowRequest) GetConfiguration() *OAuthConfiguration
func (*BeginOAuthFlowRequest) GetRedirectUrl ¶
func (m *BeginOAuthFlowRequest) GetRedirectUrl() string
func (*BeginOAuthFlowRequest) ProtoMessage ¶
func (*BeginOAuthFlowRequest) ProtoMessage()
func (*BeginOAuthFlowRequest) Reset ¶
func (m *BeginOAuthFlowRequest) Reset()
func (*BeginOAuthFlowRequest) String ¶
func (m *BeginOAuthFlowRequest) String() string
func (*BeginOAuthFlowRequest) XXX_DiscardUnknown ¶
func (m *BeginOAuthFlowRequest) XXX_DiscardUnknown()
func (*BeginOAuthFlowRequest) XXX_Marshal ¶
func (m *BeginOAuthFlowRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BeginOAuthFlowRequest) XXX_Merge ¶
func (dst *BeginOAuthFlowRequest) XXX_Merge(src proto.Message)
func (*BeginOAuthFlowRequest) XXX_Size ¶
func (m *BeginOAuthFlowRequest) XXX_Size() int
func (*BeginOAuthFlowRequest) XXX_Unmarshal ¶
func (m *BeginOAuthFlowRequest) XXX_Unmarshal(b []byte) error
type BeginOAuthFlowResponse ¶
type BeginOAuthFlowResponse struct {
// The URL the user should use to start the authorization process.
AuthorizationUrl string `protobuf:"bytes,1,opt,name=authorization_url,json=authorizationUrl,proto3" json:"authorization_url,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*BeginOAuthFlowResponse) Descriptor ¶
func (*BeginOAuthFlowResponse) Descriptor() ([]byte, []int)
func (*BeginOAuthFlowResponse) GetAuthorizationUrl ¶
func (m *BeginOAuthFlowResponse) GetAuthorizationUrl() string
func (*BeginOAuthFlowResponse) ProtoMessage ¶
func (*BeginOAuthFlowResponse) ProtoMessage()
func (*BeginOAuthFlowResponse) Reset ¶
func (m *BeginOAuthFlowResponse) Reset()
func (*BeginOAuthFlowResponse) String ¶
func (m *BeginOAuthFlowResponse) String() string
func (*BeginOAuthFlowResponse) XXX_DiscardUnknown ¶
func (m *BeginOAuthFlowResponse) XXX_DiscardUnknown()
func (*BeginOAuthFlowResponse) XXX_Marshal ¶
func (m *BeginOAuthFlowResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BeginOAuthFlowResponse) XXX_Merge ¶
func (dst *BeginOAuthFlowResponse) XXX_Merge(src proto.Message)
func (*BeginOAuthFlowResponse) XXX_Size ¶
func (m *BeginOAuthFlowResponse) XXX_Size() int
func (*BeginOAuthFlowResponse) XXX_Unmarshal ¶
func (m *BeginOAuthFlowResponse) XXX_Unmarshal(b []byte) error
type CompleteOAuthFlowRequest ¶
type CompleteOAuthFlowRequest struct {
Configuration *OAuthConfiguration `protobuf:"bytes,1,opt,name=configuration,proto3" json:"configuration,omitempty"`
// The URL that the OAuth flow redirected the user to after authentication.
// If the response_mode was 'query' this will contain the token.
RedirectUrl string `protobuf:"bytes,2,opt,name=redirect_url,json=redirectUrl,proto3" json:"redirect_url,omitempty"`
// The body that the OAuth flow caused to be posted if the response_mode
// for the redirect was 'form_post'.
RedirectBody string `protobuf:"bytes,3,opt,name=redirect_body,json=redirectBody,proto3" json:"redirect_body,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*CompleteOAuthFlowRequest) Descriptor ¶
func (*CompleteOAuthFlowRequest) Descriptor() ([]byte, []int)
func (*CompleteOAuthFlowRequest) GetConfiguration ¶
func (m *CompleteOAuthFlowRequest) GetConfiguration() *OAuthConfiguration
func (*CompleteOAuthFlowRequest) GetRedirectBody ¶
func (m *CompleteOAuthFlowRequest) GetRedirectBody() string
func (*CompleteOAuthFlowRequest) GetRedirectUrl ¶
func (m *CompleteOAuthFlowRequest) GetRedirectUrl() string
func (*CompleteOAuthFlowRequest) ProtoMessage ¶
func (*CompleteOAuthFlowRequest) ProtoMessage()
func (*CompleteOAuthFlowRequest) Reset ¶
func (m *CompleteOAuthFlowRequest) Reset()
func (*CompleteOAuthFlowRequest) String ¶
func (m *CompleteOAuthFlowRequest) String() string
func (*CompleteOAuthFlowRequest) XXX_DiscardUnknown ¶
func (m *CompleteOAuthFlowRequest) XXX_DiscardUnknown()
func (*CompleteOAuthFlowRequest) XXX_Marshal ¶
func (m *CompleteOAuthFlowRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CompleteOAuthFlowRequest) XXX_Merge ¶
func (dst *CompleteOAuthFlowRequest) XXX_Merge(src proto.Message)
func (*CompleteOAuthFlowRequest) XXX_Size ¶
func (m *CompleteOAuthFlowRequest) XXX_Size() int
func (*CompleteOAuthFlowRequest) XXX_Unmarshal ¶
func (m *CompleteOAuthFlowRequest) XXX_Unmarshal(b []byte) error
type CompleteOAuthFlowResponse ¶
type CompleteOAuthFlowResponse struct {
// JSON data containing the OAuth information the plugin wants
// to be passed to any connect request.
OauthStateJson string `protobuf:"bytes,1,opt,name=oauth_state_json,json=oauthStateJson,proto3" json:"oauth_state_json,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*CompleteOAuthFlowResponse) Descriptor ¶
func (*CompleteOAuthFlowResponse) Descriptor() ([]byte, []int)
func (*CompleteOAuthFlowResponse) GetOauthStateJson ¶
func (m *CompleteOAuthFlowResponse) GetOauthStateJson() string
func (*CompleteOAuthFlowResponse) ProtoMessage ¶
func (*CompleteOAuthFlowResponse) ProtoMessage()
func (*CompleteOAuthFlowResponse) Reset ¶
func (m *CompleteOAuthFlowResponse) Reset()
func (*CompleteOAuthFlowResponse) String ¶
func (m *CompleteOAuthFlowResponse) String() string
func (*CompleteOAuthFlowResponse) XXX_DiscardUnknown ¶
func (m *CompleteOAuthFlowResponse) XXX_DiscardUnknown()
func (*CompleteOAuthFlowResponse) XXX_Marshal ¶
func (m *CompleteOAuthFlowResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CompleteOAuthFlowResponse) XXX_Merge ¶
func (dst *CompleteOAuthFlowResponse) XXX_Merge(src proto.Message)
func (*CompleteOAuthFlowResponse) XXX_Size ¶
func (m *CompleteOAuthFlowResponse) XXX_Size() int
func (*CompleteOAuthFlowResponse) XXX_Unmarshal ¶
func (m *CompleteOAuthFlowResponse) XXX_Unmarshal(b []byte) error
type ConfigurationFormRequest ¶
type ConfigurationFormRequest struct {
// JSON object containing the current values of the settings
// as entered into the UI.
DataJson string `protobuf:"bytes,1,opt,name=data_json,json=dataJson,proto3" json:"data_json,omitempty"`
// Opaque state object from the most recent Configure*Response.
StateJson string `protobuf:"bytes,2,opt,name=state_json,json=stateJson,proto3" json:"state_json,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ConfigurationFormRequest) Descriptor ¶
func (*ConfigurationFormRequest) Descriptor() ([]byte, []int)
func (*ConfigurationFormRequest) GetDataJson ¶
func (m *ConfigurationFormRequest) GetDataJson() string
func (*ConfigurationFormRequest) GetStateJson ¶
func (m *ConfigurationFormRequest) GetStateJson() string
func (*ConfigurationFormRequest) ProtoMessage ¶
func (*ConfigurationFormRequest) ProtoMessage()
func (*ConfigurationFormRequest) Reset ¶
func (m *ConfigurationFormRequest) Reset()
func (*ConfigurationFormRequest) String ¶
func (m *ConfigurationFormRequest) String() string
func (*ConfigurationFormRequest) XXX_DiscardUnknown ¶
func (m *ConfigurationFormRequest) XXX_DiscardUnknown()
func (*ConfigurationFormRequest) XXX_Marshal ¶
func (m *ConfigurationFormRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConfigurationFormRequest) XXX_Merge ¶
func (dst *ConfigurationFormRequest) XXX_Merge(src proto.Message)
func (*ConfigurationFormRequest) XXX_Size ¶
func (m *ConfigurationFormRequest) XXX_Size() int
func (*ConfigurationFormRequest) XXX_Unmarshal ¶
func (m *ConfigurationFormRequest) XXX_Unmarshal(b []byte) error
type ConfigurationFormResponse ¶
type ConfigurationFormResponse struct {
// The JSONSchema which should be used to build the form.
SchemaJson string `protobuf:"bytes,1,opt,name=schema_json,json=schemaJson,proto3" json:"schema_json,omitempty"`
// The UI hints which should be provided to the form.
UiJson string `protobuf:"bytes,2,opt,name=ui_json,json=uiJson,proto3" json:"ui_json,omitempty"`
// The state object which should be passed in any future Configure*Request as part of this configuration session.
StateJson string `protobuf:"bytes,3,opt,name=state_json,json=stateJson,proto3" json:"state_json,omitempty"`
// Current values from the form.
DataJson string `protobuf:"bytes,4,opt,name=data_json,json=dataJson,proto3" json:"data_json,omitempty"`
// Errors which should be displayed attached to fields in the form,
// in the form of a JSON object with the same shape as the data object,
// but the values are arrays of strings containing the error messages.
DataErrorsJson string `protobuf:"bytes,5,opt,name=data_errors_json,json=dataErrorsJson,proto3" json:"data_errors_json,omitempty"`
// Generic errors which should be displayed at the bottom of the form,
// not associated with any specific fields.
Errors []string `protobuf:"bytes,6,rep,name=errors,proto3" json:"errors,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ConfigurationFormResponse) Descriptor ¶
func (*ConfigurationFormResponse) Descriptor() ([]byte, []int)
func (*ConfigurationFormResponse) GetDataErrorsJson ¶
func (m *ConfigurationFormResponse) GetDataErrorsJson() string
func (*ConfigurationFormResponse) GetDataJson ¶
func (m *ConfigurationFormResponse) GetDataJson() string
func (*ConfigurationFormResponse) GetErrors ¶
func (m *ConfigurationFormResponse) GetErrors() []string
func (*ConfigurationFormResponse) GetSchemaJson ¶
func (m *ConfigurationFormResponse) GetSchemaJson() string
func (*ConfigurationFormResponse) GetStateJson ¶
func (m *ConfigurationFormResponse) GetStateJson() string
func (*ConfigurationFormResponse) GetUiJson ¶
func (m *ConfigurationFormResponse) GetUiJson() string
func (*ConfigurationFormResponse) ProtoMessage ¶
func (*ConfigurationFormResponse) ProtoMessage()
func (*ConfigurationFormResponse) Reset ¶
func (m *ConfigurationFormResponse) Reset()
func (*ConfigurationFormResponse) String ¶
func (m *ConfigurationFormResponse) String() string
func (*ConfigurationFormResponse) XXX_DiscardUnknown ¶
func (m *ConfigurationFormResponse) XXX_DiscardUnknown()
func (*ConfigurationFormResponse) XXX_Marshal ¶
func (m *ConfigurationFormResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConfigurationFormResponse) XXX_Merge ¶
func (dst *ConfigurationFormResponse) XXX_Merge(src proto.Message)
func (*ConfigurationFormResponse) XXX_Size ¶
func (m *ConfigurationFormResponse) XXX_Size() int
func (*ConfigurationFormResponse) XXX_Unmarshal ¶
func (m *ConfigurationFormResponse) XXX_Unmarshal(b []byte) error
type ConfigureConnectionRequest ¶
type ConfigureConnectionRequest struct {
// The form state for the request.
Form *ConfigurationFormRequest `protobuf:"bytes,1,opt,name=form,proto3" json:"form,omitempty"`
// An embedded ConnectRequest to support passing
// OAuth secrets into the connection configuration operation.
ConnectRequest *ConnectRequest `protobuf:"bytes,2,opt,name=connect_request,json=connectRequest,proto3" json:"connect_request,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ConfigureConnectionRequest) Descriptor ¶
func (*ConfigureConnectionRequest) Descriptor() ([]byte, []int)
func (*ConfigureConnectionRequest) GetConnectRequest ¶
func (m *ConfigureConnectionRequest) GetConnectRequest() *ConnectRequest
func (*ConfigureConnectionRequest) GetForm ¶
func (m *ConfigureConnectionRequest) GetForm() *ConfigurationFormRequest
func (*ConfigureConnectionRequest) ProtoMessage ¶
func (*ConfigureConnectionRequest) ProtoMessage()
func (*ConfigureConnectionRequest) Reset ¶
func (m *ConfigureConnectionRequest) Reset()
func (*ConfigureConnectionRequest) String ¶
func (m *ConfigureConnectionRequest) String() string
func (*ConfigureConnectionRequest) XXX_DiscardUnknown ¶
func (m *ConfigureConnectionRequest) XXX_DiscardUnknown()
func (*ConfigureConnectionRequest) XXX_Marshal ¶
func (m *ConfigureConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConfigureConnectionRequest) XXX_Merge ¶
func (dst *ConfigureConnectionRequest) XXX_Merge(src proto.Message)
func (*ConfigureConnectionRequest) XXX_Size ¶
func (m *ConfigureConnectionRequest) XXX_Size() int
func (*ConfigureConnectionRequest) XXX_Unmarshal ¶
func (m *ConfigureConnectionRequest) XXX_Unmarshal(b []byte) error
type ConfigureConnectionResponse ¶
type ConfigureConnectionResponse struct {
Form *ConfigurationFormResponse `protobuf:"bytes,1,opt,name=form,proto3" json:"form,omitempty"`
// An embedded ConnectResponse to support returning
// updated OAuth secrets from the connection configuration operation
// if the secrets have been updated.
ConnectResponse *ConnectResponse `protobuf:"bytes,2,opt,name=connect_response,json=connectResponse,proto3" json:"connect_response,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ConfigureConnectionResponse) Descriptor ¶
func (*ConfigureConnectionResponse) Descriptor() ([]byte, []int)
func (*ConfigureConnectionResponse) GetConnectResponse ¶
func (m *ConfigureConnectionResponse) GetConnectResponse() *ConnectResponse
func (*ConfigureConnectionResponse) GetForm ¶
func (m *ConfigureConnectionResponse) GetForm() *ConfigurationFormResponse
func (*ConfigureConnectionResponse) ProtoMessage ¶
func (*ConfigureConnectionResponse) ProtoMessage()
func (*ConfigureConnectionResponse) Reset ¶
func (m *ConfigureConnectionResponse) Reset()
func (*ConfigureConnectionResponse) String ¶
func (m *ConfigureConnectionResponse) String() string
func (*ConfigureConnectionResponse) XXX_DiscardUnknown ¶
func (m *ConfigureConnectionResponse) XXX_DiscardUnknown()
func (*ConfigureConnectionResponse) XXX_Marshal ¶
func (m *ConfigureConnectionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConfigureConnectionResponse) XXX_Merge ¶
func (dst *ConfigureConnectionResponse) XXX_Merge(src proto.Message)
func (*ConfigureConnectionResponse) XXX_Size ¶
func (m *ConfigureConnectionResponse) XXX_Size() int
func (*ConfigureConnectionResponse) XXX_Unmarshal ¶
func (m *ConfigureConnectionResponse) XXX_Unmarshal(b []byte) error
type ConfigureQueryRequest ¶
type ConfigureQueryRequest struct {
// The form state for the request.
Form *ConfigurationFormRequest `protobuf:"bytes,1,opt,name=form,proto3" json:"form,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ConfigureQueryRequest) Descriptor ¶
func (*ConfigureQueryRequest) Descriptor() ([]byte, []int)
func (*ConfigureQueryRequest) GetForm ¶
func (m *ConfigureQueryRequest) GetForm() *ConfigurationFormRequest
func (*ConfigureQueryRequest) ProtoMessage ¶
func (*ConfigureQueryRequest) ProtoMessage()
func (*ConfigureQueryRequest) Reset ¶
func (m *ConfigureQueryRequest) Reset()
func (*ConfigureQueryRequest) String ¶
func (m *ConfigureQueryRequest) String() string
func (*ConfigureQueryRequest) XXX_DiscardUnknown ¶
func (m *ConfigureQueryRequest) XXX_DiscardUnknown()
func (*ConfigureQueryRequest) XXX_Marshal ¶
func (m *ConfigureQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConfigureQueryRequest) XXX_Merge ¶
func (dst *ConfigureQueryRequest) XXX_Merge(src proto.Message)
func (*ConfigureQueryRequest) XXX_Size ¶
func (m *ConfigureQueryRequest) XXX_Size() int
func (*ConfigureQueryRequest) XXX_Unmarshal ¶
func (m *ConfigureQueryRequest) XXX_Unmarshal(b []byte) error
type ConfigureQueryResponse ¶
type ConfigureQueryResponse struct {
Form *ConfigurationFormResponse `protobuf:"bytes,1,opt,name=form,proto3" json:"form,omitempty"`
// The schema that this query will produce.
Shape *Shape `protobuf:"bytes,2,opt,name=shape,proto3" json:"shape,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ConfigureQueryResponse) Descriptor ¶
func (*ConfigureQueryResponse) Descriptor() ([]byte, []int)
func (*ConfigureQueryResponse) GetForm ¶
func (m *ConfigureQueryResponse) GetForm() *ConfigurationFormResponse
func (*ConfigureQueryResponse) GetShape ¶
func (m *ConfigureQueryResponse) GetShape() *Shape
func (*ConfigureQueryResponse) ProtoMessage ¶
func (*ConfigureQueryResponse) ProtoMessage()
func (*ConfigureQueryResponse) Reset ¶
func (m *ConfigureQueryResponse) Reset()
func (*ConfigureQueryResponse) String ¶
func (m *ConfigureQueryResponse) String() string
func (*ConfigureQueryResponse) XXX_DiscardUnknown ¶
func (m *ConfigureQueryResponse) XXX_DiscardUnknown()
func (*ConfigureQueryResponse) XXX_Marshal ¶
func (m *ConfigureQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConfigureQueryResponse) XXX_Merge ¶
func (dst *ConfigureQueryResponse) XXX_Merge(src proto.Message)
func (*ConfigureQueryResponse) XXX_Size ¶
func (m *ConfigureQueryResponse) XXX_Size() int
func (*ConfigureQueryResponse) XXX_Unmarshal ¶
func (m *ConfigureQueryResponse) XXX_Unmarshal(b []byte) error
type ConfigureRealTimeRequest ¶
type ConfigureRealTimeRequest struct {
// The form state for the request.
Form *ConfigurationFormRequest `protobuf:"bytes,1,opt,name=form,proto3" json:"form,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ConfigureRealTimeRequest) Descriptor ¶
func (*ConfigureRealTimeRequest) Descriptor() ([]byte, []int)
func (*ConfigureRealTimeRequest) GetForm ¶
func (m *ConfigureRealTimeRequest) GetForm() *ConfigurationFormRequest
func (*ConfigureRealTimeRequest) ProtoMessage ¶
func (*ConfigureRealTimeRequest) ProtoMessage()
func (*ConfigureRealTimeRequest) Reset ¶
func (m *ConfigureRealTimeRequest) Reset()
func (*ConfigureRealTimeRequest) String ¶
func (m *ConfigureRealTimeRequest) String() string
func (*ConfigureRealTimeRequest) XXX_DiscardUnknown ¶
func (m *ConfigureRealTimeRequest) XXX_DiscardUnknown()
func (*ConfigureRealTimeRequest) XXX_Marshal ¶
func (m *ConfigureRealTimeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConfigureRealTimeRequest) XXX_Merge ¶
func (dst *ConfigureRealTimeRequest) XXX_Merge(src proto.Message)
func (*ConfigureRealTimeRequest) XXX_Size ¶
func (m *ConfigureRealTimeRequest) XXX_Size() int
func (*ConfigureRealTimeRequest) XXX_Unmarshal ¶
func (m *ConfigureRealTimeRequest) XXX_Unmarshal(b []byte) error
type ConfigureRealTimeResponse ¶
type ConfigureRealTimeResponse struct {
Form *ConfigurationFormResponse `protobuf:"bytes,1,opt,name=form,proto3" json:"form,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ConfigureRealTimeResponse) Descriptor ¶
func (*ConfigureRealTimeResponse) Descriptor() ([]byte, []int)
func (*ConfigureRealTimeResponse) GetForm ¶
func (m *ConfigureRealTimeResponse) GetForm() *ConfigurationFormResponse
func (*ConfigureRealTimeResponse) ProtoMessage ¶
func (*ConfigureRealTimeResponse) ProtoMessage()
func (*ConfigureRealTimeResponse) Reset ¶
func (m *ConfigureRealTimeResponse) Reset()
func (*ConfigureRealTimeResponse) String ¶
func (m *ConfigureRealTimeResponse) String() string
func (*ConfigureRealTimeResponse) XXX_DiscardUnknown ¶
func (m *ConfigureRealTimeResponse) XXX_DiscardUnknown()
func (*ConfigureRealTimeResponse) XXX_Marshal ¶
func (m *ConfigureRealTimeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConfigureRealTimeResponse) XXX_Merge ¶
func (dst *ConfigureRealTimeResponse) XXX_Merge(src proto.Message)
func (*ConfigureRealTimeResponse) XXX_Size ¶
func (m *ConfigureRealTimeResponse) XXX_Size() int
func (*ConfigureRealTimeResponse) XXX_Unmarshal ¶
func (m *ConfigureRealTimeResponse) XXX_Unmarshal(b []byte) error
type ConnectRequest ¶
type ConnectRequest struct {
// The settings the publisher should use to connect, as a JSON string.
// The JSON will be based on the JSONSchema defined in the publisher's package.json.
SettingsJson string `protobuf:"bytes,2,opt,name=settings_json,json=settingsJson,proto3" json:"settings_json,omitempty"`
// OAuth configuration information which the plugin may need to
// obtain an access token using the OAuth state.
OauthConfiguration *OAuthConfiguration `protobuf:"bytes,3,opt,name=oauth_configuration,json=oauthConfiguration,proto3" json:"oauth_configuration,omitempty"`
// The OAuth state returned from the last Connect, ConnectSession, or CompleteOAuthFlow.
OauthStateJson string `protobuf:"bytes,4,opt,name=oauth_state_json,json=oauthStateJson,proto3" json:"oauth_state_json,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func NewConnectRequest ¶
func NewConnectRequest(settings interface{}) (*ConnectRequest, error)
func (*ConnectRequest) Descriptor ¶
func (*ConnectRequest) Descriptor() ([]byte, []int)
func (*ConnectRequest) GetOauthConfiguration ¶
func (m *ConnectRequest) GetOauthConfiguration() *OAuthConfiguration
func (*ConnectRequest) GetOauthStateJson ¶
func (m *ConnectRequest) GetOauthStateJson() string
func (*ConnectRequest) GetSettingsJson ¶
func (m *ConnectRequest) GetSettingsJson() string
func (*ConnectRequest) ProtoMessage ¶
func (*ConnectRequest) ProtoMessage()
func (*ConnectRequest) Reset ¶
func (m *ConnectRequest) Reset()
func (*ConnectRequest) String ¶
func (m *ConnectRequest) String() string
func (*ConnectRequest) XXX_DiscardUnknown ¶
func (m *ConnectRequest) XXX_DiscardUnknown()
func (*ConnectRequest) XXX_Marshal ¶
func (m *ConnectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConnectRequest) XXX_Merge ¶
func (dst *ConnectRequest) XXX_Merge(src proto.Message)
func (*ConnectRequest) XXX_Size ¶
func (m *ConnectRequest) XXX_Size() int
func (*ConnectRequest) XXX_Unmarshal ¶
func (m *ConnectRequest) XXX_Unmarshal(b []byte) error
type ConnectResponse ¶
type ConnectResponse struct {
// If connection settings are invalid, this should contain the problem.
SettingsError string `protobuf:"bytes,1,opt,name=settings_error,json=settingsError,proto3" json:"settings_error,omitempty"`
// If the connection settings appear valid, connecting to the target system failed,
// this should contain the error from the target system.
ConnectionError string `protobuf:"bytes,2,opt,name=connection_error,json=connectionError,proto3" json:"connection_error,omitempty"`
// If the OAuth state is invalid or expired, this should contain a description
// of the problem.
OauthError string `protobuf:"bytes,3,opt,name=oauth_error,json=oauthError,proto3" json:"oauth_error,omitempty"`
// The OAuth data which should be stored securely and passed next time
// a connection is requested. This is returned by Connect because
// forming the connection may have used up a refresh token and
// the new refresh token must now be stored.
OauthStateJson string `protobuf:"bytes,4,opt,name=oauth_state_json,json=oauthStateJson,proto3" json:"oauth_state_json,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
Connection result information.
func (*ConnectResponse) Descriptor ¶
func (*ConnectResponse) Descriptor() ([]byte, []int)
func (*ConnectResponse) GetConnectionError ¶
func (m *ConnectResponse) GetConnectionError() string
func (*ConnectResponse) GetOauthError ¶
func (m *ConnectResponse) GetOauthError() string
func (*ConnectResponse) GetOauthStateJson ¶
func (m *ConnectResponse) GetOauthStateJson() string
func (*ConnectResponse) GetSettingsError ¶
func (m *ConnectResponse) GetSettingsError() string
func (*ConnectResponse) ProtoMessage ¶
func (*ConnectResponse) ProtoMessage()
func (*ConnectResponse) Reset ¶
func (m *ConnectResponse) Reset()
func (*ConnectResponse) String ¶
func (m *ConnectResponse) String() string
func (*ConnectResponse) XXX_DiscardUnknown ¶
func (m *ConnectResponse) XXX_DiscardUnknown()
func (*ConnectResponse) XXX_Marshal ¶
func (m *ConnectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConnectResponse) XXX_Merge ¶
func (dst *ConnectResponse) XXX_Merge(src proto.Message)
func (*ConnectResponse) XXX_Size ¶
func (m *ConnectResponse) XXX_Size() int
func (*ConnectResponse) XXX_Unmarshal ¶
func (m *ConnectResponse) XXX_Unmarshal(b []byte) error
type Count ¶
type Count struct {
Kind Count_Kind `protobuf:"varint,1,opt,name=kind,proto3,enum=pub.Count_Kind" json:"kind,omitempty"`
Value int32 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Count) Descriptor ¶
func (*Count) GetKind ¶
func (m *Count) GetKind() Count_Kind
func (*Count) ProtoMessage ¶
func (*Count) ProtoMessage()
func (*Count) XXX_DiscardUnknown ¶
func (m *Count) XXX_DiscardUnknown()
func (*Count) XXX_Marshal ¶
func (*Count) XXX_Unmarshal ¶
type Count_Kind ¶
type Count_Kind int32
const ( Count_UNAVAILABLE Count_Kind = 0 Count_ESTIMATE Count_Kind = 1 Count_EXACT Count_Kind = 2 )
func (Count_Kind) EnumDescriptor ¶
func (Count_Kind) EnumDescriptor() ([]byte, []int)
func (Count_Kind) String ¶
func (x Count_Kind) String() string
type DisconnectRequest ¶
type DisconnectRequest struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*DisconnectRequest) Descriptor ¶
func (*DisconnectRequest) Descriptor() ([]byte, []int)
func (*DisconnectRequest) ProtoMessage ¶
func (*DisconnectRequest) ProtoMessage()
func (*DisconnectRequest) Reset ¶
func (m *DisconnectRequest) Reset()
func (*DisconnectRequest) String ¶
func (m *DisconnectRequest) String() string
func (*DisconnectRequest) XXX_DiscardUnknown ¶
func (m *DisconnectRequest) XXX_DiscardUnknown()
func (*DisconnectRequest) XXX_Marshal ¶
func (m *DisconnectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DisconnectRequest) XXX_Merge ¶
func (dst *DisconnectRequest) XXX_Merge(src proto.Message)
func (*DisconnectRequest) XXX_Size ¶
func (m *DisconnectRequest) XXX_Size() int
func (*DisconnectRequest) XXX_Unmarshal ¶
func (m *DisconnectRequest) XXX_Unmarshal(b []byte) error
type DisconnectResponse ¶
type DisconnectResponse struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*DisconnectResponse) Descriptor ¶
func (*DisconnectResponse) Descriptor() ([]byte, []int)
func (*DisconnectResponse) ProtoMessage ¶
func (*DisconnectResponse) ProtoMessage()
func (*DisconnectResponse) Reset ¶
func (m *DisconnectResponse) Reset()
func (*DisconnectResponse) String ¶
func (m *DisconnectResponse) String() string
func (*DisconnectResponse) XXX_DiscardUnknown ¶
func (m *DisconnectResponse) XXX_DiscardUnknown()
func (*DisconnectResponse) XXX_Marshal ¶
func (m *DisconnectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DisconnectResponse) XXX_Merge ¶
func (dst *DisconnectResponse) XXX_Merge(src proto.Message)
func (*DisconnectResponse) XXX_Size ¶
func (m *DisconnectResponse) XXX_Size() int
func (*DisconnectResponse) XXX_Unmarshal ¶
func (m *DisconnectResponse) XXX_Unmarshal(b []byte) error
type DiscoverShapesRequest ¶
type DiscoverShapesRequest struct {
// Mode is the discovery mode.
Mode DiscoverShapesRequest_Mode `protobuf:"varint,1,opt,name=mode,proto3,enum=pub.DiscoverShapesRequest_Mode" json:"mode,omitempty"`
// The shapes to refresh if mode == 1.
ToRefresh []*Shape `protobuf:"bytes,2,rep,name=to_refresh,json=toRefresh,proto3" json:"to_refresh,omitempty"`
// Size of the sample of records to include in the returned shapes.
SampleSize uint32 `protobuf:"varint,4,opt,name=sample_size,json=sampleSize,proto3" json:"sample_size,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*DiscoverShapesRequest) Descriptor ¶
func (*DiscoverShapesRequest) Descriptor() ([]byte, []int)
func (*DiscoverShapesRequest) GetMode ¶
func (m *DiscoverShapesRequest) GetMode() DiscoverShapesRequest_Mode
func (*DiscoverShapesRequest) GetSampleSize ¶
func (m *DiscoverShapesRequest) GetSampleSize() uint32
func (*DiscoverShapesRequest) GetToRefresh ¶
func (m *DiscoverShapesRequest) GetToRefresh() []*Shape
func (*DiscoverShapesRequest) ProtoMessage ¶
func (*DiscoverShapesRequest) ProtoMessage()
func (*DiscoverShapesRequest) Reset ¶
func (m *DiscoverShapesRequest) Reset()
func (*DiscoverShapesRequest) String ¶
func (m *DiscoverShapesRequest) String() string
func (*DiscoverShapesRequest) XXX_DiscardUnknown ¶
func (m *DiscoverShapesRequest) XXX_DiscardUnknown()
func (*DiscoverShapesRequest) XXX_Marshal ¶
func (m *DiscoverShapesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DiscoverShapesRequest) XXX_Merge ¶
func (dst *DiscoverShapesRequest) XXX_Merge(src proto.Message)
func (*DiscoverShapesRequest) XXX_Size ¶
func (m *DiscoverShapesRequest) XXX_Size() int
func (*DiscoverShapesRequest) XXX_Unmarshal ¶
func (m *DiscoverShapesRequest) XXX_Unmarshal(b []byte) error
type DiscoverShapesRequest_Mode ¶
type DiscoverShapesRequest_Mode int32
const ( // ALL means all shapes the publisher can publish should be returned. DiscoverShapesRequest_ALL DiscoverShapesRequest_Mode = 0 // REFRESH means the publisher return (updated) shapes identified by the partial shapes included in to_refresh. DiscoverShapesRequest_REFRESH DiscoverShapesRequest_Mode = 1 )
func (DiscoverShapesRequest_Mode) EnumDescriptor ¶
func (DiscoverShapesRequest_Mode) EnumDescriptor() ([]byte, []int)
func (DiscoverShapesRequest_Mode) String ¶
func (x DiscoverShapesRequest_Mode) String() string
type DiscoverShapesResponse ¶
type DiscoverShapesResponse struct {
// Shapes discovered by the publisher.
Shapes []*Shape `protobuf:"bytes,1,rep,name=shapes,proto3" json:"shapes,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*DiscoverShapesResponse) Descriptor ¶
func (*DiscoverShapesResponse) Descriptor() ([]byte, []int)
func (*DiscoverShapesResponse) GetShapes ¶
func (m *DiscoverShapesResponse) GetShapes() []*Shape
func (*DiscoverShapesResponse) ProtoMessage ¶
func (*DiscoverShapesResponse) ProtoMessage()
func (*DiscoverShapesResponse) Reset ¶
func (m *DiscoverShapesResponse) Reset()
func (*DiscoverShapesResponse) String ¶
func (m *DiscoverShapesResponse) String() string
func (*DiscoverShapesResponse) XXX_DiscardUnknown ¶
func (m *DiscoverShapesResponse) XXX_DiscardUnknown()
func (*DiscoverShapesResponse) XXX_Marshal ¶
func (m *DiscoverShapesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DiscoverShapesResponse) XXX_Merge ¶
func (dst *DiscoverShapesResponse) XXX_Merge(src proto.Message)
func (*DiscoverShapesResponse) XXX_Size ¶
func (m *DiscoverShapesResponse) XXX_Size() int
func (*DiscoverShapesResponse) XXX_Unmarshal ¶
func (m *DiscoverShapesResponse) XXX_Unmarshal(b []byte) error
type OAuthConfiguration ¶
type OAuthConfiguration struct {
// Client ID to use for resolving codes.
ClientId string `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
// Client secret to use for resolving codes.
ClientSecret string `protobuf:"bytes,2,opt,name=client_secret,json=clientSecret,proto3" json:"client_secret,omitempty"`
// The configuration blob stored for this plugin type,
// which can contain any data that should not be hard coded into the plugin.
ConfigurationJson string `protobuf:"bytes,3,opt,name=configuration_json,json=configurationJson,proto3" json:"configuration_json,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*OAuthConfiguration) Descriptor ¶
func (*OAuthConfiguration) Descriptor() ([]byte, []int)
func (*OAuthConfiguration) GetClientId ¶
func (m *OAuthConfiguration) GetClientId() string
func (*OAuthConfiguration) GetClientSecret ¶
func (m *OAuthConfiguration) GetClientSecret() string
func (*OAuthConfiguration) GetConfigurationJson ¶
func (m *OAuthConfiguration) GetConfigurationJson() string
func (*OAuthConfiguration) ProtoMessage ¶
func (*OAuthConfiguration) ProtoMessage()
func (*OAuthConfiguration) Reset ¶
func (m *OAuthConfiguration) Reset()
func (*OAuthConfiguration) String ¶
func (m *OAuthConfiguration) String() string
func (*OAuthConfiguration) XXX_DiscardUnknown ¶
func (m *OAuthConfiguration) XXX_DiscardUnknown()
func (*OAuthConfiguration) XXX_Marshal ¶
func (m *OAuthConfiguration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OAuthConfiguration) XXX_Merge ¶
func (dst *OAuthConfiguration) XXX_Merge(src proto.Message)
func (*OAuthConfiguration) XXX_Size ¶
func (m *OAuthConfiguration) XXX_Size() int
func (*OAuthConfiguration) XXX_Unmarshal ¶
func (m *OAuthConfiguration) XXX_Unmarshal(b []byte) error
type Property ¶
type Property struct {
// ID is the permanent, unique identifier for this property.
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// Name is an optional display name for the property.
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
// Description of this property, if available.
Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
// Type of the property. Use STRING if no other type matches.
Type PropertyType `protobuf:"varint,4,opt,name=type,proto3,enum=pub.PropertyType" json:"type,omitempty"`
// Set to true if this property is part of the primary key for this shape.
IsKey bool `protobuf:"varint,5,opt,name=is_key,json=isKey,proto3" json:"is_key,omitempty"`
// Set to true if this property is an orderable value which can be used
// to determine if one record was created more recently than another record.
// For example, a CreatedAt datetime column or an auto-incrementing integer primary key.
IsCreateCounter bool `protobuf:"varint,6,opt,name=is_create_counter,json=isCreateCounter,proto3" json:"is_create_counter,omitempty"`
// Set to true if this property is an orderable value which can be used
// to determine if one record was updated more recently than another record.
// For example, an UpdatedAt datetime column.
IsUpdateCounter bool `protobuf:"varint,7,opt,name=is_update_counter,json=isUpdateCounter,proto3" json:"is_update_counter,omitempty"`
// Arbitrary JSON blob containing information the publisher uses for things like change detection.
PublisherMetaJson string `protobuf:"bytes,8,opt,name=publisher_meta_json,json=publisherMetaJson,proto3" json:"publisher_meta_json,omitempty"`
// The type of the property as defined in the source system. Used to provide
// human-readable hints when building mappings.
TypeAtSource string `protobuf:"bytes,9,opt,name=type_at_source,json=typeAtSource,proto3" json:"type_at_source,omitempty"`
// Indicates that this property is nullable.
IsNullable bool `protobuf:"varint,10,opt,name=is_nullable,json=isNullable,proto3" json:"is_nullable,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Property) Descriptor ¶
func (*Property) GetDescription ¶
func (*Property) GetIsCreateCounter ¶
func (*Property) GetIsNullable ¶
func (*Property) GetIsUpdateCounter ¶
func (*Property) GetPublisherMetaJson ¶
func (*Property) GetType ¶
func (m *Property) GetType() PropertyType
func (*Property) GetTypeAtSource ¶
func (*Property) ProtoMessage ¶
func (*Property) ProtoMessage()
func (*Property) XXX_DiscardUnknown ¶
func (m *Property) XXX_DiscardUnknown()
func (*Property) XXX_Marshal ¶
func (*Property) XXX_Unmarshal ¶
type PropertyType ¶
type PropertyType int32
const ( // Unicode string, less than 1024 characters. PropertyType_STRING PropertyType = 0 // true/false. PropertyType_BOOL PropertyType = 2 // 64-bit integer. PropertyType_INTEGER PropertyType = 3 // 64-bit floating point number. PropertyType_FLOAT PropertyType = 4 // Absolute precision number of any size. PropertyType_DECIMAL PropertyType = 5 // Date (no time). PropertyType_DATE PropertyType = 6 // Time (no date). PropertyType_TIME PropertyType = 7 // Datetime (date and time). PropertyType_DATETIME PropertyType = 8 // Unicode string, more than 1024 characters. PropertyType_TEXT PropertyType = 9 // Binary data as a base-64 encoded string. PropertyType_BLOB PropertyType = 10 // A JSON object as a string. PropertyType_JSON PropertyType = 11 // An XML object as a string. PropertyType_XML PropertyType = 12 )
func (PropertyType) EnumDescriptor ¶
func (PropertyType) EnumDescriptor() ([]byte, []int)
func (PropertyType) String ¶
func (x PropertyType) String() string
type PublishFilter ¶
type PublishFilter struct {
// Kind of the match.
Kind PublishFilter_Kind `protobuf:"varint,1,opt,name=kind,proto3,enum=pub.PublishFilter_Kind" json:"kind,omitempty"`
// The id of the property on each record which should be matched against the value.
PropertyId string `protobuf:"bytes,2,opt,name=property_id,json=propertyId,proto3" json:"property_id,omitempty"`
// The value of the which should be matched against the named property for each record, as a string.
// The publisher is responsible for converting the value to the correct type.
Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*PublishFilter) Descriptor ¶
func (*PublishFilter) Descriptor() ([]byte, []int)
func (*PublishFilter) GetKind ¶
func (m *PublishFilter) GetKind() PublishFilter_Kind
func (*PublishFilter) GetPropertyId ¶
func (m *PublishFilter) GetPropertyId() string
func (*PublishFilter) GetValue ¶
func (m *PublishFilter) GetValue() string
func (*PublishFilter) ProtoMessage ¶
func (*PublishFilter) ProtoMessage()
func (*PublishFilter) Reset ¶
func (m *PublishFilter) Reset()
func (*PublishFilter) String ¶
func (m *PublishFilter) String() string
func (*PublishFilter) XXX_DiscardUnknown ¶
func (m *PublishFilter) XXX_DiscardUnknown()
func (*PublishFilter) XXX_Marshal ¶
func (m *PublishFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PublishFilter) XXX_Merge ¶
func (dst *PublishFilter) XXX_Merge(src proto.Message)
func (*PublishFilter) XXX_Size ¶
func (m *PublishFilter) XXX_Size() int
func (*PublishFilter) XXX_Unmarshal ¶
func (m *PublishFilter) XXX_Unmarshal(b []byte) error
type PublishFilter_Kind ¶
type PublishFilter_Kind int32
const ( // The property on the record must equal the filter value. PublishFilter_EQUALS PublishFilter_Kind = 0 // The property on the record must be less than the filter value. PublishFilter_LESS_THAN PublishFilter_Kind = 1 // The property on the record must be greater than the filter value. PublishFilter_GREATER_THAN PublishFilter_Kind = 2 )
func (PublishFilter_Kind) EnumDescriptor ¶
func (PublishFilter_Kind) EnumDescriptor() ([]byte, []int)
func (PublishFilter_Kind) String ¶
func (x PublishFilter_Kind) String() string
type PublishRequest ¶
type PublishRequest struct {
// The shape of the records to publish.
Shape *Shape `protobuf:"bytes,1,opt,name=shape,proto3" json:"shape,omitempty"`
// Limit of number of records to return.
Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
// Zero or more filters which should be applied to the returned records.
Filters []*PublishFilter `protobuf:"bytes,3,rep,name=filters,proto3" json:"filters,omitempty"`
// Settings for connecting, if not already connected.
ConnectionSettingsJson string `` /* 129-byte string literal not displayed */
// Settings for real time publishing, if any.
RealTimeSettingsJson string `protobuf:"bytes,6,opt,name=real_time_settings_json,json=realTimeSettingsJson,proto3" json:"real_time_settings_json,omitempty"`
// State object from the last published record from the
// connection used for this publish request.
RealTimeStateJson string `protobuf:"bytes,7,opt,name=real_time_state_json,json=realTimeStateJson,proto3" json:"real_time_state_json,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*PublishRequest) Descriptor ¶
func (*PublishRequest) Descriptor() ([]byte, []int)
func (*PublishRequest) GetConnectionSettingsJson ¶
func (m *PublishRequest) GetConnectionSettingsJson() string
func (*PublishRequest) GetFilters ¶
func (m *PublishRequest) GetFilters() []*PublishFilter
func (*PublishRequest) GetLimit ¶
func (m *PublishRequest) GetLimit() uint32
func (*PublishRequest) GetRealTimeSettingsJson ¶
func (m *PublishRequest) GetRealTimeSettingsJson() string
func (*PublishRequest) GetRealTimeStateJson ¶
func (m *PublishRequest) GetRealTimeStateJson() string
func (*PublishRequest) GetShape ¶
func (m *PublishRequest) GetShape() *Shape
func (*PublishRequest) ProtoMessage ¶
func (*PublishRequest) ProtoMessage()
func (*PublishRequest) Reset ¶
func (m *PublishRequest) Reset()
func (*PublishRequest) String ¶
func (m *PublishRequest) String() string
func (*PublishRequest) XXX_DiscardUnknown ¶
func (m *PublishRequest) XXX_DiscardUnknown()
func (*PublishRequest) XXX_Marshal ¶
func (m *PublishRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PublishRequest) XXX_Merge ¶
func (dst *PublishRequest) XXX_Merge(src proto.Message)
func (*PublishRequest) XXX_Size ¶
func (m *PublishRequest) XXX_Size() int
func (*PublishRequest) XXX_Unmarshal ¶
func (m *PublishRequest) XXX_Unmarshal(b []byte) error
type PublisherClient ¶
type PublisherClient interface {
// Instructs the publisher to connect to its data source.
Connect(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*ConnectResponse, error)
// Instructs the plugin to connect to its data source
// and maintain a session where any change in the connection state
// or updates to OAuth information are streamed back to the host.
// The plugin should maintain this connection until Disconnect is called.
// This must be implemented if the plugin manifest has `canUseOAuth` set to true.
ConnectSession(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (Publisher_ConnectSessionClient, error)
// Requests a listing of shapes this publisher can provide records for.
DiscoverShapes(ctx context.Context, in *DiscoverShapesRequest, opts ...grpc.CallOption) (*DiscoverShapesResponse, error)
// PublishString begins streaming records to the client from the plugin.
PublishStream(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (Publisher_PublishStreamClient, error)
// Tells the publisher to disconnect from its data source, stop any running publishes,
// and gracefully prepare to be shut down.
Disconnect(ctx context.Context, in *DisconnectRequest, opts ...grpc.CallOption) (*DisconnectResponse, error)
// Configures a connection which can be used to connect to a data source.
// This must be implemented if the plugin manifest has `canConfigureConnection` set to true.
// This is an alternative to having a `configSchema` element in the manifest.
ConfigureConnection(ctx context.Context, in *ConfigureConnectionRequest, opts ...grpc.CallOption) (*ConfigureConnectionResponse, error)
// Configures a query which can be used to publish a shape.
// This must be implemented if the plugin manifest has `canConfigureQuery` set to true.
ConfigureQuery(ctx context.Context, in *ConfigureQueryRequest, opts ...grpc.CallOption) (*ConfigureQueryResponse, error)
// Configures settings for real time publishing (change detection).
// This must be implemented if the plugin manifest has `canPublishRealTime` set to true.
ConfigureRealTime(ctx context.Context, in *ConfigureRealTimeRequest, opts ...grpc.CallOption) (*ConfigureRealTimeResponse, error)
// Invoked to begin an OAuth flow. This must be implemented if the plugin
// manifest has `canUseOAuth` set to true.
BeginOAuthFlow(ctx context.Context, in *BeginOAuthFlowRequest, opts ...grpc.CallOption) (*BeginOAuthFlowResponse, error)
// Invoked to complete an OAuth flow. This must be implemented if the plugin
// manifest has `canUseOAuth` set to true.
CompleteOAuthFlow(ctx context.Context, in *CompleteOAuthFlowRequest, opts ...grpc.CallOption) (*CompleteOAuthFlowResponse, error)
}
PublisherClient is the client API for Publisher service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewPublisherClient ¶
func NewPublisherClient(cc *grpc.ClientConn) PublisherClient
type PublisherServer ¶
type PublisherServer interface {
// Instructs the publisher to connect to its data source.
Connect(context.Context, *ConnectRequest) (*ConnectResponse, error)
// Instructs the plugin to connect to its data source
// and maintain a session where any change in the connection state
// or updates to OAuth information are streamed back to the host.
// The plugin should maintain this connection until Disconnect is called.
// This must be implemented if the plugin manifest has `canUseOAuth` set to true.
ConnectSession(*ConnectRequest, Publisher_ConnectSessionServer) error
// Requests a listing of shapes this publisher can provide records for.
DiscoverShapes(context.Context, *DiscoverShapesRequest) (*DiscoverShapesResponse, error)
// PublishString begins streaming records to the client from the plugin.
PublishStream(*PublishRequest, Publisher_PublishStreamServer) error
// Tells the publisher to disconnect from its data source, stop any running publishes,
// and gracefully prepare to be shut down.
Disconnect(context.Context, *DisconnectRequest) (*DisconnectResponse, error)
// Configures a connection which can be used to connect to a data source.
// This must be implemented if the plugin manifest has `canConfigureConnection` set to true.
// This is an alternative to having a `configSchema` element in the manifest.
ConfigureConnection(context.Context, *ConfigureConnectionRequest) (*ConfigureConnectionResponse, error)
// Configures a query which can be used to publish a shape.
// This must be implemented if the plugin manifest has `canConfigureQuery` set to true.
ConfigureQuery(context.Context, *ConfigureQueryRequest) (*ConfigureQueryResponse, error)
// Configures settings for real time publishing (change detection).
// This must be implemented if the plugin manifest has `canPublishRealTime` set to true.
ConfigureRealTime(context.Context, *ConfigureRealTimeRequest) (*ConfigureRealTimeResponse, error)
// Invoked to begin an OAuth flow. This must be implemented if the plugin
// manifest has `canUseOAuth` set to true.
BeginOAuthFlow(context.Context, *BeginOAuthFlowRequest) (*BeginOAuthFlowResponse, error)
// Invoked to complete an OAuth flow. This must be implemented if the plugin
// manifest has `canUseOAuth` set to true.
CompleteOAuthFlow(context.Context, *CompleteOAuthFlowRequest) (*CompleteOAuthFlowResponse, error)
}
PublisherServer is the server API for Publisher service.
type Publisher_ConnectSessionClient ¶
type Publisher_ConnectSessionClient interface {
Recv() (*ConnectResponse, error)
grpc.ClientStream
}
type Publisher_ConnectSessionServer ¶
type Publisher_ConnectSessionServer interface {
Send(*ConnectResponse) error
grpc.ServerStream
}
type Publisher_PublishStreamClient ¶
type Publisher_PublishStreamClient interface {
Recv() (*Record, error)
grpc.ClientStream
}
type Publisher_PublishStreamServer ¶
type Publisher_PublishStreamServer interface {
Send(*Record) error
grpc.ServerStream
}
type Record ¶
type Record struct {
// Action for this record. Default value is UPSERT if the plugin
// cannot determine what the action should be relative to data alreay acquired.
Action Record_Action `protobuf:"varint,1,opt,name=action,proto3,enum=pub.Record_Action" json:"action,omitempty"`
// Data for this record, as a JSON string.
DataJson string `protobuf:"bytes,2,opt,name=data_json,json=dataJson,proto3" json:"data_json,omitempty"`
// State which should be preserved and passed back to the next
// call of PublishStream. Only considered if action indicates this is a state commit.
RealTimeStateJson string `protobuf:"bytes,3,opt,name=real_time_state_json,json=realTimeStateJson,proto3" json:"real_time_state_json,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func NewRecord ¶
func NewRecord(action Record_Action, data interface{}) (*Record, error)
func (*Record) Descriptor ¶
func (*Record) GetAction ¶
func (m *Record) GetAction() Record_Action
func (*Record) GetDataJson ¶
func (*Record) GetRealTimeStateJson ¶
func (*Record) ProtoMessage ¶
func (*Record) ProtoMessage()
func (*Record) XXX_DiscardUnknown ¶
func (m *Record) XXX_DiscardUnknown()
func (*Record) XXX_Marshal ¶
func (*Record) XXX_Unmarshal ¶
type Record_Action ¶
type Record_Action int32
const ( Record_UPSERT Record_Action = 0 Record_INSERT Record_Action = 1 Record_UPDATE Record_Action = 2 Record_DELETE Record_Action = 3 // This action indicates that there is no data in this record; // instead the real time state field on this record should be persisted. Record_REAL_TIME_STATE_COMMIT Record_Action = 4 )
func (Record_Action) EnumDescriptor ¶
func (Record_Action) EnumDescriptor() ([]byte, []int)
func (Record_Action) String ¶
func (x Record_Action) String() string
type Shape ¶
type Shape struct {
// ID that the plugin uses to uniquely identify this shape.
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// Name of this shape (must be a permanant identifier which is unique in this source).
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
// Description of this shape, if available.
Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
// Properties of this shape.
Properties []*Property `protobuf:"bytes,4,rep,name=properties,proto3" json:"properties,omitempty"`
// Count of records available in this shape.
Count *Count `protobuf:"bytes,5,opt,name=count,proto3" json:"count,omitempty"`
// Sample containing zero or more records representative of the data in this shape.
Sample []*Record `protobuf:"bytes,6,rep,name=sample,proto3" json:"sample,omitempty"`
// When returned from a publisher, the optional query which can be passed to the publisher to publish records from this shape.
// When passed to the publisher, the query which should be used to publish records from this shape.
Query string `protobuf:"bytes,7,opt,name=query,proto3" json:"query,omitempty"`
// Arbitrary JSON blob containing information the publisher uses for things like change detection.
PublisherMetaJson string `protobuf:"bytes,8,opt,name=publisher_meta_json,json=publisherMetaJson,proto3" json:"publisher_meta_json,omitempty"`
// Errors that occurred while discovering this shape.
Errors []string `protobuf:"bytes,9,rep,name=errors,proto3" json:"errors,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Shape) Descriptor ¶
func (*Shape) GetDescription ¶
func (*Shape) GetProperties ¶
func (*Shape) GetPublisherMetaJson ¶
func (*Shape) ProtoMessage ¶
func (*Shape) ProtoMessage()
func (*Shape) XXX_DiscardUnknown ¶
func (m *Shape) XXX_DiscardUnknown()
func (*Shape) XXX_Marshal ¶
func (*Shape) XXX_Unmarshal ¶
Click to show internal directories.
Click to hide internal directories.