sink

type Command struct {
	Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
	// Native request method, such as GET or POST. Unused by MongoDB.
	Method string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	// Operation path relative to the URI resource, e.g. /_search or /_mapping.
	// Unused by MongoDB; its operation is carried by the BSON command.
	Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	// URL-encoded query parameters without a leading '?'; repeated keys are valid.
	Query string `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
	// Authentication and transport-owned headers remain server-controlled.
	// Set Content-Type using content_type, not headers.
	Headers []*Header `protobuf:"bytes,5,rep,name=headers,proto3" json:"headers,omitempty"`
	// Payload media type. Required when payload is nonempty.
	ContentType string `protobuf:"bytes,6,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// Original ordered command or request body, without a Sink-specific envelope.
	Payload []byte `protobuf:"bytes,7,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

type CompletionMode int32

type CountRequest struct {

	// MongoDB find with an absent or empty filter automatically uses collection
	// metadata when no options require exact execution. Filtered queries,
	// aggregate pipelines and HTTP search counts remain exact.
	Command *Command `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	// contains filtered or unexported fields
}

type CountResponse struct {
	Count uint64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// True when the backend used an estimate instead of counting matching rows.
	Estimated bool `protobuf:"varint,2,opt,name=estimated,proto3" json:"estimated,omitempty"`
	// contains filtered or unexported fields
}

