pub

package
v0.0.0-...-3223366 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 15, 2024 License: MIT Imports: 18 Imported by: 0

Documentation

Index

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 DiscoverSchemasRequest_Mode_name = map[int32]string{
	0: "ALL",
	1: "REFRESH",
}
View Source 
var DiscoverSchemasRequest_Mode_value = map[string]int32{
	"ALL":     0,
	"REFRESH": 1,
}
View Source 
var LogLevel_name = map[int32]string{
	0: "Error",
	1: "Warn",
	2: "Info",
	3: "Debug",
	4: "Trace",
}
View Source 
var LogLevel_value = map[string]int32{
	"Error": 0,
	"Warn":  1,
	"Info":  2,
	"Debug": 3,
	"Trace": 4,
}
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,
}
View Source 
var Schema_DataFlowDirection_name = map[int32]string{
	0: "READ",
	1: "WRITE",
	2: "READ_WRITE",
}
View Source 
var Schema_DataFlowDirection_value = map[string]int32{
	"READ":       0,
	"WRITE":      1,
	"READ_WRITE": 2,
}

Functions

func AdaptHCLog 

func AdaptHCLog(log *logrus.Entry) hclog.Logger

func NewClientPlugin 

func NewClientPlugin(log *logrus.Entry) plugin.Plugin

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 (m *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 (m *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 (m *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 (m *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"`
	// If true, the user has indicated that they want to save the current
	// settings, so the plugin should perform final validation
	// and may attempt to perform any destructive actions needed
	// to apply the settings.
	IsSave               bool     `protobuf:"varint,3,opt,name=is_save,json=isSave,proto3" json:"is_save,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) GetIsSave 

func (m *ConfigurationFormRequest) GetIsSave() bool

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 (m *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 schema 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 (m *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 ConfigurationFormResponseBuilder 

type ConfigurationFormResponseBuilder struct {
	Response   *ConfigurationFormResponse
	FormSchema *jsonschema.JSONSchema
	UISchema   map[string]interface{}
	Data       map[string]interface{}
}

func NewConfigurationFormResponseBuilder 

func NewConfigurationFormResponseBuilder(req *ConfigurationFormRequest) *ConfigurationFormResponseBuilder

func (*ConfigurationFormResponseBuilder) Build 

func (c *ConfigurationFormResponseBuilder) Build() *ConfigurationFormResponse

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 (m *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 (m *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 (m *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.
	Schema               *Schema  `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,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) GetSchema 

func (m *ConfigureQueryResponse) GetSchema() *Schema

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 (m *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"`
	// The schema (schema) which is being targeted for real time publishing.
	Schema               *Schema  `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,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) GetSchema 

func (m *ConfigureRealTimeRequest) GetSchema() *Schema

func (*ConfigureRealTimeRequest) ProtoMessage 

func (*ConfigureRealTimeRequest) ProtoMessage()

func (*ConfigureRealTimeRequest) Reset 

func (m *ConfigureRealTimeRequest) Reset()

func (*ConfigureRealTimeRequest) String 

func (m *ConfigureRealTimeRequest) String() string

func (*ConfigureRealTimeRequest) WithData 

func (m *ConfigureRealTimeRequest) WithData(data interface{}) *ConfigureRealTimeRequest

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 (m *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) GetDataErrorsJSONAsErrorMap 

func (m *ConfigureRealTimeResponse) GetDataErrorsJSONAsErrorMap() map[string]interface{}

func (*ConfigureRealTimeResponse) GetForm 

func (m *ConfigureRealTimeResponse) GetForm() *ConfigurationFormResponse

func (*ConfigureRealTimeResponse) GetJSONSchemaForForm 

func (m *ConfigureRealTimeResponse) GetJSONSchemaForForm() *jsonschema.JSONSchema

func (*ConfigureRealTimeResponse) ProtoMessage 

func (*ConfigureRealTimeResponse) ProtoMessage()

func (*ConfigureRealTimeResponse) Reset 

func (m *ConfigureRealTimeResponse) Reset()

func (*ConfigureRealTimeResponse) String 

func (m *ConfigureRealTimeResponse) String() string

func (*ConfigureRealTimeResponse) WithFormErrors 

func (m *ConfigureRealTimeResponse) WithFormErrors(errs ...string) *ConfigureRealTimeResponse

func (*ConfigureRealTimeResponse) WithSchema 

func (m *ConfigureRealTimeResponse) WithSchema(schema *jsonschema.JSONSchema) *ConfigureRealTimeResponse

func (*ConfigureRealTimeResponse) WithUI 

func (m *ConfigureRealTimeResponse) WithUI(ui map[string]interface{}) *ConfigureRealTimeResponse

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 (m *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 ConfigureReplicationRequest 

type ConfigureReplicationRequest struct {
	// Configuration object to build the ui
	Form *ConfigurationFormRequest `protobuf:"bytes,1,opt,name=form,proto3" json:"form,omitempty"`
	// The schema (based on a shape) which is being replicated.
	Schema *Schema `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	// The versions which will be written back with this replication.
	Versions             []*ReplicationWriteVersion `protobuf:"bytes,3,rep,name=versions,proto3" json:"versions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*ConfigureReplicationRequest) Descriptor 

func (*ConfigureReplicationRequest) Descriptor() ([]byte, []int)

func (*ConfigureReplicationRequest) GetForm 

func (m *ConfigureReplicationRequest) GetForm() *ConfigurationFormRequest

func (*ConfigureReplicationRequest) GetSchema 

func (m *ConfigureReplicationRequest) GetSchema() *Schema

func (*ConfigureReplicationRequest) GetVersions 

func (m *ConfigureReplicationRequest) GetVersions() []*ReplicationWriteVersion

func (*ConfigureReplicationRequest) ProtoMessage 

func (*ConfigureReplicationRequest) ProtoMessage()

func (*ConfigureReplicationRequest) Reset 

func (m *ConfigureReplicationRequest) Reset()

func (*ConfigureReplicationRequest) String 

func (m *ConfigureReplicationRequest) String() string

func (*ConfigureReplicationRequest) XXX_DiscardUnknown 

func (m *ConfigureReplicationRequest) XXX_DiscardUnknown()

func (*ConfigureReplicationRequest) XXX_Marshal 

func (m *ConfigureReplicationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigureReplicationRequest) XXX_Merge 

func (m *ConfigureReplicationRequest) XXX_Merge(src proto.Message)

func (*ConfigureReplicationRequest) XXX_Size 

func (m *ConfigureReplicationRequest) XXX_Size() int

func (*ConfigureReplicationRequest) XXX_Unmarshal 

func (m *ConfigureReplicationRequest) XXX_Unmarshal(b []byte) error

type ConfigureReplicationResponse 

type ConfigureReplicationResponse struct {
	// Configuration object to build the ui
	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 (*ConfigureReplicationResponse) Descriptor 

func (*ConfigureReplicationResponse) Descriptor() ([]byte, []int)

func (*ConfigureReplicationResponse) GetForm 

func (m *ConfigureReplicationResponse) GetForm() *ConfigurationFormResponse

func (*ConfigureReplicationResponse) ProtoMessage 

func (*ConfigureReplicationResponse) ProtoMessage()

func (*ConfigureReplicationResponse) Reset 

func (m *ConfigureReplicationResponse) Reset()

func (*ConfigureReplicationResponse) String 

func (m *ConfigureReplicationResponse) String() string

func (*ConfigureReplicationResponse) XXX_DiscardUnknown 

func (m *ConfigureReplicationResponse) XXX_DiscardUnknown()

func (*ConfigureReplicationResponse) XXX_Marshal 

func (m *ConfigureReplicationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigureReplicationResponse) XXX_Merge 

func (m *ConfigureReplicationResponse) XXX_Merge(src proto.Message)

func (*ConfigureReplicationResponse) XXX_Size 

func (m *ConfigureReplicationResponse) XXX_Size() int

func (*ConfigureReplicationResponse) XXX_Unmarshal 

func (m *ConfigureReplicationResponse) XXX_Unmarshal(b []byte) error

type ConfigureRequest 

type ConfigureRequest struct {
	// The level of logging information the plugin should emit.
	LogLevel LogLevel `protobuf:"varint,1,opt,name=log_level,json=logLevel,proto3,enum=pub.LogLevel" json:"log_level,omitempty"`
	// Directory where log files should be stored.
	LogDirectory string `protobuf:"bytes,2,opt,name=log_directory,json=logDirectory,proto3" json:"log_directory,omitempty"`
	// Directory where the plugin can store data permanently.
	PermanentDirectory string `protobuf:"bytes,3,opt,name=permanent_directory,json=permanentDirectory,proto3" json:"permanent_directory,omitempty"`
	// Directory where the plugin can store temporary information which may be
	// deleted.
	TemporaryDirectory string `protobuf:"bytes,4,opt,name=temporary_directory,json=temporaryDirectory,proto3" json:"temporary_directory,omitempty"`
	// Data versions which will be in effect until the next configure request.
	// This can be used to name log files or caches.
	DataVersions         *DataVersions `protobuf:"bytes,5,opt,name=data_versions,json=dataVersions,proto3" json:"data_versions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ConfigureRequest) Descriptor 

func (*ConfigureRequest) Descriptor() ([]byte, []int)

func (*ConfigureRequest) GetDataVersions 

func (m *ConfigureRequest) GetDataVersions() *DataVersions

func (*ConfigureRequest) GetLogDirectory 

func (m *ConfigureRequest) GetLogDirectory() string

func (*ConfigureRequest) GetLogLevel 

func (m *ConfigureRequest) GetLogLevel() LogLevel

func (*ConfigureRequest) GetPermanentDirectory 

func (m *ConfigureRequest) GetPermanentDirectory() string

func (*ConfigureRequest) GetTemporaryDirectory 

func (m *ConfigureRequest) GetTemporaryDirectory() string

func (*ConfigureRequest) ProtoMessage 

func (*ConfigureRequest) ProtoMessage()

func (*ConfigureRequest) Reset 

func (m *ConfigureRequest) Reset()

func (*ConfigureRequest) String 

func (m *ConfigureRequest) String() string

func (*ConfigureRequest) XXX_DiscardUnknown 

func (m *ConfigureRequest) XXX_DiscardUnknown()

func (*ConfigureRequest) XXX_Marshal 

func (m *ConfigureRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigureRequest) XXX_Merge 

func (m *ConfigureRequest) XXX_Merge(src proto.Message)

func (*ConfigureRequest) XXX_Size 

func (m *ConfigureRequest) XXX_Size() int

func (*ConfigureRequest) XXX_Unmarshal 

func (m *ConfigureRequest) XXX_Unmarshal(b []byte) error

type ConfigureResponse 

type ConfigureResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ConfigureResponse) Descriptor 

func (*ConfigureResponse) Descriptor() ([]byte, []int)

func (*ConfigureResponse) ProtoMessage 

func (*ConfigureResponse) ProtoMessage()

func (*ConfigureResponse) Reset 

func (m *ConfigureResponse) Reset()

func (*ConfigureResponse) String 

func (m *ConfigureResponse) String() string

func (*ConfigureResponse) XXX_DiscardUnknown 

func (m *ConfigureResponse) XXX_DiscardUnknown()

func (*ConfigureResponse) XXX_Marshal 

func (m *ConfigureResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigureResponse) XXX_Merge 

func (m *ConfigureResponse) XXX_Merge(src proto.Message)

func (*ConfigureResponse) XXX_Size 

func (m *ConfigureResponse) XXX_Size() int

func (*ConfigureResponse) XXX_Unmarshal 

func (m *ConfigureResponse) XXX_Unmarshal(b []byte) error

type ConfigureWriteRequest 

type ConfigureWriteRequest 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 (*ConfigureWriteRequest) Descriptor 

func (*ConfigureWriteRequest) Descriptor() ([]byte, []int)

func (*ConfigureWriteRequest) GetForm 

func (m *ConfigureWriteRequest) GetForm() *ConfigurationFormRequest

func (*ConfigureWriteRequest) ProtoMessage 

func (*ConfigureWriteRequest) ProtoMessage()

func (*ConfigureWriteRequest) Reset 

func (m *ConfigureWriteRequest) Reset()

func (*ConfigureWriteRequest) String 

func (m *ConfigureWriteRequest) String() string

func (*ConfigureWriteRequest) XXX_DiscardUnknown 

func (m *ConfigureWriteRequest) XXX_DiscardUnknown()

func (*ConfigureWriteRequest) XXX_Marshal 

func (m *ConfigureWriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigureWriteRequest) XXX_Merge 

func (m *ConfigureWriteRequest) XXX_Merge(src proto.Message)

func (*ConfigureWriteRequest) XXX_Size 

func (m *ConfigureWriteRequest) XXX_Size() int

func (*ConfigureWriteRequest) XXX_Unmarshal 

func (m *ConfigureWriteRequest) XXX_Unmarshal(b []byte) error

type ConfigureWriteResponse 

type ConfigureWriteResponse struct {
	// Configuration object to build the ui
	Form *ConfigurationFormResponse `protobuf:"bytes,1,opt,name=form,proto3" json:"form,omitempty"`
	// The schema (schema) which is being targeted for write backs.
	Schema               *Schema  `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ConfigureWriteResponse) Descriptor 

func (*ConfigureWriteResponse) Descriptor() ([]byte, []int)

func (*ConfigureWriteResponse) GetForm 

func (m *ConfigureWriteResponse) GetForm() *ConfigurationFormResponse

func (*ConfigureWriteResponse) GetSchema 

func (m *ConfigureWriteResponse) GetSchema() *Schema

func (*ConfigureWriteResponse) ProtoMessage 

func (*ConfigureWriteResponse) ProtoMessage()

func (*ConfigureWriteResponse) Reset 

func (m *ConfigureWriteResponse) Reset()

func (*ConfigureWriteResponse) String 

func (m *ConfigureWriteResponse) String() string

func (*ConfigureWriteResponse) XXX_DiscardUnknown 

func (m *ConfigureWriteResponse) XXX_DiscardUnknown()

func (*ConfigureWriteResponse) XXX_Marshal 

func (m *ConfigureWriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConfigureWriteResponse) XXX_Merge 

func (m *ConfigureWriteResponse) XXX_Merge(src proto.Message)

func (*ConfigureWriteResponse) XXX_Size 

func (m *ConfigureWriteResponse) XXX_Size() int

func (*ConfigureWriteResponse) XXX_Unmarshal 

func (m *ConfigureWriteResponse) 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"`
	// Data versions which will be in effect until the next configure request.
	// This can be used to name log files or caches.
	DataVersions         *DataVersions `protobuf:"bytes,5,opt,name=data_versions,json=dataVersions,proto3" json:"data_versions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func NewConnectRequest 

func NewConnectRequest(settings interface{}) *ConnectRequest

func (*ConnectRequest) Descriptor 

func (*ConnectRequest) Descriptor() ([]byte, []int)

func (*ConnectRequest) GetDataVersions 

func (m *ConnectRequest) GetDataVersions() *DataVersions

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 (m *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) HasError 

func (m *ConnectResponse) HasError() bool

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 (m *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) Descriptor() ([]byte, []int)

func (*Count) Format 

func (c *Count) Format() string

func (*Count) GetKind 

func (m *Count) GetKind() Count_Kind

func (*Count) GetValue 

func (m *Count) GetValue() int32

func (*Count) ProtoMessage 

func (*Count) ProtoMessage()

func (*Count) Reset 

func (m *Count) Reset()

func (*Count) String 

func (m *Count) String() string

func (*Count) XXX_DiscardUnknown 

func (m *Count) XXX_DiscardUnknown()

func (*Count) XXX_Marshal 

func (m *Count) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Count) XXX_Merge 

func (m *Count) XXX_Merge(src proto.Message)

func (*Count) XXX_Size 

func (m *Count) XXX_Size() int

func (*Count) XXX_Unmarshal 

func (m *Count) XXX_Unmarshal(b []byte) error

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 DataVersions 

type DataVersions struct {
	// The ID of the job related to this request, if any. Can be used to
	// name caches related to a specific job.
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// The data version of the job related to this request. When this increments,
	// any cached data associated with the job should be discarded.
	JobDataVersion uint32 `protobuf:"varint,2,opt,name=job_data_version,json=jobDataVersion,proto3" json:"job_data_version,omitempty"`
	// The ID of the shape related to this request, if any. Can be used to
	// name caches related to a specific shape.
	ShapeId string `protobuf:"bytes,3,opt,name=shape_id,json=shapeId,proto3" json:"shape_id,omitempty"`
	// The data version of the shape related to this request. When this
	// increments, any cached data associated with the shape should be discarded.
	ShapeDataVersion     uint32   `protobuf:"varint,4,opt,name=shape_data_version,json=shapeDataVersion,proto3" json:"shape_data_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DataVersions) Descriptor 

func (*DataVersions) Descriptor() ([]byte, []int)

func (*DataVersions) GetJobDataVersion 

func (m *DataVersions) GetJobDataVersion() uint32

func (*DataVersions) GetJobId 

func (m *DataVersions) GetJobId() string

func (*DataVersions) GetShapeDataVersion 

func (m *DataVersions) GetShapeDataVersion() uint32

func (*DataVersions) GetShapeId 

func (m *DataVersions) GetShapeId() string

func (*DataVersions) ProtoMessage 

func (*DataVersions) ProtoMessage()

func (*DataVersions) Reset 

func (m *DataVersions) Reset()

func (*DataVersions) String 

func (m *DataVersions) String() string

func (*DataVersions) XXX_DiscardUnknown 

func (m *DataVersions) XXX_DiscardUnknown()

func (*DataVersions) XXX_Marshal 

func (m *DataVersions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataVersions) XXX_Merge 

func (m *DataVersions) XXX_Merge(src proto.Message)

func (*DataVersions) XXX_Size 

func (m *DataVersions) XXX_Size() int

func (*DataVersions) XXX_Unmarshal 

func (m *DataVersions) XXX_Unmarshal(b []byte) error

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 (m *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 (m *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 DiscoverRelatedEntitiesRequest 

type DiscoverRelatedEntitiesRequest struct {
	// The schemas to discover related entities for
	ToRelate             []*Schema `protobuf:"bytes,1,rep,name=to_relate,json=toRelate,proto3" json:"to_relate,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*DiscoverRelatedEntitiesRequest) Descriptor 

func (*DiscoverRelatedEntitiesRequest) Descriptor() ([]byte, []int)

func (*DiscoverRelatedEntitiesRequest) GetToRelate 

func (m *DiscoverRelatedEntitiesRequest) GetToRelate() []*Schema

func (*DiscoverRelatedEntitiesRequest) ProtoMessage 

func (*DiscoverRelatedEntitiesRequest) ProtoMessage()

func (*DiscoverRelatedEntitiesRequest) Reset 

func (m *DiscoverRelatedEntitiesRequest) Reset()

func (*DiscoverRelatedEntitiesRequest) String 

func (m *DiscoverRelatedEntitiesRequest) String() string

func (*DiscoverRelatedEntitiesRequest) XXX_DiscardUnknown 

func (m *DiscoverRelatedEntitiesRequest) XXX_DiscardUnknown()

func (*DiscoverRelatedEntitiesRequest) XXX_Marshal 

func (m *DiscoverRelatedEntitiesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiscoverRelatedEntitiesRequest) XXX_Merge 

func (m *DiscoverRelatedEntitiesRequest) XXX_Merge(src proto.Message)

func (*DiscoverRelatedEntitiesRequest) XXX_Size 

func (m *DiscoverRelatedEntitiesRequest) XXX_Size() int

func (*DiscoverRelatedEntitiesRequest) XXX_Unmarshal 

func (m *DiscoverRelatedEntitiesRequest) XXX_Unmarshal(b []byte) error

type DiscoverRelatedEntitiesResponse 

type DiscoverRelatedEntitiesResponse struct {
	// Related entities discovered by the publisher.
	RelatedEntities      []*RelatedEntity `protobuf:"bytes,1,rep,name=related_entities,json=relatedEntities,proto3" json:"related_entities,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*DiscoverRelatedEntitiesResponse) Descriptor 

func (*DiscoverRelatedEntitiesResponse) Descriptor() ([]byte, []int)

func (*DiscoverRelatedEntitiesResponse) GetRelatedEntities 

func (m *DiscoverRelatedEntitiesResponse) GetRelatedEntities() []*RelatedEntity

func (*DiscoverRelatedEntitiesResponse) ProtoMessage 

func (*DiscoverRelatedEntitiesResponse) ProtoMessage()

func (*DiscoverRelatedEntitiesResponse) Reset 

func (m *DiscoverRelatedEntitiesResponse) Reset()

func (*DiscoverRelatedEntitiesResponse) String 

func (m *DiscoverRelatedEntitiesResponse) String() string

func (*DiscoverRelatedEntitiesResponse) XXX_DiscardUnknown 

func (m *DiscoverRelatedEntitiesResponse) XXX_DiscardUnknown()

func (*DiscoverRelatedEntitiesResponse) XXX_Marshal 

func (m *DiscoverRelatedEntitiesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiscoverRelatedEntitiesResponse) XXX_Merge 

func (m *DiscoverRelatedEntitiesResponse) XXX_Merge(src proto.Message)

func (*DiscoverRelatedEntitiesResponse) XXX_Size 

func (m *DiscoverRelatedEntitiesResponse) XXX_Size() int

func (*DiscoverRelatedEntitiesResponse) XXX_Unmarshal 

func (m *DiscoverRelatedEntitiesResponse) XXX_Unmarshal(b []byte) error

type DiscoverSchemasRequest 

type DiscoverSchemasRequest struct {
	// Mode is the discovery mode.
	Mode DiscoverSchemasRequest_Mode `protobuf:"varint,1,opt,name=mode,proto3,enum=pub.DiscoverSchemasRequest_Mode" json:"mode,omitempty"`
	// The schemas to refresh if mode == 1.
	ToRefresh []*Schema `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 schemas.
	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 (*DiscoverSchemasRequest) Descriptor 

func (*DiscoverSchemasRequest) Descriptor() ([]byte, []int)

func (*DiscoverSchemasRequest) GetMode 

func (m *DiscoverSchemasRequest) GetMode() DiscoverSchemasRequest_Mode

func (*DiscoverSchemasRequest) GetSampleSize 

func (m *DiscoverSchemasRequest) GetSampleSize() uint32

func (*DiscoverSchemasRequest) GetToRefresh 

func (m *DiscoverSchemasRequest) GetToRefresh() []*Schema

func (*DiscoverSchemasRequest) ProtoMessage 

func (*DiscoverSchemasRequest) ProtoMessage()

func (*DiscoverSchemasRequest) Reset 

func (m *DiscoverSchemasRequest) Reset()

func (*DiscoverSchemasRequest) String 

func (m *DiscoverSchemasRequest) String() string

func (*DiscoverSchemasRequest) XXX_DiscardUnknown 

func (m *DiscoverSchemasRequest) XXX_DiscardUnknown()

func (*DiscoverSchemasRequest) XXX_Marshal 

func (m *DiscoverSchemasRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiscoverSchemasRequest) XXX_Merge 

func (m *DiscoverSchemasRequest) XXX_Merge(src proto.Message)

func (*DiscoverSchemasRequest) XXX_Size 

func (m *DiscoverSchemasRequest) XXX_Size() int

func (*DiscoverSchemasRequest) XXX_Unmarshal 

func (m *DiscoverSchemasRequest) XXX_Unmarshal(b []byte) error

type DiscoverSchemasRequest_Mode 

type DiscoverSchemasRequest_Mode int32
const (
	// ALL means all schemas the publisher can publish should be returned.
	DiscoverSchemasRequest_ALL DiscoverSchemasRequest_Mode = 0
	// REFRESH means the publisher return (updated) schemas identified by the
	// partial schemas included in to_refresh.
	DiscoverSchemasRequest_REFRESH DiscoverSchemasRequest_Mode = 1
)

func (DiscoverSchemasRequest_Mode) EnumDescriptor 

func (DiscoverSchemasRequest_Mode) EnumDescriptor() ([]byte, []int)

func (DiscoverSchemasRequest_Mode) String 

func (x DiscoverSchemasRequest_Mode) String() string

type DiscoverSchemasResponse 

type DiscoverSchemasResponse struct {
	// Schemas discovered by the publisher.
	Schemas              []*Schema `protobuf:"bytes,1,rep,name=schemas,proto3" json:"schemas,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*DiscoverSchemasResponse) Descriptor 

func (*DiscoverSchemasResponse) Descriptor() ([]byte, []int)

func (*DiscoverSchemasResponse) GetSchemas 

func (m *DiscoverSchemasResponse) GetSchemas() []*Schema

func (*DiscoverSchemasResponse) ProtoMessage 

func (*DiscoverSchemasResponse) ProtoMessage()

func (*DiscoverSchemasResponse) Reset 

func (m *DiscoverSchemasResponse) Reset()

func (*DiscoverSchemasResponse) String 

func (m *DiscoverSchemasResponse) String() string

func (*DiscoverSchemasResponse) XXX_DiscardUnknown 

func (m *DiscoverSchemasResponse) XXX_DiscardUnknown()

func (*DiscoverSchemasResponse) XXX_Marshal 

func (m *DiscoverSchemasResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiscoverSchemasResponse) XXX_Merge 

func (m *DiscoverSchemasResponse) XXX_Merge(src proto.Message)

func (*DiscoverSchemasResponse) XXX_Size 

func (m *DiscoverSchemasResponse) XXX_Size() int

func (*DiscoverSchemasResponse) XXX_Unmarshal 

func (m *DiscoverSchemasResponse) XXX_Unmarshal(b []byte) error

type LogLevel 

type LogLevel int32
const (
	LogLevel_Error LogLevel = 0
	LogLevel_Warn  LogLevel = 1
	LogLevel_Info  LogLevel = 2
	LogLevel_Debug LogLevel = 3
	LogLevel_Trace LogLevel = 4
)

func (LogLevel) EnumDescriptor 

func (LogLevel) EnumDescriptor() ([]byte, []int)

func (LogLevel) String 

func (x LogLevel) String() string

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 (m *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 PrepareWriteRequest 

type PrepareWriteRequest struct {
	// Time in seconds that a record write back must be acknowledged by the plugin
	CommitSlaSeconds int32 `protobuf:"varint,1,opt,name=commit_sla_seconds,json=commitSlaSeconds,proto3" json:"commit_sla_seconds,omitempty"`
	// Schema to write back to source system
	Schema *Schema `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	// Replication information; if this is present, plugin should
	// prepare replication targets and expect incoming records to contain
	// replication data.
	Replication          *ReplicationWriteRequest `protobuf:"bytes,3,opt,name=replication,proto3" json:"replication,omitempty"`
	DataVersions         *DataVersions            `protobuf:"bytes,4,opt,name=data_versions,json=dataVersions,proto3" json:"data_versions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*PrepareWriteRequest) Descriptor 

func (*PrepareWriteRequest) Descriptor() ([]byte, []int)

func (*PrepareWriteRequest) GetCommitSlaSeconds 

func (m *PrepareWriteRequest) GetCommitSlaSeconds() int32

func (*PrepareWriteRequest) GetDataVersions 

func (m *PrepareWriteRequest) GetDataVersions() *DataVersions

func (*PrepareWriteRequest) GetReplication 

func (m *PrepareWriteRequest) GetReplication() *ReplicationWriteRequest

func (*PrepareWriteRequest) GetSchema 

func (m *PrepareWriteRequest) GetSchema() *Schema

func (*PrepareWriteRequest) ProtoMessage 

func (*PrepareWriteRequest) ProtoMessage()

func (*PrepareWriteRequest) Reset 

func (m *PrepareWriteRequest) Reset()

func (*PrepareWriteRequest) String 

func (m *PrepareWriteRequest) String() string

func (*PrepareWriteRequest) XXX_DiscardUnknown 

func (m *PrepareWriteRequest) XXX_DiscardUnknown()

func (*PrepareWriteRequest) XXX_Marshal 

func (m *PrepareWriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrepareWriteRequest) XXX_Merge 

func (m *PrepareWriteRequest) XXX_Merge(src proto.Message)

func (*PrepareWriteRequest) XXX_Size 

func (m *PrepareWriteRequest) XXX_Size() int

func (*PrepareWriteRequest) XXX_Unmarshal 

func (m *PrepareWriteRequest) XXX_Unmarshal(b []byte) error

type PrepareWriteResponse 

type PrepareWriteResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PrepareWriteResponse) Descriptor 

func (*PrepareWriteResponse) Descriptor() ([]byte, []int)

func (*PrepareWriteResponse) ProtoMessage 

func (*PrepareWriteResponse) ProtoMessage()

func (*PrepareWriteResponse) Reset 

func (m *PrepareWriteResponse) Reset()

func (*PrepareWriteResponse) String 

func (m *PrepareWriteResponse) String() string

func (*PrepareWriteResponse) XXX_DiscardUnknown 

func (m *PrepareWriteResponse) XXX_DiscardUnknown()

func (*PrepareWriteResponse) XXX_Marshal 

func (m *PrepareWriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PrepareWriteResponse) XXX_Merge 

func (m *PrepareWriteResponse) XXX_Merge(src proto.Message)

func (*PrepareWriteResponse) XXX_Size 

func (m *PrepareWriteResponse) XXX_Size() int

func (*PrepareWriteResponse) XXX_Unmarshal 

func (m *PrepareWriteResponse) 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 schema.
	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) Descriptor() ([]byte, []int)

func (*Property) GetDescription 

func (m *Property) GetDescription() string

func (*Property) GetId 

func (m *Property) GetId() string

func (*Property) GetIsCreateCounter 

func (m *Property) GetIsCreateCounter() bool

func (*Property) GetIsKey 

func (m *Property) GetIsKey() bool

func (*Property) GetIsNullable 

func (m *Property) GetIsNullable() bool

func (*Property) GetIsUpdateCounter 

func (m *Property) GetIsUpdateCounter() bool

func (*Property) GetName 

func (m *Property) GetName() string

func (*Property) GetPublisherMetaJson 

func (m *Property) GetPublisherMetaJson() string

func (*Property) GetType 

func (m *Property) GetType() PropertyType

func (*Property) GetTypeAtSource 

func (m *Property) GetTypeAtSource() string

func (*Property) ProtoMessage 

func (*Property) ProtoMessage()

func (*Property) Reset 

func (m *Property) Reset()

func (*Property) String 

func (m *Property) String() string

func (*Property) XXX_DiscardUnknown 

func (m *Property) XXX_DiscardUnknown()

func (*Property) XXX_Marshal 

func (m *Property) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Property) XXX_Merge 

func (m *Property) XXX_Merge(src proto.Message)

func (*Property) XXX_Size 

func (m *Property) XXX_Size() int

func (*Property) XXX_Unmarshal 

func (m *Property) XXX_Unmarshal(b []byte) error

type PropertyMetadata 

type PropertyMetadata struct {
}

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 (m *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 PublisherClient 

type PublisherClient interface {
	// Configures the plugin.
	Configure(ctx context.Context, in *ConfigureRequest, opts ...grpc.CallOption) (*ConfigureResponse, error)
	// Instructs the plugin 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)
	// DiscoverShapes requests a listing of schemas this publisher can provide
	// records for.
	//
	// Deprecated: Deprecated in API version 2. Implement DiscoverSchemasStream
	// instead.
	//
	// Deprecated: Do not use.
	DiscoverShapes(ctx context.Context, in *DiscoverSchemasRequest, opts ...grpc.CallOption) (*DiscoverSchemasResponse, error)
	// Requests a listing of schemas this publisher can provide records for.
	// New plugins should implement DiscoverSchemaStream and stream discovered
	// schemes to the caller.
	//
	// Deprecated: Deprecated in API version 2. Implement DiscoverSchemasStream
	// instead.
	DiscoverSchemas(ctx context.Context, in *DiscoverSchemasRequest, opts ...grpc.CallOption) (*DiscoverSchemasResponse, error)
	// Requests a stream of schemas this publisher can provide records for.
	//
	// API Version: 3
	DiscoverSchemasStream(ctx context.Context, in *DiscoverSchemasRequest, opts ...grpc.CallOption) (Publisher_DiscoverSchemasStreamClient, error)
	// PublishStream begins streaming records to the client from the plugin.
	// Implement ReadStream instead.
	//
	// Deprecated: Deprecated in API Version 2. Implement ReadStream instead.
	//
	// Deprecated: Do not use.
	PublishStream(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (Publisher_PublishStreamClient, error)
	// ReadStream begins streaming records to the client from the plugin.
	// API Version: 2
	ReadStream(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (Publisher_ReadStreamClient, error)
	// Tells the plugin 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 schema.
	// 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)
	// Configures a write back which can be used to write back a schema to the
	// source. This must be implemented if the plugin manifest has
	// `canConfigureWrite` set to true.
	ConfigureWrite(ctx context.Context, in *ConfigureWriteRequest, opts ...grpc.CallOption) (*ConfigureWriteResponse, error)
	// Configures a replication write back, where the plugin is in control
	// of the destination and can insert/update/delete at will.
	ConfigureReplication(ctx context.Context, in *ConfigureReplicationRequest, opts ...grpc.CallOption) (*ConfigureReplicationResponse, error)
	// Invoked to begin a write back request
	// This must be implemented if the manifest has `canWrite` set to true.
	PrepareWrite(ctx context.Context, in *PrepareWriteRequest, opts ...grpc.CallOption) (*PrepareWriteResponse, error)
	// Creates a stream of records to write back and opens a stream to receive
	// acks for write backs This must be implemented if the manifest has
	// `canWrite` set to true.
	WriteStream(ctx context.Context, opts ...grpc.CallOption) (Publisher_WriteStreamClient, error)
	// Requests a listing of all related entities.
	DiscoverRelatedEntities(ctx context.Context, in *DiscoverRelatedEntitiesRequest, opts ...grpc.CallOption) (*DiscoverRelatedEntitiesResponse, 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.ClientConnInterface) PublisherClient

type PublisherServer 

type PublisherServer interface {
	// Configures the plugin.
	Configure(context.Context, *ConfigureRequest) (*ConfigureResponse, error)
	// Instructs the plugin 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
	// DiscoverShapes requests a listing of schemas this publisher can provide
	// records for.
	//
	// Deprecated: Deprecated in API version 2. Implement DiscoverSchemasStream
	// instead.
	//
	// Deprecated: Do not use.
	DiscoverShapes(context.Context, *DiscoverSchemasRequest) (*DiscoverSchemasResponse, error)
	// Requests a listing of schemas this publisher can provide records for.
	// New plugins should implement DiscoverSchemaStream and stream discovered
	// schemes to the caller.
	//
	// Deprecated: Deprecated in API version 2. Implement DiscoverSchemasStream
	// instead.
	DiscoverSchemas(context.Context, *DiscoverSchemasRequest) (*DiscoverSchemasResponse, error)
	// Requests a stream of schemas this publisher can provide records for.
	//
	// API Version: 3
	DiscoverSchemasStream(*DiscoverSchemasRequest, Publisher_DiscoverSchemasStreamServer) error
	// PublishStream begins streaming records to the client from the plugin.
	// Implement ReadStream instead.
	//
	// Deprecated: Deprecated in API Version 2. Implement ReadStream instead.
	//
	// Deprecated: Do not use.
	PublishStream(*ReadRequest, Publisher_PublishStreamServer) error
	// ReadStream begins streaming records to the client from the plugin.
	// API Version: 2
	ReadStream(*ReadRequest, Publisher_ReadStreamServer) error
	// Tells the plugin 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 schema.
	// 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)
	// Configures a write back which can be used to write back a schema to the
	// source. This must be implemented if the plugin manifest has
	// `canConfigureWrite` set to true.
	ConfigureWrite(context.Context, *ConfigureWriteRequest) (*ConfigureWriteResponse, error)
	// Configures a replication write back, where the plugin is in control
	// of the destination and can insert/update/delete at will.
	ConfigureReplication(context.Context, *ConfigureReplicationRequest) (*ConfigureReplicationResponse, error)
	// Invoked to begin a write back request
	// This must be implemented if the manifest has `canWrite` set to true.
	PrepareWrite(context.Context, *PrepareWriteRequest) (*PrepareWriteResponse, error)
	// Creates a stream of records to write back and opens a stream to receive
	// acks for write backs This must be implemented if the manifest has
	// `canWrite` set to true.
	WriteStream(Publisher_WriteStreamServer) error
	// Requests a listing of all related entities.
	DiscoverRelatedEntities(context.Context, *DiscoverRelatedEntitiesRequest) (*DiscoverRelatedEntitiesResponse, 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_DiscoverSchemasStreamClient 

type Publisher_DiscoverSchemasStreamClient interface {
	Recv() (*Schema, error)
	grpc.ClientStream
}

type Publisher_DiscoverSchemasStreamServer 

type Publisher_DiscoverSchemasStreamServer interface {
	Send(*Schema) 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 Publisher_ReadStreamClient 

type Publisher_ReadStreamClient interface {
	Recv() (*Record, error)
	grpc.ClientStream
}

type Publisher_ReadStreamServer 

type Publisher_ReadStreamServer interface {
	Send(*Record) error
	grpc.ServerStream
}

type Publisher_WriteStreamClient 

type Publisher_WriteStreamClient interface {
	Send(*Record) error
	Recv() (*RecordAck, error)
	grpc.ClientStream
}

type Publisher_WriteStreamServer 

type Publisher_WriteStreamServer interface {
	Send(*RecordAck) error
	Recv() (*Record, error)
	grpc.ServerStream
}

type ReadRequest 

type ReadRequest struct {
	// The schema of the records to publish.
	Schema *Schema `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,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 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"`
	// ID for the job which contains the schema, the connection used
	// to connect before starting this job, the real time settings and state,
	// and so on. Can be used to persist local state between publishes.
	JobId string `protobuf:"bytes,8,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// The data_version is a counter that will be incremented whenever
	// all data produced for a particular job_id should be discarded.
	//
	// Deprecated: Use the data_versions property instead.
	DataVersion          uint32        `protobuf:"varint,9,opt,name=data_version,json=dataVersion,proto3" json:"data_version,omitempty"`
	DataVersions         *DataVersions `protobuf:"bytes,10,opt,name=data_versions,json=dataVersions,proto3" json:"data_versions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ReadRequest) Descriptor 

func (*ReadRequest) Descriptor() ([]byte, []int)

func (*ReadRequest) GetDataVersion 

func (m *ReadRequest) GetDataVersion() uint32

func (*ReadRequest) GetDataVersions 

func (m *ReadRequest) GetDataVersions() *DataVersions

func (*ReadRequest) GetFilters 

func (m *ReadRequest) GetFilters() []*PublishFilter

func (*ReadRequest) GetJobId 

func (m *ReadRequest) GetJobId() string

func (*ReadRequest) GetLimit 

func (m *ReadRequest) GetLimit() uint32

func (*ReadRequest) GetRealTimeSettingsJson 

func (m *ReadRequest) GetRealTimeSettingsJson() string

func (*ReadRequest) GetRealTimeStateJson 

func (m *ReadRequest) GetRealTimeStateJson() string

func (*ReadRequest) GetSchema 

func (m *ReadRequest) GetSchema() *Schema

func (*ReadRequest) ProtoMessage 

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) Reset 

func (m *ReadRequest) Reset()

func (*ReadRequest) String 

func (m *ReadRequest) String() string

func (*ReadRequest) XXX_DiscardUnknown 

func (m *ReadRequest) XXX_DiscardUnknown()

func (*ReadRequest) XXX_Marshal 

func (m *ReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadRequest) XXX_Merge 

func (m *ReadRequest) XXX_Merge(src proto.Message)

func (*ReadRequest) XXX_Size 

func (m *ReadRequest) XXX_Size() int

func (*ReadRequest) XXX_Unmarshal 

func (m *ReadRequest) XXX_Unmarshal(b []byte) error

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"`
	// Cause for the publish of the record.
	// If provided, this should be an end-user readable string describing what
	// triggered the publish. This should only be set for real time published
	// records, where the cause may be interesting.
	Cause string `protobuf:"bytes,4,opt,name=cause,proto3" json:"cause,omitempty"`
	// Correlation ID for a record
	// Only expected to be used within the WriteStream method
	CorrelationId string `protobuf:"bytes,5,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	// RecordID for the source record.
	// Only set on a replication writeback.
	RecordId string `protobuf:"bytes,6,opt,name=record_id,json=recordId,proto3" json:"record_id,omitempty"`
	// Versions of the record from other sources.
	// Only set on a replication writeback.
	Versions             []*RecordVersion `protobuf:"bytes,7,rep,name=versions,proto3" json:"versions,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) AsUnmarshalled 

func (r *Record) AsUnmarshalled() (*UnmarshalledRecord, error)

func (*Record) Descriptor 

func (*Record) Descriptor() ([]byte, []int)

func (*Record) GetAction 

func (m *Record) GetAction() Record_Action

func (*Record) GetCause 

func (m *Record) GetCause() string

func (*Record) GetCorrelationId 

func (m *Record) GetCorrelationId() string

func (*Record) GetDataJson 

func (m *Record) GetDataJson() string

func (*Record) GetRealTimeStateJson 

func (m *Record) GetRealTimeStateJson() string

func (*Record) GetRecordId 

func (m *Record) GetRecordId() string

func (*Record) GetVersions 

func (m *Record) GetVersions() []*RecordVersion

func (*Record) ProtoMessage 

func (*Record) ProtoMessage()

func (*Record) Reset 

func (m *Record) Reset()

func (*Record) String 

func (m *Record) String() string

func (*Record) UnmarshalData 

func (r *Record) UnmarshalData(out interface{}) error

func (*Record) UnmarshalRealTimeState 

func (r *Record) UnmarshalRealTimeState(out interface{}) error

func (*Record) XXX_DiscardUnknown 

func (m *Record) XXX_DiscardUnknown()

func (*Record) XXX_Marshal 

func (m *Record) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Record) XXX_Merge 

func (m *Record) XXX_Merge(src proto.Message)

func (*Record) XXX_Size 

func (m *Record) XXX_Size() int

func (*Record) XXX_Unmarshal 

func (m *Record) XXX_Unmarshal(b []byte) error

type RecordAck 

type RecordAck struct {
	// Correlation ID for record that has been written back
	CorrelationId string `protobuf:"bytes,1,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	// Contains information about any error in writing back the record
	Error                string   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RecordAck) Descriptor 

func (*RecordAck) Descriptor() ([]byte, []int)

func (*RecordAck) GetCorrelationId 

func (m *RecordAck) GetCorrelationId() string

func (*RecordAck) GetError 

func (m *RecordAck) GetError() string

func (*RecordAck) ProtoMessage 

func (*RecordAck) ProtoMessage()

func (*RecordAck) Reset 

func (m *RecordAck) Reset()

func (*RecordAck) String 

func (m *RecordAck) String() string

func (*RecordAck) XXX_DiscardUnknown 

func (m *RecordAck) XXX_DiscardUnknown()

func (*RecordAck) XXX_Marshal 

func (m *RecordAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RecordAck) XXX_Merge 

func (m *RecordAck) XXX_Merge(src proto.Message)

func (*RecordAck) XXX_Size 

func (m *RecordAck) XXX_Size() int

func (*RecordAck) XXX_Unmarshal 

func (m *RecordAck) XXX_Unmarshal(b []byte) error

type RecordVersion 

type RecordVersion struct {
	// The connection than produced this version.
	ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	// The job that produced this version.
	JobId string `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// The schema that produced this version.
	SchemaId string `protobuf:"bytes,3,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"`
	// The RID of the original record for this version.
	RecordId string `protobuf:"bytes,4,opt,name=record_id,json=recordId,proto3" json:"record_id,omitempty"`
	// The shape data mapped from the schema data for this version.
	DataJson string `protobuf:"bytes,5,opt,name=data_json,json=dataJson,proto3" json:"data_json,omitempty"`
	// Any captured schema data for this version.
	SchemaDataJson       string   `protobuf:"bytes,6,opt,name=schema_data_json,json=schemaDataJson,proto3" json:"schema_data_json,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A version of a record, provided on a replication writeback. Contains the data from a version mapped from a schema, rather than the golden record data.

func (*RecordVersion) Descriptor 

func (*RecordVersion) Descriptor() ([]byte, []int)

func (*RecordVersion) GetConnectionId 

func (m *RecordVersion) GetConnectionId() string

func (*RecordVersion) GetDataJson 

func (m *RecordVersion) GetDataJson() string

func (*RecordVersion) GetJobId 

func (m *RecordVersion) GetJobId() string

func (*RecordVersion) GetRecordId 

func (m *RecordVersion) GetRecordId() string

func (*RecordVersion) GetSchemaDataJson 

func (m *RecordVersion) GetSchemaDataJson() string

func (*RecordVersion) GetSchemaId 

func (m *RecordVersion) GetSchemaId() string

func (*RecordVersion) ProtoMessage 

func (*RecordVersion) ProtoMessage()

func (*RecordVersion) Reset 

func (m *RecordVersion) Reset()

func (*RecordVersion) String 

func (m *RecordVersion) String() string

func (*RecordVersion) XXX_DiscardUnknown 

func (m *RecordVersion) XXX_DiscardUnknown()

func (*RecordVersion) XXX_Marshal 

func (m *RecordVersion) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RecordVersion) XXX_Merge 

func (m *RecordVersion) XXX_Merge(src proto.Message)

func (*RecordVersion) XXX_Size 

func (m *RecordVersion) XXX_Size() int

func (*RecordVersion) XXX_Unmarshal 

func (m *RecordVersion) XXX_Unmarshal(b []byte) error

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 RelatedEntity 

type RelatedEntity struct {
	// The source schema id that this applies to
	SchemaId string `protobuf:"bytes,1,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"`
	// The name of the source resource
	SourceResource string `protobuf:"bytes,2,opt,name=source_resource,json=sourceResource,proto3" json:"source_resource,omitempty"`
	// The name of the source column on the source resource
	SourceColumn string `protobuf:"bytes,3,opt,name=source_column,json=sourceColumn,proto3" json:"source_column,omitempty"`
	// The name of the foreign resource
	ForeignResource string `protobuf:"bytes,4,opt,name=foreign_resource,json=foreignResource,proto3" json:"foreign_resource,omitempty"`
	// The name of the foreign column on the foreign resource
	ForeignColumn string `protobuf:"bytes,5,opt,name=foreign_column,json=foreignColumn,proto3" json:"foreign_column,omitempty"`
	// The name of the type of relationship defined
	RelationshipName     string   `protobuf:"bytes,6,opt,name=relationship_name,json=relationshipName,proto3" json:"relationship_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RelatedEntity) Descriptor 

func (*RelatedEntity) Descriptor() ([]byte, []int)

func (*RelatedEntity) GetForeignColumn 

func (m *RelatedEntity) GetForeignColumn() string

func (*RelatedEntity) GetForeignResource 

func (m *RelatedEntity) GetForeignResource() string

func (*RelatedEntity) GetRelationshipName 

func (m *RelatedEntity) GetRelationshipName() string

func (*RelatedEntity) GetSchemaId 

func (m *RelatedEntity) GetSchemaId() string

func (*RelatedEntity) GetSourceColumn 

func (m *RelatedEntity) GetSourceColumn() string

func (*RelatedEntity) GetSourceResource 

func (m *RelatedEntity) GetSourceResource() string

func (*RelatedEntity) ProtoMessage 

func (*RelatedEntity) ProtoMessage()

func (*RelatedEntity) Reset 

func (m *RelatedEntity) Reset()

func (*RelatedEntity) String 

func (m *RelatedEntity) String() string

func (*RelatedEntity) XXX_DiscardUnknown 

func (m *RelatedEntity) XXX_DiscardUnknown()

func (*RelatedEntity) XXX_Marshal 

func (m *RelatedEntity) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RelatedEntity) XXX_Merge 

func (m *RelatedEntity) XXX_Merge(src proto.Message)

func (*RelatedEntity) XXX_Size 

func (m *RelatedEntity) XXX_Size() int

func (*RelatedEntity) XXX_Unmarshal 

func (m *RelatedEntity) XXX_Unmarshal(b []byte) error

type ReplicationWriteRequest 

type ReplicationWriteRequest struct {
	// The versions which may be present on each replicated record.
	Versions []*ReplicationWriteVersion `protobuf:"bytes,1,rep,name=versions,proto3" json:"versions,omitempty"`
	// The settings produced using the ConfigureReplication operation.
	SettingsJson         string   `protobuf:"bytes,2,opt,name=settings_json,json=settingsJson,proto3" json:"settings_json,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReplicationWriteRequest) Descriptor 

func (*ReplicationWriteRequest) Descriptor() ([]byte, []int)

func (*ReplicationWriteRequest) GetSettingsJson 

func (m *ReplicationWriteRequest) GetSettingsJson() string

func (*ReplicationWriteRequest) GetVersions 

func (m *ReplicationWriteRequest) GetVersions() []*ReplicationWriteVersion

func (*ReplicationWriteRequest) ProtoMessage 

func (*ReplicationWriteRequest) ProtoMessage()

func (*ReplicationWriteRequest) Reset 

func (m *ReplicationWriteRequest) Reset()

func (*ReplicationWriteRequest) String 

func (m *ReplicationWriteRequest) String() string

func (*ReplicationWriteRequest) XXX_DiscardUnknown 

func (m *ReplicationWriteRequest) XXX_DiscardUnknown()

func (*ReplicationWriteRequest) XXX_Marshal 

func (m *ReplicationWriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicationWriteRequest) XXX_Merge 

func (m *ReplicationWriteRequest) XXX_Merge(src proto.Message)

func (*ReplicationWriteRequest) XXX_Size 

func (m *ReplicationWriteRequest) XXX_Size() int

func (*ReplicationWriteRequest) XXX_Unmarshal 

func (m *ReplicationWriteRequest) XXX_Unmarshal(b []byte) error

type ReplicationWriteVersion 

type ReplicationWriteVersion struct {
	ConnectionId   string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	ConnectionName string `protobuf:"bytes,2,opt,name=connection_name,json=connectionName,proto3" json:"connection_name,omitempty"`
	JobId          string `protobuf:"bytes,3,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	JobName        string `protobuf:"bytes,4,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	SchemaId       string `protobuf:"bytes,5,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"`
	SchemaName     string `protobuf:"bytes,6,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"`
	// If the version includes any captured schema data,
	// this map will be a map of property ID to property type for
	// each captured property.
	CapturedSchemaDataProperties map[string]PropertyType `` /* 260-byte string literal not displayed */
	XXX_NoUnkeyedLiteral         struct{}                `json:"-"`
	XXX_unrecognized             []byte                  `json:"-"`
	XXX_sizecache                int32                   `json:"-"`
}

The version source information, which should be used to store the version records in a way which lets the source of the version be visible to users of the replicated data.

func (*ReplicationWriteVersion) Descriptor 

func (*ReplicationWriteVersion) Descriptor() ([]byte, []int)

func (*ReplicationWriteVersion) GetCapturedSchemaDataProperties 

func (m *ReplicationWriteVersion) GetCapturedSchemaDataProperties() map[string]PropertyType

func (*ReplicationWriteVersion) GetConnectionId 

func (m *ReplicationWriteVersion) GetConnectionId() string

func (*ReplicationWriteVersion) GetConnectionName 

func (m *ReplicationWriteVersion) GetConnectionName() string

func (*ReplicationWriteVersion) GetJobId 

func (m *ReplicationWriteVersion) GetJobId() string

func (*ReplicationWriteVersion) GetJobName 

func (m *ReplicationWriteVersion) GetJobName() string

func (*ReplicationWriteVersion) GetSchemaId 

func (m *ReplicationWriteVersion) GetSchemaId() string

func (*ReplicationWriteVersion) GetSchemaName 

func (m *ReplicationWriteVersion) GetSchemaName() string

func (*ReplicationWriteVersion) ProtoMessage 

func (*ReplicationWriteVersion) ProtoMessage()

func (*ReplicationWriteVersion) Reset 

func (m *ReplicationWriteVersion) Reset()

func (*ReplicationWriteVersion) String 

func (m *ReplicationWriteVersion) String() string

func (*ReplicationWriteVersion) XXX_DiscardUnknown 

func (m *ReplicationWriteVersion) XXX_DiscardUnknown()

func (*ReplicationWriteVersion) XXX_Marshal 

func (m *ReplicationWriteVersion) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplicationWriteVersion) XXX_Merge 

func (m *ReplicationWriteVersion) XXX_Merge(src proto.Message)

func (*ReplicationWriteVersion) XXX_Size 

func (m *ReplicationWriteVersion) XXX_Size() int

func (*ReplicationWriteVersion) XXX_Unmarshal 

func (m *ReplicationWriteVersion) XXX_Unmarshal(b []byte) error

type Schema 

type Schema struct {
	// ID that the plugin uses to uniquely identify this schema.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Name of this schema (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 schema, if available.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Properties of this schema.
	Properties []*Property `protobuf:"bytes,4,rep,name=properties,proto3" json:"properties,omitempty"`
	// Count of records available in this schema.
	Count *Count `protobuf:"bytes,5,opt,name=count,proto3" json:"count,omitempty"`
	// Sample containing zero or more records representative of the data in this
	// schema.
	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 schema. When passed to the
	// publisher, the query which should be used to publish records from this
	// schema.
	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 schema.
	Errors               []string                 `protobuf:"bytes,9,rep,name=errors,proto3" json:"errors,omitempty"`
	DataFlowDirection    Schema_DataFlowDirection `` /* 150-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*Schema) Descriptor 

func (*Schema) Descriptor() ([]byte, []int)

func (*Schema) GetCount 

func (m *Schema) GetCount() *Count

func (*Schema) GetDataFlowDirection 

func (m *Schema) GetDataFlowDirection() Schema_DataFlowDirection

func (*Schema) GetDescription 

func (m *Schema) GetDescription() string

func (*Schema) GetErrors 

func (m *Schema) GetErrors() []string

func (*Schema) GetId 

func (m *Schema) GetId() string

func (*Schema) GetName 

func (m *Schema) GetName() string

func (*Schema) GetProperties 

func (m *Schema) GetProperties() []*Property

func (*Schema) GetPublisherMetaJson 

func (m *Schema) GetPublisherMetaJson() string

func (*Schema) GetQuery 

func (m *Schema) GetQuery() string

func (*Schema) GetSample 

func (m *Schema) GetSample() []*Record

func (*Schema) ProtoMessage 

func (*Schema) ProtoMessage()

func (*Schema) Reset 

func (m *Schema) Reset()

func (*Schema) String 

func (m *Schema) String() string

func (*Schema) XXX_DiscardUnknown 

func (m *Schema) XXX_DiscardUnknown()

func (*Schema) XXX_Marshal 

func (m *Schema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Schema) XXX_Merge 

func (m *Schema) XXX_Merge(src proto.Message)

func (*Schema) XXX_Size 

func (m *Schema) XXX_Size() int

func (*Schema) XXX_Unmarshal 

func (m *Schema) XXX_Unmarshal(b []byte) error

type Schema_DataFlowDirection 

type Schema_DataFlowDirection int32
const (
	Schema_READ       Schema_DataFlowDirection = 0
	Schema_WRITE      Schema_DataFlowDirection = 1
	Schema_READ_WRITE Schema_DataFlowDirection = 2
)

func (Schema_DataFlowDirection) EnumDescriptor 

func (Schema_DataFlowDirection) EnumDescriptor() ([]byte, []int)

func (Schema_DataFlowDirection) String 

func (x Schema_DataFlowDirection) String() string

type ShapeMetadata 

type ShapeMetadata struct {
}

type SortableProperties 

type SortableProperties []*Property

func (SortableProperties) Len 

func (s SortableProperties) Len() int

func (SortableProperties) Less 

func (s SortableProperties) Less(i, j int) bool

func (SortableProperties) Swap 

func (s SortableProperties) Swap(i, j int)

type SortableShapes 

type SortableShapes []*Schema

func (SortableShapes) Len 

func (s SortableShapes) Len() int

func (SortableShapes) Less 

func (s SortableShapes) Less(i, j int) bool

func (SortableShapes) Swap 

func (s SortableShapes) Swap(i, j int)

type UnimplementedPublisherServer 

type UnimplementedPublisherServer struct {
}

UnimplementedPublisherServer can be embedded to have forward compatible implementations.

func (*UnimplementedPublisherServer) BeginOAuthFlow 

func (*UnimplementedPublisherServer) BeginOAuthFlow(ctx context.Context, req *BeginOAuthFlowRequest) (*BeginOAuthFlowResponse, error)

func (*UnimplementedPublisherServer) CompleteOAuthFlow 

func (*UnimplementedPublisherServer) CompleteOAuthFlow(ctx context.Context, req *CompleteOAuthFlowRequest) (*CompleteOAuthFlowResponse, error)

func (*UnimplementedPublisherServer) Configure 

func (*UnimplementedPublisherServer) Configure(ctx context.Context, req *ConfigureRequest) (*ConfigureResponse, error)

func (*UnimplementedPublisherServer) ConfigureConnection 

func (*UnimplementedPublisherServer) ConfigureConnection(ctx context.Context, req *ConfigureConnectionRequest) (*ConfigureConnectionResponse, error)

func (*UnimplementedPublisherServer) ConfigureQuery 

func (*UnimplementedPublisherServer) ConfigureQuery(ctx context.Context, req *ConfigureQueryRequest) (*ConfigureQueryResponse, error)

func (*UnimplementedPublisherServer) ConfigureRealTime 

func (*UnimplementedPublisherServer) ConfigureRealTime(ctx context.Context, req *ConfigureRealTimeRequest) (*ConfigureRealTimeResponse, error)

func (*UnimplementedPublisherServer) ConfigureReplication 

func (*UnimplementedPublisherServer) ConfigureReplication(ctx context.Context, req *ConfigureReplicationRequest) (*ConfigureReplicationResponse, error)

func (*UnimplementedPublisherServer) ConfigureWrite 

func (*UnimplementedPublisherServer) ConfigureWrite(ctx context.Context, req *ConfigureWriteRequest) (*ConfigureWriteResponse, error)

func (*UnimplementedPublisherServer) Connect 

func (*UnimplementedPublisherServer) Connect(ctx context.Context, req *ConnectRequest) (*ConnectResponse, error)

func (*UnimplementedPublisherServer) ConnectSession 

func (*UnimplementedPublisherServer) ConnectSession(req *ConnectRequest, srv Publisher_ConnectSessionServer) error

func (*UnimplementedPublisherServer) Disconnect 

func (*UnimplementedPublisherServer) Disconnect(ctx context.Context, req *DisconnectRequest) (*DisconnectResponse, error)

func (*UnimplementedPublisherServer) DiscoverRelatedEntities 

func (*UnimplementedPublisherServer) DiscoverRelatedEntities(ctx context.Context, req *DiscoverRelatedEntitiesRequest) (*DiscoverRelatedEntitiesResponse, error)

func (*UnimplementedPublisherServer) DiscoverSchemas 

func (*UnimplementedPublisherServer) DiscoverSchemas(ctx context.Context, req *DiscoverSchemasRequest) (*DiscoverSchemasResponse, error)

func (*UnimplementedPublisherServer) DiscoverSchemasStream 

func (*UnimplementedPublisherServer) DiscoverSchemasStream(req *DiscoverSchemasRequest, srv Publisher_DiscoverSchemasStreamServer) error

func (*UnimplementedPublisherServer) DiscoverShapes 

func (*UnimplementedPublisherServer) DiscoverShapes(ctx context.Context, req *DiscoverSchemasRequest) (*DiscoverSchemasResponse, error)

func (*UnimplementedPublisherServer) PrepareWrite 

func (*UnimplementedPublisherServer) PrepareWrite(ctx context.Context, req *PrepareWriteRequest) (*PrepareWriteResponse, error)

func (*UnimplementedPublisherServer) PublishStream 

func (*UnimplementedPublisherServer) PublishStream(req *ReadRequest, srv Publisher_PublishStreamServer) error

func (*UnimplementedPublisherServer) ReadStream 

func (*UnimplementedPublisherServer) ReadStream(req *ReadRequest, srv Publisher_ReadStreamServer) error

func (*UnimplementedPublisherServer) WriteStream 

func (*UnimplementedPublisherServer) WriteStream(srv Publisher_WriteStreamServer) error

type UnmarshalledRecord 

type UnmarshalledRecord struct {
	Record
	Data                 map[string]interface{}       `json:"data"`
	UnmarshalledVersions []*UnmarshalledVersionRecord `json:"unmarshalledVersions"`
}

func (UnmarshalledRecord) Clone 

func (u UnmarshalledRecord) Clone() *UnmarshalledRecord

func (UnmarshalledRecord) String 

func (u UnmarshalledRecord) String() string

type UnmarshalledVersionRecord 

type UnmarshalledVersionRecord struct {
	RecordVersion
	Data       map[string]interface{} `json:"data"`
	SchemaData map[string]interface{} `json:"schemaData"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.