pb

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

type Configure_Request struct {

	// Holds information such as credentials, regions, accounts, etc'
	// Marshalled spec.SourceSpec or spec.DestinationSpec
	Config []byte `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

type Configure_Response struct {
	Error            string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	JsonschemaResult []byte `protobuf:"bytes,2,opt,name=jsonschema_result,json=jsonschemaResult,proto3" json:"jsonschema_result,omitempty"`
	// contains filtered or unexported fields
}

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

type CreateTables_Request struct {

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

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

type DestinationClient interface {
	Configure(ctx context.Context, in *Configure_Request, opts ...grpc.CallOption) (*Configure_Response, error)
	// Get an example configuration for the source plugin
	GetExampleConfig(ctx context.Context, in *GetExampleConfig_Request, opts ...grpc.CallOption) (*GetExampleConfig_Response, error)
	// Save resources
	Save(ctx context.Context, opts ...grpc.CallOption) (Destination_SaveClient, error)
	// Create tables
	CreateTables(ctx context.Context, in *CreateTables_Request, opts ...grpc.CallOption) (*CreateTables_Response, error)
}

type DestinationServer interface {
	Configure(context.Context, *Configure_Request) (*Configure_Response, error)
	// Get an example configuration for the source plugin
	GetExampleConfig(context.Context, *GetExampleConfig_Request) (*GetExampleConfig_Response, error)
	// Save resources
	Save(Destination_SaveServer) error
	// Create tables
	CreateTables(context.Context, *CreateTables_Request) (*CreateTables_Response, error)
	// contains filtered or unexported methods
}

type Destination_SaveClient interface {
	Send(*Save_Request) error
	CloseAndRecv() (*Save_Response, error)
	grpc.ClientStream
}

type Destination_SaveServer interface {
	SendAndClose(*Save_Response) error
	Recv() (*Save_Request, error)
	grpc.ServerStream
}

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

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

type Fetch_Response struct {

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

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

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

type GetExampleConfig_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"`
	Config  string `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

type GetTables struct {
	// 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 Save struct {
	// contains filtered or unexported fields
}

type Save_Request struct {

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

type Save_Response struct {

	// marshalled goschemajson.Result
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type SourceClient interface {
	// Get all tables the source plugin supports
	GetTables(ctx context.Context, in *GetTables_Request, opts ...grpc.CallOption) (*GetTables_Response, error)
	// Get an example configuration for the source plugin
	GetExampleConfig(ctx context.Context, in *GetExampleConfig_Request, opts ...grpc.CallOption) (*GetExampleConfig_Response, error)
	// Configure the source plugin with the given spec
	Configure(ctx context.Context, in *Configure_Request, opts ...grpc.CallOption) (*Configure_Response, error)
	// Fetch resources
	Fetch(ctx context.Context, in *Fetch_Request, opts ...grpc.CallOption) (Source_FetchClient, error)
}

type SourceServer interface {
	// Get all tables the source plugin supports
	GetTables(context.Context, *GetTables_Request) (*GetTables_Response, error)
	// Get an example configuration for the source plugin
	GetExampleConfig(context.Context, *GetExampleConfig_Request) (*GetExampleConfig_Response, error)
	// Configure the source plugin with the given spec
	Configure(context.Context, *Configure_Request) (*Configure_Response, error)
	// Fetch resources
	Fetch(*Fetch_Request, Source_FetchServer) error
	// contains filtered or unexported methods
}

type Source_FetchClient interface {
	Recv() (*Fetch_Response, error)
	grpc.ClientStream
}

type Source_FetchServer interface {
	Send(*Fetch_Response) error
	grpc.ServerStream
}

type UnimplementedDestinationServer struct {
}

type UnimplementedSourceServer struct {
}

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

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