type DeleteOperation struct {
	Address *RecordAddress `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

type DeleteRequest struct {
	CompletionMode CompletionMode `` /* 132-byte string literal not displayed */
	// Deletes are hard deletes. Deleting an absent record is successful.
	Operations []*DeleteOperation `protobuf:"bytes,2,rep,name=operations,proto3" json:"operations,omitempty"`
	// contains filtered or unexported fields
}

type DeleteResponse struct {
	Results []*DeleteResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

type DeleteResult struct {
	OperationIndex uint32       `protobuf:"varint,1,opt,name=operation_index,json=operationIndex,proto3" json:"operation_index,omitempty"`
	Status         DeleteStatus `protobuf:"varint,2,opt,name=status,proto3,enum=sink.v1.DeleteStatus" json:"status,omitempty"`
	Failure        *Failure     `protobuf:"bytes,3,opt,name=failure,proto3" json:"failure,omitempty"`
	// contains filtered or unexported fields
}

type DeleteStatus int32

type Document struct {
	Encoding DocumentEncoding `protobuf:"varint,1,opt,name=encoding,proto3,enum=sink.v1.DocumentEncoding" json:"encoding,omitempty"`
	Payload  []byte           `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

type DocumentEncoding int32

type ExecuteRequest struct {
	Command *Command `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	// contains filtered or unexported fields
}

type ExecuteResponse struct {
	ContentType string `protobuf:"bytes,1,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	Payload     []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// Native command success, or HTTP 2xx. Callers must still inspect item-level
	// failures in batch responses. Document commands also check native write and
	// write-concern errors.
	Success bool `protobuf:"varint,3,opt,name=success,proto3" json:"success,omitempty"`
	// Native transport status when available; zero means no such status exists.
	StatusCode uint32    `protobuf:"varint,4,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	Headers    []*Header `protobuf:"bytes,5,rep,name=headers,proto3" json:"headers,omitempty"`
	// contains filtered or unexported fields
}

type Failure struct {
	Code      FailureCode `protobuf:"varint,1,opt,name=code,proto3,enum=sink.v1.FailureCode" json:"code,omitempty"`
	Message   string      `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Retryable bool        `protobuf:"varint,3,opt,name=retryable,proto3" json:"retryable,omitempty"`
	// contains filtered or unexported fields
}

type FailureCode int32

type Header struct {
	Name   string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Values []string `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

type LuaProgram struct {

	// Source may be omitted from a merge operation when the matching full program
	// is present in WriteRequest.lua_programs. Workers always receive full source.
	Source []byte `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	// Optional SHA-256 digest. Sink verifies it when present and always uses the
	// computed digest as the compiled-program cache key.
	Sha256 []byte `protobuf:"bytes,2,opt,name=sha256,proto3" json:"sha256,omitempty"`
	// contains filtered or unexported fields
}

type MergeOperation struct {
	IncomingDocument *Document   `protobuf:"bytes,1,opt,name=incoming_document,json=incomingDocument,proto3" json:"incoming_document,omitempty"`
	LuaProgram       *LuaProgram `protobuf:"bytes,2,opt,name=lua_program,json=luaProgram,proto3" json:"lua_program,omitempty"`
	// contains filtered or unexported fields
}

type Projection struct {
	Fields  []string `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	Exclude bool     `protobuf:"varint,2,opt,name=exclude,proto3" json:"exclude,omitempty"` // False includes listed fields; true excludes them.
	// contains filtered or unexported fields
}

type PutOperation struct {
	Document *Document `protobuf:"bytes,1,opt,name=document,proto3" json:"document,omitempty"`
	Mode     WriteMode `protobuf:"varint,2,opt,name=mode,proto3,enum=sink.v1.WriteMode" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

type QueryRequest struct {
	Command *Command `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	// One-based page number; zero selects page 1. Deep pages still incur backend
	// offset costs and are subject to the backend's result-window limits.
	Page uint32 `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"`
	// Zero selects 100; maximum 1000. Query replaces native find skip/limit and
	// HTTP from/size. For aggregate, pagination follows the supplied pipeline.
	PageSize uint32 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Ordered sort keys. Empty preserves the native sort; nonempty replaces find
	// or HTTP sorting. For aggregate, sort follows the supplied pipeline.
	Sort []*SortField `protobuf:"bytes,4,rep,name=sort,proto3" json:"sort,omitempty"`
	// Absent preserves native projection. Present replaces find projection or
	// HTTP _source selection; aggregate applies it after the pipeline and sort,
	// before pagination. An empty fields list selects all document fields.
	Projection *Projection `protobuf:"bytes,5,opt,name=projection,proto3" json:"projection,omitempty"`
	// contains filtered or unexported fields
}

type QueryResponse struct {
	Documents []*Document `protobuf:"bytes,1,rep,name=documents,proto3" json:"documents,omitempty"`
	// Determined by fetching one extra result, not by running Count. Result-window
	// limits apply to this extra result too. A byte limit fails the whole request;
	// it never produces a silently shortened page.
	HasMore  bool `protobuf:"varint,2,opt,name=has_more,json=hasMore,proto3" json:"has_more,omitempty"`
	Complete bool `protobuf:"varint,3,opt,name=complete,proto3" json:"complete,omitempty"`
	// contains filtered or unexported fields
}

type ReadOperation struct {
	Address *RecordAddress `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

type ReadRequest struct {
	Operations []*ReadOperation `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"`
	// contains filtered or unexported fields
}

type ReadResponse struct {

	// Each frame contains one result. Results may arrive out of order; correlate
	// by operation_index. Successful EOF requires exactly one result per operation.
	Results []*ReadResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

type ReadResult struct {
	OperationIndex uint32     `protobuf:"varint,1,opt,name=operation_index,json=operationIndex,proto3" json:"operation_index,omitempty"`
	Status         ReadStatus `protobuf:"varint,2,opt,name=status,proto3,enum=sink.v1.ReadStatus" json:"status,omitempty"`
	Document       *Document  `protobuf:"bytes,3,opt,name=document,proto3" json:"document,omitempty"`
	Failure        *Failure   `protobuf:"bytes,5,opt,name=failure,proto3" json:"failure,omitempty"`
	// contains filtered or unexported fields
}

type ReadStatus int32

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

type ScanRequest struct {
	Command *Command `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	// Zero selects 100; maximum 1000. The byte limit may produce a smaller page.
	BatchSize uint32 `protobuf:"varint,2,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	// Empty starts a new scan. Treat this continuation marker as opaque; it is
	// bound to Command and Projection and is not an authorization credential.
	Cursor []byte `protobuf:"bytes,3,opt,name=cursor,proto3" json:"cursor,omitempty"`
	// Absent preserves native projection. Present replaces find projection or
	// HTTP _source selection. Empty fields selects all document fields. MongoDB
	// retains _id internally for continuation even when excluded from results;
	// HTTP hit metadata and sort values are unchanged.
	Projection *Projection `protobuf:"bytes,4,opt,name=projection,proto3" json:"projection,omitempty"`
	// contains filtered or unexported fields
}

type ScanResponse struct {
	Documents []*Document `protobuf:"bytes,1,rep,name=documents,proto3" json:"documents,omitempty"`
	// Empty means the scan reached the end observed by this request. Commit a
	// checkpoint only after processing documents and successful EOF. No close RPC is needed.
	NextCursor []byte `protobuf:"bytes,2,opt,name=next_cursor,json=nextCursor,proto3" json:"next_cursor,omitempty"`
	Complete   bool   `protobuf:"varint,3,opt,name=complete,proto3" json:"complete,omitempty"`
	// contains filtered or unexported fields
}

type SinkClient interface {
	Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ReadResponse], error)
	Write(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[WriteResponse], error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	Execute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error)
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[QueryResponse], error)
	Count(ctx context.Context, in *CountRequest, opts ...grpc.CallOption) (*CountResponse, error)
	Scan(ctx context.Context, in *ScanRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ScanResponse], error)
}

