Help us shape the future of Go! Take the 2026 Go Developer Survey

sdk_sync

package
v0.57.29 Latest Latest
Warning

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

 Go to latest Published: Oct 26, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const SRPCApplicationServiceID = "sdk.sync.Application"
View Source 
const SRPCCollectionServiceID = "sdk.sync.Collection"
View Source 
const SRPCGatewayServiceID = "sdk.sync.Gateway"

Variables

View Source 
var (
	ErrorCode_name = map[int32]string{
		0:  "ERROR_CODE_UNSPECIFIED",
		1:  "VALIDATION",
		2:  "AUTHENTICATION",
		3:  "DENIED",
		4:  "MISSING_COLLECTION",
		5:  "SCHEMA_MISMATCH",
		6:  "QUERY_LIMIT",
		7:  "CONFLICT",
		8:  "UNAVAILABLE",
		9:  "UNCERTAIN",
		10: "STORAGE",
		11: "CLOSED",
	}
	ErrorCode_value = map[string]int32{
		"ERROR_CODE_UNSPECIFIED": 0,
		"VALIDATION":             1,
		"AUTHENTICATION":         2,
		"DENIED":                 3,
		"MISSING_COLLECTION":     4,
		"SCHEMA_MISMATCH":        5,
		"QUERY_LIMIT":            6,
		"CONFLICT":               7,
		"UNAVAILABLE":            8,
		"UNCERTAIN":              9,
		"STORAGE":                10,
		"CLOSED":                 11,
	}
)

Enum value maps for ErrorCode.

Functions

func NewSRPCApplicationHandler 

func NewSRPCApplicationHandler(impl SRPCApplicationServer, serviceID string) srpc.Handler

NewSRPCApplicationHandler constructs a new RPC handler. serviceID: if empty, uses default: sdk.sync.Application

func NewSRPCCollectionHandler 

func NewSRPCCollectionHandler(impl SRPCCollectionServer, serviceID string) srpc.Handler

NewSRPCCollectionHandler constructs a new RPC handler. serviceID: if empty, uses default: sdk.sync.Collection

func NewSRPCGatewayHandler 

func NewSRPCGatewayHandler(impl SRPCGatewayServer, serviceID string) srpc.Handler

NewSRPCGatewayHandler constructs a new RPC handler. serviceID: if empty, uses default: sdk.sync.Gateway

func SRPCRegisterApplication 

func SRPCRegisterApplication(mux srpc.Mux, impl SRPCApplicationServer) error

SRPCRegisterApplication registers the implementation with the mux. Uses the default serviceID: sdk.sync.Application

func SRPCRegisterCollection 

func SRPCRegisterCollection(mux srpc.Mux, impl SRPCCollectionServer) error

SRPCRegisterCollection registers the implementation with the mux. Uses the default serviceID: sdk.sync.Collection

func SRPCRegisterGateway 

func SRPCRegisterGateway(mux srpc.Mux, impl SRPCGatewayServer) error

SRPCRegisterGateway registers the implementation with the mux. Uses the default serviceID: sdk.sync.Gateway

Types

type Acceptance 

type Acceptance struct {

	// Error is absent only after the receipt and change are durably fenced.
	Error *Failure `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

Acceptance acknowledges a durable write or reports its failure.

func (*Acceptance) CloneMessageVT 

func (m *Acceptance) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*Acceptance) CloneVT 

func (m *Acceptance) CloneVT() *Acceptance

func (*Acceptance) EqualMessageVT 

func (this *Acceptance) EqualMessageVT(thatMsg any) bool

func (*Acceptance) EqualVT 

func (this *Acceptance) EqualVT(that *Acceptance) bool

func (*Acceptance) GetError 

func (x *Acceptance) GetError() *Failure

func (*Acceptance) MarshalJSON 

func (x *Acceptance) MarshalJSON() ([]byte, error)

MarshalJSON marshals the Acceptance to JSON.

func (*Acceptance) MarshalProtoJSON 

func (x *Acceptance) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the Acceptance message to JSON.

func (*Acceptance) MarshalProtoText 

func (x *Acceptance) MarshalProtoText() string

func (*Acceptance) MarshalToSizedBufferVT 

func (m *Acceptance) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Acceptance) MarshalToVT 

func (m *Acceptance) MarshalToVT(dAtA []byte) (int, error)

func (*Acceptance) MarshalVT 

func (m *Acceptance) MarshalVT() (dAtA []byte, err error)

func (*Acceptance) ProtoMessage 

func (*Acceptance) ProtoMessage()

func (*Acceptance) Reset 

func (x *Acceptance) Reset()

func (*Acceptance) SizeVT 

func (m *Acceptance) SizeVT() (n int)

func (*Acceptance) String 

func (x *Acceptance) String() string

func (*Acceptance) UnmarshalJSON 

func (x *Acceptance) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the Acceptance from JSON.

func (*Acceptance) UnmarshalProtoJSON 

func (x *Acceptance) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the Acceptance message from JSON.

func (*Acceptance) UnmarshalVT 

func (m *Acceptance) UnmarshalVT(dAtA []byte) error

type DeleteRequest 

type DeleteRequest struct {

	// Key identifies the record within the collection.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// RequestId must remain unchanged when retrying this removal.
	RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"requestId,omitempty"`
	// contains filtered or unexported fields
}

DeleteRequest identifies a removal and its stable retry identity.

func (*DeleteRequest) CloneMessageVT 

func (m *DeleteRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*DeleteRequest) CloneVT 

func (m *DeleteRequest) CloneVT() *DeleteRequest

func (*DeleteRequest) EqualMessageVT 

func (this *DeleteRequest) EqualMessageVT(thatMsg any) bool

func (*DeleteRequest) EqualVT 

func (this *DeleteRequest) EqualVT(that *DeleteRequest) bool

func (*DeleteRequest) GetKey 

