plugin

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

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

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

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

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

type GetName_Response struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

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

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

type GetSpecSchema_Response struct {

	// Should be a valid JSON schema for the plugin spec.
	// See https://json-schema.org for more details.
	JsonSchema *string `protobuf:"bytes,1,opt,name=json_schema,json=jsonSchema,proto3,oneof" json:"json_schema,omitempty"`
	// contains filtered or unexported fields
}

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

type GetTables_Request struct {
	Tables              []string `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	SkipTables          []string `protobuf:"bytes,2,rep,name=skip_tables,json=skipTables,proto3" json:"skip_tables,omitempty"`
	SkipDependentTables bool     `protobuf:"varint,3,opt,name=skip_dependent_tables,json=skipDependentTables,proto3" json:"skip_dependent_tables,omitempty"`
	// contains filtered or unexported fields
}

type GetTables_Response struct {

	// marshalled []arrow.Schema
	Tables [][]byte `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

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

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

type GetVersion_Response struct {
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

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

type Init_Request struct {
	Spec         []byte `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`                                      // Internal plugin-specific spec
	NoConnection bool   `protobuf:"varint,2,opt,name=no_connection,json=noConnection,proto3" json:"no_connection,omitempty"` // A flag to indicate plugins should skip establishing a connection
	InvocationId string `protobuf:"bytes,3,opt,name=invocation_id,json=invocationId,proto3" json:"invocation_id,omitempty"`  // unique execution_id that will identify the invocation (sync, migrate etc)
	// contains filtered or unexported fields
}

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

type PluginClient interface {
	// Get the name of the plugin
	GetName(ctx context.Context, in *GetName_Request, opts ...grpc.CallOption) (*GetName_Response, error)
	// Get the current version of the plugin
	GetVersion(ctx context.Context, in *GetVersion_Request, opts ...grpc.CallOption) (*GetVersion_Response, error)
	// Get plugin spec schema.
	// This will allow validating the input even before calling Init.
	// Should be called before Init.
	GetSpecSchema(ctx context.Context, in *GetSpecSchema_Request, opts ...grpc.CallOption) (*GetSpecSchema_Response, error)
	// Configure the plugin with the given credentials and mode
	Init(ctx context.Context, in *Init_Request, opts ...grpc.CallOption) (*Init_Response, error)
	// Get all tables the source plugin supports. Must be called after Init
	GetTables(ctx context.Context, in *GetTables_Request, opts ...grpc.CallOption) (*GetTables_Response, error)
	// Start a sync on the source plugin. It streams messages as output.
	Sync(ctx context.Context, in *Sync_Request, opts ...grpc.CallOption) (Plugin_SyncClient, error)
	// Start a Read on the source plugin for a given table and schema. It streams messages as output.
	// The plugin assume that that schema was used to also write the data beforehand
	Read(ctx context.Context, in *Read_Request, opts ...grpc.CallOption) (Plugin_ReadClient, error)
	// Write resources. Write is the mirror of Sync, expecting a stream of messages as input.
	Write(ctx context.Context, opts ...grpc.CallOption) (Plugin_WriteClient, error)
	// Send signal to flush and close open connections
	Close(ctx context.Context, in *Close_Request, opts ...grpc.CallOption) (*Close_Response, error)
	// Validate and test the connections used by the plugin
	TestConnection(ctx context.Context, in *TestConnection_Request, opts ...grpc.CallOption) (*TestConnection_Response, error)
}

type PluginServer interface {
	// Get the name of the plugin
	GetName(context.Context, *GetName_Request) (*GetName_Response, error)
	// Get the current version of the plugin
	GetVersion(context.Context, *GetVersion_Request) (*GetVersion_Response, error)
	// Get plugin spec schema.
	// This will allow validating the input even before calling Init.
	// Should be called before Init.
	GetSpecSchema(context.Context, *GetSpecSchema_Request) (*GetSpecSchema_Response, error)
	// Configure the plugin with the given credentials and mode
	Init(context.Context, *Init_Request) (*Init_Response, error)
	// Get all tables the source plugin supports. Must be called after Init
	GetTables(context.Context, *GetTables_Request) (*GetTables_Response, error)
	// Start a sync on the source plugin. It streams messages as output.
	Sync(*Sync_Request, Plugin_SyncServer) error
	// Start a Read on the source plugin for a given table and schema. It streams messages as output.
	// The plugin assume that that schema was used to also write the data beforehand
	Read(*Read_Request, Plugin_ReadServer) error
	// Write resources. Write is the mirror of Sync, expecting a stream of messages as input.
	Write(Plugin_WriteServer) error
	// Send signal to flush and close open connections
	Close(context.Context, *Close_Request) (*Close_Response, error)
	// Validate and test the connections used by the plugin
	TestConnection(context.Context, *TestConnection_Request) (*TestConnection_Response, error)
	// contains filtered or unexported methods
}

type Plugin_ReadClient interface {
	Recv() (*Read_Response, error)
	grpc.ClientStream
}

type Plugin_ReadServer interface {
	Send(*Read_Response) error
	grpc.ServerStream
}

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

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

type Plugin_WriteClient interface {
	Send(*Write_Request) error
	CloseAndRecv() (*Write_Response, error)
	grpc.ClientStream
}

type Plugin_WriteServer interface {
	SendAndClose(*Write_Response) error
	Recv() (*Write_Request, error)
	grpc.ServerStream
}

type Predicate struct {
	Operator Predicate_Operator `protobuf:"varint,1,opt,name=operator,proto3,enum=cloudquery.plugin.v3.Predicate_Operator" json:"operator,omitempty"`
	Column   string             `protobuf:"bytes,2,opt,name=column,proto3" json:"column,omitempty"`
	// marshalled arrow.Record
	Record []byte `protobuf:"bytes,3,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

type Predicate_Operator int32

type PredicatesGroup struct {
	GroupingType PredicatesGroup_GroupingType `` /* 153-byte string literal not displayed */
	Predicates   []*Predicate                 `protobuf:"bytes,2,rep,name=predicates,proto3" json:"predicates,omitempty"`
	// contains filtered or unexported fields
}

type PredicatesGroup_GroupingType int32

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

type Read_Request struct {

	// marshalled arrow.Schema
	Table []byte `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

type Read_Response struct {

	// marshalled arrow.Record
	Record []byte `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

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

type Sync_BackendOptions struct {

	// table name to use for state backend
	TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// connection path to use for state backend
	Connection string `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"`
	// contains filtered or unexported fields
}

type Sync_MessageDeleteRecord struct {
	TableName      string             `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	WhereClause    []*PredicatesGroup `protobuf:"bytes,2,rep,name=where_clause,json=whereClause,proto3" json:"where_clause,omitempty"`
	TableRelations []*TableRelation   `protobuf:"bytes,3,rep,name=table_relations,json=tableRelations,proto3" json:"table_relations,omitempty"`
	// contains filtered or unexported fields
}

type Sync_MessageInsert struct {

	// marshalled arrow.Record
	Record []byte `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

type Sync_MessageMigrateTable struct {

	// marshalled arrow.Schema
	Table []byte `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

type Sync_Request struct {
	Tables              []string             `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	SkipTables          []string             `protobuf:"bytes,2,rep,name=skip_tables,json=skipTables,proto3" json:"skip_tables,omitempty"`
	SkipDependentTables bool                 `protobuf:"varint,3,opt,name=skip_dependent_tables,json=skipDependentTables,proto3" json:"skip_dependent_tables,omitempty"`
	DeterministicCqId   bool                 `protobuf:"varint,4,opt,name=deterministic_cq_id,json=deterministicCqId,proto3" json:"deterministic_cq_id,omitempty"`
	Backend             *Sync_BackendOptions `protobuf:"bytes,5,opt,name=backend,proto3" json:"backend,omitempty"`
	// contains filtered or unexported fields
}

type Sync_Response struct {

	// Types that are assignable to Message:
	//
	//	*Sync_Response_MigrateTable
	//	*Sync_Response_Insert
	//	*Sync_Response_DeleteRecord
	Message isSync_Response_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

type Sync_Response_DeleteRecord struct {
	DeleteRecord *Sync_MessageDeleteRecord `protobuf:"bytes,3,opt,name=delete_record,json=deleteRecord,proto3,oneof"`
}

type Sync_Response_Insert struct {
	Insert *Sync_MessageInsert `protobuf:"bytes,2,opt,name=insert,proto3,oneof"`
}

type Sync_Response_MigrateTable struct {
	MigrateTable *Sync_MessageMigrateTable `protobuf:"bytes,1,opt,name=migrate_table,json=migrateTable,proto3,oneof"`
}

type TableRelation struct {
	TableName   string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	ParentTable string `protobuf:"bytes,2,opt,name=parent_table,json=parentTable,proto3" json:"parent_table,omitempty"`
	// contains filtered or unexported fields
}

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

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

type TestConnection_Response struct {
	Success            bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	FailureCode        string `protobuf:"bytes,2,opt,name=failure_code,json=failureCode,proto3" json:"failure_code,omitempty"`
	FailureDescription string `protobuf:"bytes,3,opt,name=failure_description,json=failureDescription,proto3" json:"failure_description,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedPluginServer struct {
}

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

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

type Write_MessageDeleteRecord struct {
	TableName      string             `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	WhereClause    []*PredicatesGroup `protobuf:"bytes,2,rep,name=where_clause,json=whereClause,proto3" json:"where_clause,omitempty"`
	TableRelations []*TableRelation   `protobuf:"bytes,3,rep,name=table_relations,json=tableRelations,proto3" json:"table_relations,omitempty"`
	// contains filtered or unexported fields
}

type Write_MessageDeleteStale struct {

	// marshalled arrow.Schema
	//
	// Deprecated: Marked as deprecated in plugin-pb/plugin/v3/plugin.proto.
	Table      []byte                 `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	SourceName string                 `protobuf:"bytes,2,opt,name=source_name,json=sourceName,proto3" json:"source_name,omitempty"`
	SyncTime   *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=sync_time,json=syncTime,proto3" json:"sync_time,omitempty"`
	TableName  string                 `protobuf:"bytes,4,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// contains filtered or unexported fields
}

type Write_MessageInsert struct {

	// marshalled arrow.Record
	Record []byte `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

type Write_MessageMigrateTable struct {

	// marshalled arrow.Schema
	Table        []byte `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	MigrateForce bool   `protobuf:"varint,2,opt,name=migrate_force,json=migrateForce,proto3" json:"migrate_force,omitempty"`
	// contains filtered or unexported fields
}

type Write_Request struct {

	// Types that are assignable to Message:
	//
	//	*Write_Request_MigrateTable
	//	*Write_Request_Insert
	//	*Write_Request_Delete
	//	*Write_Request_DeleteRecord
	Message isWrite_Request_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

type Write_Request_Delete struct {
	Delete *Write_MessageDeleteStale `protobuf:"bytes,3,opt,name=delete,proto3,oneof"`
}

type Write_Request_DeleteRecord struct {
	DeleteRecord *Write_MessageDeleteRecord `protobuf:"bytes,4,opt,name=delete_record,json=deleteRecord,proto3,oneof"`
}

type Write_Request_Insert struct {
	Insert *Write_MessageInsert `protobuf:"bytes,2,opt,name=insert,proto3,oneof"`
}

type Write_Request_MigrateTable struct {
	MigrateTable *Write_MessageMigrateTable `protobuf:"bytes,1,opt,name=migrate_table,json=migrateTable,proto3,oneof"`
}

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