type SinkServer interface {
	Read(*ReadRequest, grpc.ServerStreamingServer[ReadResponse]) error
	Write(*WriteRequest, grpc.ServerStreamingServer[WriteResponse]) error
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error)
	Query(*QueryRequest, grpc.ServerStreamingServer[QueryResponse]) error
	Count(context.Context, *CountRequest) (*CountResponse, error)
	Scan(*ScanRequest, grpc.ServerStreamingServer[ScanResponse]) error
	// contains filtered or unexported methods
}

type Sink_QueryClient = grpc.ServerStreamingClient[QueryResponse]

type Sink_QueryServer = grpc.ServerStreamingServer[QueryResponse]

type Sink_ReadClient = grpc.ServerStreamingClient[ReadResponse]

type Sink_ReadServer = grpc.ServerStreamingServer[ReadResponse]

type Sink_ScanClient = grpc.ServerStreamingClient[ScanResponse]

type Sink_ScanServer = grpc.ServerStreamingServer[ScanResponse]

type Sink_WriteClient = grpc.ServerStreamingClient[WriteResponse]

type Sink_WriteServer = grpc.ServerStreamingServer[WriteResponse]

type SortField struct {
	Field      string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	Descending bool   `protobuf:"varint,2,opt,name=descending,proto3" json:"descending,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedSinkServer struct{}

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

type WriteMode int32

type WriteOperation struct {
	Address *RecordAddress `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Types that are valid to be assigned to Action:
	//
	//	*WriteOperation_Put
	//	*WriteOperation_Merge
	Action isWriteOperation_Action `protobuf_oneof:"action"`
	// Return the logical document submitted by this operation after its commit.
	// Only synchronous completion modes support this. These operations do not
	// share a folded commit with preceding or following operations.
	ReturnDocument bool `protobuf:"varint,4,opt,name=return_document,json=returnDocument,proto3" json:"return_document,omitempty"`
	// contains filtered or unexported fields
}

type WriteOperation_Merge struct {
	Merge *MergeOperation `protobuf:"bytes,3,opt,name=merge,proto3,oneof"`
}

type WriteOperation_Put struct {
	Put *PutOperation `protobuf:"bytes,2,opt,name=put,proto3,oneof"`
}

type WriteRequest struct {
	CompletionMode CompletionMode `` /* 132-byte string literal not displayed */
	// Operations for the same address are executed in request order. Operations
	// for different addresses may execute concurrently.
	Operations []*WriteOperation `protobuf:"bytes,2,rep,name=operations,proto3" json:"operations,omitempty"`
	// Programs can be declared once and referenced by digest from multiple merge
	// operations, avoiding repeated Lua source bytes in a synchronous batch.
	LuaPrograms []*LuaProgram `protobuf:"bytes,3,rep,name=lua_programs,json=luaPrograms,proto3" json:"lua_programs,omitempty"`
	// contains filtered or unexported fields
}

type WriteResponse struct {
	Results []*WriteResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

type WriteResult struct {
	OperationIndex uint32      `protobuf:"varint,1,opt,name=operation_index,json=operationIndex,proto3" json:"operation_index,omitempty"`
	Status         WriteStatus `protobuf:"varint,2,opt,name=status,proto3,enum=sink.v1.WriteStatus" json:"status,omitempty"`
	Failure        *Failure    `protobuf:"bytes,4,opt,name=failure,proto3" json:"failure,omitempty"`
	Document       *Document   `protobuf:"bytes,5,opt,name=document,proto3" json:"document,omitempty"`
	// contains filtered or unexported fields
}

type WriteStatus int32