source

type GetSourceMetrics struct {
	// contains filtered or unexported fields
}

type GetSourceMetrics_Request struct {
	// contains filtered or unexported fields
}

type GetSourceMetrics_Response struct {

	// marshalled json of plugins.SourceMetrics
	Metrics []byte `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

type GetSyncSummary struct {
	// contains filtered or unexported fields
}

type GetSyncSummary_Request struct {
	// contains filtered or unexported fields
}

type GetSyncSummary_Response struct {

	// marshalled *schema.SyncSummary
	Summary []byte `protobuf:"bytes,1,opt,name=summary,proto3" json:"summary,omitempty"`
	// contains filtered or unexported fields
}

type GetTables struct {
	// contains filtered or unexported fields
}

type GetTablesForSpec struct {
	// contains filtered or unexported fields
}

type GetTablesForSpec_Request struct {

	// Marshalled specs.Source
	Spec []byte `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

type GetTablesForSpec_Response struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// Marshalled []*schema.Table
	Tables []byte `protobuf:"bytes,3,opt,name=tables,proto3" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

type GetTables_Request struct {
	// contains filtered or unexported fields
}

type GetTables_Response struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// Marshalled []*schema.Table
	Tables []byte `protobuf:"bytes,3,opt,name=tables,proto3" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

type SourceClient interface {
	// Get the current protocol version of the plugin. This helps
	// get the right message about upgrade/downgrade of cli and/or plugin.
	// Also, on the cli side it can try to upgrade/downgrade the protocol if cli supports it.
	// Depcrecated: use GetSupportedProtocolVersions instead
	GetProtocolVersion(ctx context.Context, in *v0.GetProtocolVersion_Request, opts ...grpc.CallOption) (*v0.GetProtocolVersion_Response, error)
	// Get the name of the plugin
	GetName(ctx context.Context, in *v0.GetName_Request, opts ...grpc.CallOption) (*v0.GetName_Response, error)
	// Get the current version of the plugin
	GetVersion(ctx context.Context, in *v0.GetVersion_Request, opts ...grpc.CallOption) (*v0.GetVersion_Response, error)
	// Get all tables the source plugin supports
	GetTables(ctx context.Context, in *GetTables_Request, opts ...grpc.CallOption) (*GetTables_Response, error)
	// Get all tables the source plugin supports, optionally filtered by a given spec.
	// Introduced in version 2 of the protocol.
	GetTablesForSpec(ctx context.Context, in *GetTablesForSpec_Request, opts ...grpc.CallOption) (*GetTablesForSpec_Response, error)
	// GetSyncSummary returns the latest sync summary of the source plugin. we don't want to send the summary on
	// every sync request.
	GetSyncSummary(ctx context.Context, in *GetSyncSummary_Request, opts ...grpc.CallOption) (*GetSyncSummary_Response, error)
	// Fetch resources
	Sync(ctx context.Context, in *Sync_Request, opts ...grpc.CallOption) (Source_SyncClient, error)
	// Sync2 is a new sync API that supports CQ Types. It is not backward compatible with Sync.
	Sync2(ctx context.Context, in *Sync2_Request, opts ...grpc.CallOption) (Source_Sync2Client, error)
	// Get metrics for the source plugin
	GetMetrics(ctx context.Context, in *GetSourceMetrics_Request, opts ...grpc.CallOption) (*GetSourceMetrics_Response, error)
}

type SourceServer interface {
	// Get the current protocol version of the plugin. This helps
	// get the right message about upgrade/downgrade of cli and/or plugin.
	// Also, on the cli side it can try to upgrade/downgrade the protocol if cli supports it.
	// Depcrecated: use GetSupportedProtocolVersions instead
	GetProtocolVersion(context.Context, *v0.GetProtocolVersion_Request) (*v0.GetProtocolVersion_Response, error)
	// Get the name of the plugin
	GetName(context.Context, *v0.GetName_Request) (*v0.GetName_Response, error)
	// Get the current version of the plugin
	GetVersion(context.Context, *v0.GetVersion_Request) (*v0.GetVersion_Response, error)
	// Get all tables the source plugin supports
	GetTables(context.Context, *GetTables_Request) (*GetTables_Response, error)
	// Get all tables the source plugin supports, optionally filtered by a given spec.
	// Introduced in version 2 of the protocol.
	GetTablesForSpec(context.Context, *GetTablesForSpec_Request) (*GetTablesForSpec_Response, error)
	// GetSyncSummary returns the latest sync summary of the source plugin. we don't want to send the summary on
	// every sync request.
	GetSyncSummary(context.Context, *GetSyncSummary_Request) (*GetSyncSummary_Response, error)
	// Fetch resources
	Sync(*Sync_Request, Source_SyncServer) error
	// Sync2 is a new sync API that supports CQ Types. It is not backward compatible with Sync.
	Sync2(*Sync2_Request, Source_Sync2Server) error
	// Get metrics for the source plugin
	GetMetrics(context.Context, *GetSourceMetrics_Request) (*GetSourceMetrics_Response, error)
	// contains filtered or unexported methods
}

type Source_Sync2Client interface {
	Recv() (*Sync2_Response, error)
	grpc.ClientStream
}

type Source_Sync2Server interface {
	Send(*Sync2_Response) error
	grpc.ServerStream
}

type Source_SyncClient interface {
	Recv() (*Sync_Response, error)
	grpc.ClientStream
}

type Source_SyncServer interface {
	Send(*Sync_Response) error
	grpc.ServerStream
}

type Sync struct {
	// contains filtered or unexported fields
}

type Sync2 struct {
	// contains filtered or unexported fields
}

type Sync2_Request struct {
	Spec []byte `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

type Sync2_Response struct {

	// marshalled *schema.Resources
	Resource []byte `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

type Sync_Request struct {
	Spec []byte `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// sync timestamp
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type Sync_Response struct {

	// marshalled *schema.Resources
	Resource []byte `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedSourceServer struct {
}

type UnsafeSourceServer interface {
	// contains filtered or unexported methods
}