func (x *DeleteRequest) GetKey() string

func (*DeleteRequest) GetRequestId 

func (x *DeleteRequest) GetRequestId() string

func (*DeleteRequest) MarshalJSON 

func (x *DeleteRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the DeleteRequest to JSON.

func (*DeleteRequest) MarshalProtoJSON 

func (x *DeleteRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the DeleteRequest message to JSON.

func (*DeleteRequest) MarshalProtoText 

func (x *DeleteRequest) MarshalProtoText() string

func (*DeleteRequest) MarshalToSizedBufferVT 

func (m *DeleteRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DeleteRequest) MarshalToVT 

func (m *DeleteRequest) MarshalToVT(dAtA []byte) (int, error)

func (*DeleteRequest) MarshalVT 

func (m *DeleteRequest) MarshalVT() (dAtA []byte, err error)

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) SizeVT 

func (m *DeleteRequest) SizeVT() (n int)

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

func (*DeleteRequest) UnmarshalJSON 

func (x *DeleteRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the DeleteRequest from JSON.

func (*DeleteRequest) UnmarshalProtoJSON 

func (x *DeleteRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the DeleteRequest message from JSON.

func (*DeleteRequest) UnmarshalVT 

func (m *DeleteRequest) UnmarshalVT(dAtA []byte) error

type ErrorCode 

type ErrorCode int32

ErrorCode identifies stable application failure classes. 

const (
	// ERROR_CODE_UNSPECIFIED is not a valid failure.
	ErrorCode_ERROR_CODE_UNSPECIFIED ErrorCode = 0
	// VALIDATION rejects a value that does not satisfy the contract.
	ErrorCode_VALIDATION ErrorCode = 1
	// AUTHENTICATION requires a new valid principal.
	ErrorCode_AUTHENTICATION ErrorCode = 2
	// DENIED rejects an operation forbidden by collection policy.
	ErrorCode_DENIED ErrorCode = 3
	// MISSING_COLLECTION identifies an undeclared collection.
	ErrorCode_MISSING_COLLECTION ErrorCode = 4
	// SCHEMA_MISMATCH rejects incompatible wire, application, or stored versions.
	ErrorCode_SCHEMA_MISMATCH ErrorCode = 5
	// QUERY_LIMIT rejects an oversized complete snapshot or record.
	ErrorCode_QUERY_LIMIT ErrorCode = 6
	// CONFLICT rejects a request ID reused with different input.
	ErrorCode_CONFLICT ErrorCode = 7
	// UNAVAILABLE identifies a disconnected or canceled operation.
	ErrorCode_UNAVAILABLE ErrorCode = 8
	// UNCERTAIN requires retrying the same request ID and input.
	ErrorCode_UNCERTAIN ErrorCode = 9
	// STORAGE reports failure without exposing internal storage details.
	ErrorCode_STORAGE ErrorCode = 10
	// CLOSED identifies a released handle or stopped server.
	ErrorCode_CLOSED ErrorCode = 11
)

func (ErrorCode) Enum 

func (x ErrorCode) Enum() *ErrorCode

func (ErrorCode) MarshalJSON 

func (x ErrorCode) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ErrorCode to JSON.

func (ErrorCode) MarshalProtoJSON 

func (x ErrorCode) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ErrorCode to JSON.

func (ErrorCode) MarshalProtoText 

func (x ErrorCode) MarshalProtoText() string

func (ErrorCode) MarshalText 

func (x ErrorCode) MarshalText() ([]byte, error)

MarshalText marshals the ErrorCode to text.

func (ErrorCode) String 

func (x ErrorCode) String() string

func (*ErrorCode) UnmarshalJSON 

func (x *ErrorCode) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ErrorCode from JSON.

func (*ErrorCode) UnmarshalProtoJSON 

func (x *ErrorCode) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ErrorCode from JSON.

func (*ErrorCode) UnmarshalText 

func (x *ErrorCode) UnmarshalText(b []byte) error

UnmarshalText unmarshals the ErrorCode from text.

type Failure 

type Failure struct {

	// Code is the stable failure class.
	Code ErrorCode `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// Message explains the action the application can take.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// RequestId identifies an uncertain mutation for explicit recovery.
	RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"requestId,omitempty"`
	// contains filtered or unexported fields
}

Failure contains only safe application details and an optional recovery ID.

func (*Failure) CloneMessageVT 

func (m *Failure) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*Failure) CloneVT 

func (m *Failure) CloneVT() *Failure

func (*Failure) EqualMessageVT 

func (this *Failure) EqualMessageVT(thatMsg any) bool

func (*Failure) EqualVT 

func (this *Failure) EqualVT(that *Failure) bool

func (*Failure) GetCode 

func (x *Failure) GetCode() ErrorCode

func (*Failure) GetMessage 

func (x *Failure) GetMessage() string

func (*Failure) GetRequestId 

func (x *Failure) GetRequestId() string

func (*Failure) MarshalJSON 

func (x *Failure) MarshalJSON() ([]byte, error)

MarshalJSON marshals the Failure to JSON.

func (*Failure) MarshalProtoJSON 

func (x *Failure) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the Failure message to JSON.

func (*Failure) MarshalProtoText 

func (x *Failure) MarshalProtoText() string

func (*Failure) MarshalToSizedBufferVT 

func (m *Failure) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Failure) MarshalToVT 

func (m *Failure) MarshalToVT(dAtA []byte) (int, error)

func (*Failure) MarshalVT 

func (m *Failure) MarshalVT() (dAtA []byte, err error)

func (*Failure) ProtoMessage 

func (*Failure) ProtoMessage()

func (*Failure) Reset 

func (x *Failure) Reset()

func (*Failure) SizeVT 

func (m *Failure) SizeVT() (n int)

func (*Failure) String 

func (x *Failure) String() string

func (*Failure) UnmarshalJSON 

func (x *Failure) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the Failure from JSON.

func (*Failure) UnmarshalProtoJSON 

func (x *Failure) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the Failure message from JSON.

func (*Failure) UnmarshalVT 

func (m *Failure) UnmarshalVT(dAtA []byte) error

type GetRequest 

type GetRequest struct {

	// Key identifies the record within the bound collection.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

GetRequest selects one UTF-8 record key.

func (*GetRequest) CloneMessageVT 

func (m *GetRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*GetRequest) CloneVT 

func (m *GetRequest) CloneVT() *GetRequest

func (*GetRequest) EqualMessageVT 

func (this *GetRequest) EqualMessageVT(thatMsg any) bool

func (*GetRequest) EqualVT 

func (this *GetRequest) EqualVT(that *GetRequest) bool

func (*GetRequest) GetKey 

func (x *GetRequest) GetKey() string

func (*GetRequest) MarshalJSON 

func (x *GetRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetRequest to JSON.

func (*GetRequest) MarshalProtoJSON 

func (x *GetRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetRequest message to JSON.

func (*GetRequest) MarshalProtoText 

func (x *GetRequest) MarshalProtoText() string

func (*GetRequest) MarshalToSizedBufferVT 

func (m *GetRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetRequest) MarshalToVT 

func (m *GetRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetRequest) MarshalVT 

func (m *GetRequest) MarshalVT() (dAtA []byte, err error)

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) SizeVT 

func (m *GetRequest) SizeVT() (n int)

func (*GetRequest) String 

func (x *GetRequest) String() string

func (*GetRequest) UnmarshalJSON 

func (x *GetRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetRequest from JSON.

func (*GetRequest) UnmarshalProtoJSON 

func (x *GetRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetRequest message from JSON.

func (*GetRequest) UnmarshalVT 

func (m *GetRequest) UnmarshalVT(dAtA []byte) error

type GetResponse 

type GetResponse struct {

	// Found is true even when Data encodes JSON null.
	Found bool `protobuf:"varint,1,opt,name=found,proto3" json:"found,omitempty"`
	// Data contains canonical JSON for a present record.
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// Error is set when the read fails.
	Error *Failure `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

GetResponse distinguishes absence from a present JSON value.

func (*GetResponse) CloneMessageVT 

func (m *GetResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*GetResponse) CloneVT 

func (m *GetResponse) CloneVT() *GetResponse

func (*GetResponse) EqualMessageVT 

func (this *GetResponse) EqualMessageVT(thatMsg any) bool

func (*GetResponse) EqualVT 

func (this *GetResponse) EqualVT(that *GetResponse) bool

func (*GetResponse) GetData 

func (x *GetResponse) GetData() []byte

func (*GetResponse) GetError 

func (x *GetResponse) GetError() *Failure

func (*GetResponse) GetFound 

func (x *GetResponse) GetFound() bool

func (*GetResponse) MarshalJSON 

func (x *GetResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the GetResponse to JSON.

func (*GetResponse) MarshalProtoJSON 

func (x *GetResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the GetResponse message to JSON.

func (*GetResponse) MarshalProtoText 

func (x *GetResponse) MarshalProtoText() string

func (*GetResponse) MarshalToSizedBufferVT 

func (m *GetResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetResponse) MarshalToVT 

func (m *GetResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetResponse) MarshalVT 

func (m *GetResponse) MarshalVT() (dAtA []byte, err error)

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) SizeVT 

func (m *GetResponse) SizeVT() (n int)

func (*GetResponse) String 

func (x *GetResponse) String() string

func (*GetResponse) UnmarshalJSON 

func (x *GetResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the GetResponse from JSON.

func (*GetResponse) UnmarshalProtoJSON 

func (x *GetResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the GetResponse message from JSON.

func (*GetResponse) UnmarshalVT 

func (m *GetResponse) UnmarshalVT(dAtA []byte) error

type HandshakeRequest 

type HandshakeRequest struct {

	// WireVersion selects the package-owned protocol version.
	WireVersion uint32 `protobuf:"varint,1,opt,name=wire_version,json=wireVersion,proto3" json:"wireVersion,omitempty"`
	// ApplicationId identifies the declared application contract.
	ApplicationId string `protobuf:"bytes,2,opt,name=application_id,json=applicationId,proto3" json:"applicationId,omitempty"`
	// ApplicationVersion selects its explicit schema version.
	ApplicationVersion uint32 `protobuf:"varint,3,opt,name=application_version,json=applicationVersion,proto3" json:"applicationVersion,omitempty"`
	// Token is supplied to the server authentication callback and never retained.
	Token string `protobuf:"bytes,4,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

HandshakeRequest supplies compatibility and authentication in the first RPC.

func (*HandshakeRequest) CloneMessageVT 

func (m *HandshakeRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*HandshakeRequest) CloneVT 

func (m *HandshakeRequest) CloneVT() *HandshakeRequest

func (*HandshakeRequest) EqualMessageVT 

func (this *HandshakeRequest) EqualMessageVT(thatMsg any) bool

func (*HandshakeRequest) EqualVT 

func (this *HandshakeRequest) EqualVT(that *HandshakeRequest) bool

func (*HandshakeRequest) GetApplicationId 

func (x *HandshakeRequest) GetApplicationId() string

func (*HandshakeRequest) GetApplicationVersion 

func (x *HandshakeRequest) GetApplicationVersion() uint32

func (*HandshakeRequest) GetToken 

func (x *HandshakeRequest) GetToken() string

func (*HandshakeRequest) GetWireVersion 

func (x *HandshakeRequest) GetWireVersion() uint32

func (*HandshakeRequest) MarshalJSON 

func (x *HandshakeRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the HandshakeRequest to JSON.

func (*HandshakeRequest) MarshalProtoJSON 

func (x *HandshakeRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the HandshakeRequest message to JSON.

func (*HandshakeRequest) MarshalProtoText 

func (x *HandshakeRequest) MarshalProtoText() string

func (*HandshakeRequest) MarshalToSizedBufferVT 

func (m *HandshakeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*HandshakeRequest) MarshalToVT 

func (m *HandshakeRequest) MarshalToVT(dAtA []byte) (int, error)

func (*HandshakeRequest) MarshalVT 

func (m *HandshakeRequest) MarshalVT() (dAtA []byte, err error)

func (*HandshakeRequest) ProtoMessage 

func (*HandshakeRequest) ProtoMessage()

func (*HandshakeRequest) Reset 

func (x *HandshakeRequest) Reset()

func (*HandshakeRequest) SizeVT 

func (m *HandshakeRequest) SizeVT() (n int)

func (*HandshakeRequest) String 

func (x *HandshakeRequest) String() string

func (*HandshakeRequest) UnmarshalJSON 

func (x *HandshakeRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the HandshakeRequest from JSON.

func (*HandshakeRequest) UnmarshalProtoJSON 

func (x *HandshakeRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the HandshakeRequest message from JSON.

func (*HandshakeRequest) UnmarshalVT 

func (m *HandshakeRequest) UnmarshalVT(dAtA []byte) error

type HandshakeResponse 

type HandshakeResponse struct {

	// Error is set when admission fails.
	Error *Failure `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

HandshakeResponse confirms admission or reports a safe failure.

func (*HandshakeResponse) CloneMessageVT 

func (m *HandshakeResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*HandshakeResponse) CloneVT 

func (m *HandshakeResponse) CloneVT() *HandshakeResponse

func (*HandshakeResponse) EqualMessageVT 

func (this *HandshakeResponse) EqualMessageVT(thatMsg any) bool

func (*HandshakeResponse) EqualVT 

func (this *HandshakeResponse) EqualVT(that *HandshakeResponse) bool

func (*HandshakeResponse) GetError 

func (x *HandshakeResponse) GetError() *Failure

func (*HandshakeResponse) MarshalJSON 

func (x *HandshakeResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the HandshakeResponse to JSON.

func (*HandshakeResponse) MarshalProtoJSON 

func (x *HandshakeResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the HandshakeResponse message to JSON.

func (*HandshakeResponse) MarshalProtoText 

func (x *HandshakeResponse) MarshalProtoText() string

func (*HandshakeResponse) MarshalToSizedBufferVT 

func (m *HandshakeResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*HandshakeResponse) MarshalToVT 

func (m *HandshakeResponse) MarshalToVT(dAtA []byte) (int, error)

func (*HandshakeResponse) MarshalVT 

func (m *HandshakeResponse) MarshalVT() (dAtA []byte, err error)

func (*HandshakeResponse) ProtoMessage 

func (*HandshakeResponse) ProtoMessage()

func (*HandshakeResponse) Reset 

func (x *HandshakeResponse) Reset()

func (*HandshakeResponse) SizeVT 

func (m *HandshakeResponse) SizeVT() (n int)

func (*HandshakeResponse) String 

func (x *HandshakeResponse) String() string

func (*HandshakeResponse) UnmarshalJSON 

func (x *HandshakeResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the HandshakeResponse from JSON.

func (*HandshakeResponse) UnmarshalProtoJSON 

func (x *HandshakeResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the HandshakeResponse message from JSON.

func (*HandshakeResponse) UnmarshalVT 

func (m *HandshakeResponse) UnmarshalVT(dAtA []byte) error

type MutationRequest 

type MutationRequest struct {

	// Name identifies the mutation in the shared contract.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Input contains its JSON input before server validation.
	Input []byte `protobuf:"bytes,2,opt,name=input,proto3" json:"input,omitempty"`
	// RequestId must remain unchanged when retrying this invocation.
	RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"requestId,omitempty"`
	// contains filtered or unexported fields
}

MutationRequest invokes a declared server handler with a stable retry ID.

func (*MutationRequest) CloneMessageVT 

func (m *MutationRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*MutationRequest) CloneVT 

func (m *MutationRequest) CloneVT() *MutationRequest

func (*MutationRequest) EqualMessageVT 

func (this *MutationRequest) EqualMessageVT(thatMsg any) bool

func (*MutationRequest) EqualVT 

func (this *MutationRequest) EqualVT(that *MutationRequest) bool

func (*MutationRequest) GetInput 

func (x *MutationRequest) GetInput() []byte

func (*MutationRequest) GetName 

func (x *MutationRequest) GetName() string

func (*MutationRequest) GetRequestId 

func (x *MutationRequest) GetRequestId() string

func (*MutationRequest) MarshalJSON 

func (x *MutationRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the MutationRequest to JSON.

func (*MutationRequest) MarshalProtoJSON 

func (x *MutationRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the MutationRequest message to JSON.

func (*MutationRequest) MarshalProtoText 

func (x *MutationRequest) MarshalProtoText() string

func (*MutationRequest) MarshalToSizedBufferVT 

func (m *MutationRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MutationRequest) MarshalToVT 

func (m *MutationRequest) MarshalToVT(dAtA []byte) (int, error)

func (*MutationRequest) MarshalVT 

func (m *MutationRequest) MarshalVT() (dAtA []byte, err error)

func (*MutationRequest) ProtoMessage 

func (*MutationRequest) ProtoMessage()

func (*MutationRequest) Reset 

func (x *MutationRequest) Reset()

func (*MutationRequest) SizeVT 

func (m *MutationRequest) SizeVT() (n int)

func (*MutationRequest) String 

func (x *MutationRequest) String() string

func (*MutationRequest) UnmarshalJSON 

func (x *MutationRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the MutationRequest from JSON.

func (*MutationRequest) UnmarshalProtoJSON 

func (x *MutationRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the MutationRequest message from JSON.

func (*MutationRequest) UnmarshalVT 

func (m *MutationRequest) UnmarshalVT(dAtA []byte) error

type MutationResponse 

type MutationResponse struct {

	// Result contains the accepted JSON output, including JSON null.
	Result []byte `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// Error is set when acceptance or its outcome could not be confirmed.
	Error *Failure `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

MutationResponse contains the validated durable result or a safe failure.

func (*MutationResponse) CloneMessageVT 

func (m *MutationResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*MutationResponse) CloneVT 

func (m *MutationResponse) CloneVT() *MutationResponse

func (*MutationResponse) EqualMessageVT 

func (this *MutationResponse) EqualMessageVT(thatMsg any) bool

func (*MutationResponse) EqualVT 

func (this *MutationResponse) EqualVT(that *MutationResponse) bool

func (*MutationResponse) GetError 

func (x *MutationResponse) GetError() *Failure

func (*MutationResponse) GetResult 

func (x *MutationResponse) GetResult() []byte

func (*MutationResponse) MarshalJSON 

func (x *MutationResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the MutationResponse to JSON.

func (*MutationResponse) MarshalProtoJSON 

func (x *MutationResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the MutationResponse message to JSON.

func (*MutationResponse) MarshalProtoText 

func (x *MutationResponse) MarshalProtoText() string

func (*MutationResponse) MarshalToSizedBufferVT 

func (m *MutationResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MutationResponse) MarshalToVT 

func (m *MutationResponse) MarshalToVT(dAtA []byte) (int, error)

func (*MutationResponse) MarshalVT 

func (m *MutationResponse) MarshalVT() (dAtA []byte, err error)

func (*MutationResponse) ProtoMessage 

func (*MutationResponse) ProtoMessage()

func (*MutationResponse) Reset 

func (x *MutationResponse) Reset()

func (*MutationResponse) SizeVT 

func (m *MutationResponse) SizeVT() (n int)

func (*MutationResponse) String 

func (x *MutationResponse) String() string

func (*MutationResponse) UnmarshalJSON 

func (x *MutationResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the MutationResponse from JSON.

func (*MutationResponse) UnmarshalProtoJSON 

func (x *MutationResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the MutationResponse message from JSON.

func (*MutationResponse) UnmarshalVT 

func (m *MutationResponse) UnmarshalVT(dAtA []byte) error

type OpenCollectionRequest 

type OpenCollectionRequest struct {

	// Name identifies the collection in the application schema.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

OpenCollectionRequest selects a declared collection before prefix filtering.

func (*OpenCollectionRequest) CloneMessageVT 

func (m *OpenCollectionRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*OpenCollectionRequest) CloneVT 

func (m *OpenCollectionRequest) CloneVT() *OpenCollectionRequest

func (*OpenCollectionRequest) EqualMessageVT 

func (this *OpenCollectionRequest) EqualMessageVT(thatMsg any) bool

func (*OpenCollectionRequest) EqualVT 

func (this *OpenCollectionRequest) EqualVT(that *OpenCollectionRequest) bool

func (*OpenCollectionRequest) GetName 

func (x *OpenCollectionRequest) GetName() string

func (*OpenCollectionRequest) MarshalJSON 

func (x *OpenCollectionRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the OpenCollectionRequest to JSON.

func (*OpenCollectionRequest) MarshalProtoJSON 

func (x *OpenCollectionRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the OpenCollectionRequest message to JSON.

func (*OpenCollectionRequest) MarshalProtoText 

func (x *OpenCollectionRequest) MarshalProtoText() string

func (*OpenCollectionRequest) MarshalToSizedBufferVT 

func (m *OpenCollectionRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*OpenCollectionRequest) MarshalToVT 

func (m *OpenCollectionRequest) MarshalToVT(dAtA []byte) (int, error)

func (*OpenCollectionRequest) MarshalVT 

func (m *OpenCollectionRequest) MarshalVT() (dAtA []byte, err error)

func (*OpenCollectionRequest) ProtoMessage 

func (*OpenCollectionRequest) ProtoMessage()

func (*OpenCollectionRequest) Reset 

func (x *OpenCollectionRequest) Reset()

func (*OpenCollectionRequest) SizeVT 

func (m *OpenCollectionRequest) SizeVT() (n int)

func (*OpenCollectionRequest) String 

func (x *OpenCollectionRequest) String() string

func (*OpenCollectionRequest) UnmarshalJSON 

func (x *OpenCollectionRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the OpenCollectionRequest from JSON.

func (*OpenCollectionRequest) UnmarshalProtoJSON 

func (x *OpenCollectionRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the OpenCollectionRequest message from JSON.

func (*OpenCollectionRequest) UnmarshalVT 

func (m *OpenCollectionRequest) UnmarshalVT(dAtA []byte) error

type OpenCollectionResponse 

type OpenCollectionResponse struct {

	// ResourceId exposes only the Collection service.
	ResourceId uint32 `protobuf:"varint,1,opt,name=resource_id,json=resourceId,proto3" json:"resourceId,omitempty"`
	// Error is set when the collection cannot be opened.
	Error *Failure `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

OpenCollectionResponse grants one connection-owned collection Resource.

func (*OpenCollectionResponse) CloneMessageVT 

func (m *OpenCollectionResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*OpenCollectionResponse) CloneVT 

func (m *OpenCollectionResponse) CloneVT() *OpenCollectionResponse

func (*OpenCollectionResponse) EqualMessageVT 

func (this *OpenCollectionResponse) EqualMessageVT(thatMsg any) bool

func (*OpenCollectionResponse) EqualVT 

func (this *OpenCollectionResponse) EqualVT(that *OpenCollectionResponse) bool

func (*OpenCollectionResponse) GetError 

func (x *OpenCollectionResponse) GetError() *Failure

func (*OpenCollectionResponse) GetResourceId 

func (x *OpenCollectionResponse) GetResourceId() uint32

func (*OpenCollectionResponse) MarshalJSON 

func (x *OpenCollectionResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the OpenCollectionResponse to JSON.

func (*OpenCollectionResponse) MarshalProtoJSON 

func (x *OpenCollectionResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the OpenCollectionResponse message to JSON.

func (*OpenCollectionResponse) MarshalProtoText 

func (x *OpenCollectionResponse) MarshalProtoText() string

func (*OpenCollectionResponse) MarshalToSizedBufferVT 

func (m *OpenCollectionResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*OpenCollectionResponse) MarshalToVT 

func (m *OpenCollectionResponse) MarshalToVT(dAtA []byte) (int, error)

func (*OpenCollectionResponse) MarshalVT 

func (m *OpenCollectionResponse) MarshalVT() (dAtA []byte, err error)

func (*OpenCollectionResponse) ProtoMessage 

func (*OpenCollectionResponse) ProtoMessage()

func (*OpenCollectionResponse) Reset 

func (x *OpenCollectionResponse) Reset()

func (*OpenCollectionResponse) SizeVT 

func (m *OpenCollectionResponse) SizeVT() (n int)

func (*OpenCollectionResponse) String 

func (x *OpenCollectionResponse) String() string

func (*OpenCollectionResponse) UnmarshalJSON 

func (x *OpenCollectionResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the OpenCollectionResponse from JSON.

func (*OpenCollectionResponse) UnmarshalProtoJSON 

func (x *OpenCollectionResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the OpenCollectionResponse message from JSON.

func (*OpenCollectionResponse) UnmarshalVT 

func (m *OpenCollectionResponse) UnmarshalVT(dAtA []byte) error

type PutRequest 

type PutRequest struct {

	// Key identifies the record within the collection.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Data is JSON input validated before storage.
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// RequestId must remain unchanged when retrying this input.
	RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"requestId,omitempty"`
	// contains filtered or unexported fields
}

PutRequest contains a stable retry identity and unvalidated JSON input.

func (*PutRequest) CloneMessageVT 

func (m *PutRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*PutRequest) CloneVT 

func (m *PutRequest) CloneVT() *PutRequest

func (*PutRequest) EqualMessageVT 

func (this *PutRequest) EqualMessageVT(thatMsg any) bool

func (*PutRequest) EqualVT 

func (this *PutRequest) EqualVT(that *PutRequest) bool

func (*PutRequest) GetData 

func (x *PutRequest) GetData() []byte

func (*PutRequest) GetKey 

func (x *PutRequest) GetKey() string

func (*PutRequest) GetRequestId 

func (x *PutRequest) GetRequestId() string

func (*PutRequest) MarshalJSON 

func (x *PutRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the PutRequest to JSON.

func (*PutRequest) MarshalProtoJSON 

func (x *PutRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the PutRequest message to JSON.

func (*PutRequest) MarshalProtoText 

func (x *PutRequest) MarshalProtoText() string

func (*PutRequest) MarshalToSizedBufferVT 

func (m *PutRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PutRequest) MarshalToVT 

func (m *PutRequest) MarshalToVT(dAtA []byte) (int, error)

func (*PutRequest) MarshalVT 

func (m *PutRequest) MarshalVT() (dAtA []byte, err error)

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) Reset 

func (x *PutRequest) Reset()

func (*PutRequest) SizeVT 

func (m *PutRequest) SizeVT() (n int)

func (*PutRequest) String 

func (x *PutRequest) String() string

func (*PutRequest) UnmarshalJSON 

func (x *PutRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the PutRequest from JSON.

func (*PutRequest) UnmarshalProtoJSON 

func (x *PutRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the PutRequest message from JSON.

func (*PutRequest) UnmarshalVT 

func (m *PutRequest) UnmarshalVT(dAtA []byte) error

type QueryRequest 

type QueryRequest struct {

	// Prefix is empty to select the complete collection.
	Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// contains filtered or unexported fields
}

QueryRequest selects a key prefix in the bound collection.

func (*QueryRequest) CloneMessageVT 

func (m *QueryRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*QueryRequest) CloneVT 

func (m *QueryRequest) CloneVT() *QueryRequest

func (*QueryRequest) EqualMessageVT 

func (this *QueryRequest) EqualMessageVT(thatMsg any) bool

func (*QueryRequest) EqualVT 

func (this *QueryRequest) EqualVT(that *QueryRequest) bool

func (*QueryRequest) GetPrefix 

func (x *QueryRequest) GetPrefix() string

func (*QueryRequest) MarshalJSON 

func (x *QueryRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the QueryRequest to JSON.

func (*QueryRequest) MarshalProtoJSON 

func (x *QueryRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the QueryRequest message to JSON.

func (*QueryRequest) MarshalProtoText 

func (x *QueryRequest) MarshalProtoText() string

func (*QueryRequest) MarshalToSizedBufferVT 

func (m *QueryRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*QueryRequest) MarshalToVT 

func (m *QueryRequest) MarshalToVT(dAtA []byte) (int, error)

func (*QueryRequest) MarshalVT 

func (m *QueryRequest) MarshalVT() (dAtA []byte, err error)

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) SizeVT 

func (m *QueryRequest) SizeVT() (n int)

func (*QueryRequest) String 

func (x *QueryRequest) String() string

func (*QueryRequest) UnmarshalJSON 

func (x *QueryRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the QueryRequest from JSON.

func (*QueryRequest) UnmarshalProtoJSON 

func (x *QueryRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the QueryRequest message from JSON.

func (*QueryRequest) UnmarshalVT 

func (m *QueryRequest) UnmarshalVT(dAtA []byte) error

type RecordEntry 

type RecordEntry struct {

	// Key identifies the record within the collection.
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Data contains its canonical JSON value.
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

RecordEntry contains one complete record in a snapshot.

func (*RecordEntry) CloneMessageVT 

func (m *RecordEntry) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*RecordEntry) CloneVT 

func (m *RecordEntry) CloneVT() *RecordEntry

func (*RecordEntry) EqualMessageVT 

func (this *RecordEntry) EqualMessageVT(thatMsg any) bool

func (*RecordEntry) EqualVT 

func (this *RecordEntry) EqualVT(that *RecordEntry) bool

func (*RecordEntry) GetData 

func (x *RecordEntry) GetData() []byte

func (*RecordEntry) GetKey 

func (x *RecordEntry) GetKey() string

func (*RecordEntry) MarshalJSON 

func (x *RecordEntry) MarshalJSON() ([]byte, error)

MarshalJSON marshals the RecordEntry to JSON.

func (*RecordEntry) MarshalProtoJSON 

func (x *RecordEntry) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the RecordEntry message to JSON.

func (*RecordEntry) MarshalProtoText 

func (x *RecordEntry) MarshalProtoText() string

func (*RecordEntry) MarshalToSizedBufferVT 

func (m *RecordEntry) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RecordEntry) MarshalToVT 

func (m *RecordEntry) MarshalToVT(dAtA []byte) (int, error)

func (*RecordEntry) MarshalVT 

func (m *RecordEntry) MarshalVT() (dAtA []byte, err error)

func (*RecordEntry) ProtoMessage 

func (*RecordEntry) ProtoMessage()

func (*RecordEntry) Reset 

func (x *RecordEntry) Reset()

func (*RecordEntry) SizeVT 

func (m *RecordEntry) SizeVT() (n int)

func (*RecordEntry) String 

func (x *RecordEntry) String() string

func (*RecordEntry) UnmarshalJSON 

func (x *RecordEntry) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the RecordEntry from JSON.

func (*RecordEntry) UnmarshalProtoJSON 

func (x *RecordEntry) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the RecordEntry message from JSON.

func (*RecordEntry) UnmarshalVT 

func (m *RecordEntry) UnmarshalVT(dAtA []byte) error

type SRPCApplicationClient 

type SRPCApplicationClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	// OpenCollection returns a connection-owned collection Resource.
	OpenCollection(ctx context.Context, in *OpenCollectionRequest) (*OpenCollectionResponse, error)
	// Mutate invokes a declared handler within one authoritative transaction.
	Mutate(ctx context.Context, in *MutationRequest) (*MutationResponse, error)
}

func NewSRPCApplicationClient 

func NewSRPCApplicationClient(cc srpc.Client) SRPCApplicationClient

func NewSRPCApplicationClientWithServiceID 

func NewSRPCApplicationClientWithServiceID(cc srpc.Client, serviceID string) SRPCApplicationClient

type SRPCApplicationHandler 

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

func (SRPCApplicationHandler) GetMethodIDs 

func (SRPCApplicationHandler) GetMethodIDs() []string

func (*SRPCApplicationHandler) GetServiceID 

func (d *SRPCApplicationHandler) GetServiceID() string

func (*SRPCApplicationHandler) InvokeMethod 

func (d *SRPCApplicationHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCApplicationHandler) InvokeMethod_Mutate 

func (SRPCApplicationHandler) InvokeMethod_Mutate(impl SRPCApplicationServer, strm srpc.Stream) error

func (SRPCApplicationHandler) InvokeMethod_OpenCollection 

func (SRPCApplicationHandler) InvokeMethod_OpenCollection(impl SRPCApplicationServer, strm srpc.Stream) error

type SRPCApplicationServer 

type SRPCApplicationServer interface {
	// OpenCollection returns a connection-owned collection Resource.
	OpenCollection(context.Context, *OpenCollectionRequest) (*OpenCollectionResponse, error)
	// Mutate invokes a declared handler within one authoritative transaction.
	Mutate(context.Context, *MutationRequest) (*MutationResponse, error)
}

type SRPCApplication_MutateStream 

type SRPCApplication_MutateStream interface {
	srpc.Stream
}

type SRPCApplication_OpenCollectionStream 

type SRPCApplication_OpenCollectionStream interface {
	srpc.Stream
}

type SRPCCollectionClient 

type SRPCCollectionClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	// Get distinguishes an absent record from a stored JSON null.
	Get(ctx context.Context, in *GetRequest) (*GetResponse, error)
	// Scan returns a complete bounded snapshot in bytewise key order.
	Scan(ctx context.Context, in *QueryRequest) (*Snapshot, error)
	// Put validates and durably accepts a record with a retained request receipt.
	Put(ctx context.Context, in *PutRequest) (*Acceptance, error)
	// Delete durably accepts removal, including removal of an absent key.
	Delete(ctx context.Context, in *DeleteRequest) (*Acceptance, error)
	// Watch delivers complete latest snapshots, coalescing intermediate changes.
	Watch(ctx context.Context, in *QueryRequest) (SRPCCollection_WatchClient, error)
}

func NewSRPCCollectionClient 

func NewSRPCCollectionClient(cc srpc.Client) SRPCCollectionClient

func NewSRPCCollectionClientWithServiceID 

func NewSRPCCollectionClientWithServiceID(cc srpc.Client, serviceID string) SRPCCollectionClient

type SRPCCollectionHandler 

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

func (SRPCCollectionHandler) GetMethodIDs 

func (SRPCCollectionHandler) GetMethodIDs() []string

func (*SRPCCollectionHandler) GetServiceID 

func (d *SRPCCollectionHandler) GetServiceID() string

func (*SRPCCollectionHandler) InvokeMethod 

func (d *SRPCCollectionHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCCollectionHandler) InvokeMethod_Delete 

func (SRPCCollectionHandler) InvokeMethod_Delete(impl SRPCCollectionServer, strm srpc.Stream) error

func (SRPCCollectionHandler) InvokeMethod_Get 

func (SRPCCollectionHandler) InvokeMethod_Get(impl SRPCCollectionServer, strm srpc.Stream) error

func (SRPCCollectionHandler) InvokeMethod_Put 

func (SRPCCollectionHandler) InvokeMethod_Put(impl SRPCCollectionServer, strm srpc.Stream) error

func (SRPCCollectionHandler) InvokeMethod_Scan 

func (SRPCCollectionHandler) InvokeMethod_Scan(impl SRPCCollectionServer, strm srpc.Stream) error

func (SRPCCollectionHandler) InvokeMethod_Watch 

func (SRPCCollectionHandler) InvokeMethod_Watch(impl SRPCCollectionServer, strm srpc.Stream) error

type SRPCCollectionServer 

type SRPCCollectionServer interface {
	// Get distinguishes an absent record from a stored JSON null.
	Get(context.Context, *GetRequest) (*GetResponse, error)
	// Scan returns a complete bounded snapshot in bytewise key order.
	Scan(context.Context, *QueryRequest) (*Snapshot, error)
	// Put validates and durably accepts a record with a retained request receipt.
	Put(context.Context, *PutRequest) (*Acceptance, error)
	// Delete durably accepts removal, including removal of an absent key.
	Delete(context.Context, *DeleteRequest) (*Acceptance, error)
	// Watch delivers complete latest snapshots, coalescing intermediate changes.
	Watch(*QueryRequest, SRPCCollection_WatchStream) error
}

type SRPCCollection_DeleteStream 

type SRPCCollection_DeleteStream interface {
	srpc.Stream
}

type SRPCCollection_GetStream 

type SRPCCollection_GetStream interface {
	srpc.Stream
}

type SRPCCollection_PutStream 

type SRPCCollection_PutStream interface {
	srpc.Stream
}

type SRPCCollection_ScanStream 

type SRPCCollection_ScanStream interface {
	srpc.Stream
}

type SRPCCollection_WatchClient 

type SRPCCollection_WatchClient interface {
	srpc.Stream
	Recv() (*Snapshot, error)
	RecvTo(*Snapshot) error
}

type SRPCCollection_WatchStream 

type SRPCCollection_WatchStream interface {
	srpc.Stream
	Send(*Snapshot) error
	SendAndClose(*Snapshot) error
}

type SRPCGatewayClient 

type SRPCGatewayClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	// Authenticate verifies wire and application versions and the bearer token.
	Authenticate(ctx context.Context, in *HandshakeRequest) (*HandshakeResponse, error)
}

func NewSRPCGatewayClient 

func NewSRPCGatewayClient(cc srpc.Client) SRPCGatewayClient

func NewSRPCGatewayClientWithServiceID 

func NewSRPCGatewayClientWithServiceID(cc srpc.Client, serviceID string) SRPCGatewayClient

type SRPCGatewayHandler 

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

func (SRPCGatewayHandler) GetMethodIDs 

func (SRPCGatewayHandler) GetMethodIDs() []string

func (*SRPCGatewayHandler) GetServiceID 

func (d *SRPCGatewayHandler) GetServiceID() string

func (*SRPCGatewayHandler) InvokeMethod 

func (d *SRPCGatewayHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCGatewayHandler) InvokeMethod_Authenticate 

func (SRPCGatewayHandler) InvokeMethod_Authenticate(impl SRPCGatewayServer, strm srpc.Stream) error

type SRPCGatewayServer 

type SRPCGatewayServer interface {
	// Authenticate verifies wire and application versions and the bearer token.
	Authenticate(context.Context, *HandshakeRequest) (*HandshakeResponse, error)
}

type SRPCGateway_AuthenticateStream 

type SRPCGateway_AuthenticateStream interface {
	srpc.Stream
}

type Snapshot 

type Snapshot struct {

	// Entries are ordered by their UTF-8 key bytes.
	Entries []*RecordEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// Error terminates this subscription or scan without affecting other handles.
	Error *Failure `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

Snapshot replaces the prior view and never represents a partial result.

func (*Snapshot) CloneMessageVT 

func (m *Snapshot) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*Snapshot) CloneVT 

func (m *Snapshot) CloneVT() *Snapshot

func (*Snapshot) EqualMessageVT 

func (this *Snapshot) EqualMessageVT(thatMsg any) bool

func (*Snapshot) EqualVT 

func (this *Snapshot) EqualVT(that *Snapshot) bool

func (*Snapshot) GetEntries 

func (x *Snapshot) GetEntries() []*RecordEntry

func (*Snapshot) GetError 

func (x *Snapshot) GetError() *Failure

func (*Snapshot) MarshalJSON 

func (x *Snapshot) MarshalJSON() ([]byte, error)

MarshalJSON marshals the Snapshot to JSON.

func (*Snapshot) MarshalProtoJSON 

func (x *Snapshot) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the Snapshot message to JSON.

func (*Snapshot) MarshalProtoText 

func (x *Snapshot) MarshalProtoText() string

func (*Snapshot) MarshalToSizedBufferVT 

func (m *Snapshot) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Snapshot) MarshalToVT 

func (m *Snapshot) MarshalToVT(dAtA []byte) (int, error)

func (*Snapshot) MarshalVT 

func (m *Snapshot) MarshalVT() (dAtA []byte, err error)

func (*Snapshot) ProtoMessage 

func (*Snapshot) ProtoMessage()

func (*Snapshot) Reset 

func (x *Snapshot) Reset()

func (*Snapshot) SizeVT 

func (m *Snapshot) SizeVT() (n int)

func (*Snapshot) String 

func (x *Snapshot) String() string

func (*Snapshot) UnmarshalJSON 

func (x *Snapshot) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the Snapshot from JSON.

func (*Snapshot) UnmarshalProtoJSON 

func (x *Snapshot) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the Snapshot message from JSON.

func (*Snapshot) UnmarshalVT 

func (m *Snapshot) UnmarshalVT(dAtA []byte) error

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.