object_rpc

package
v0.50.0 Latest Latest
Warning

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

 Go to latest Published: Apr 28, 2026 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const SRPCObjectStoreServiceID = "object.rpc.ObjectStore"

Variables

This section is empty.

Functions

func NewSRPCObjectStoreHandler 

func NewSRPCObjectStoreHandler(impl SRPCObjectStoreServer, serviceID string) srpc.Handler

NewSRPCObjectStoreHandler constructs a new RPC handler. serviceID: if empty, uses default: object.rpc.ObjectStore

func SRPCRegisterObjectStore 

func SRPCRegisterObjectStore(mux srpc.Mux, impl SRPCObjectStoreServer) error

SRPCRegisterObjectStore registers the implementation with the mux. Uses the default serviceID: object.rpc.ObjectStore

Types

type DeleteObjectStoreRequest 

type DeleteObjectStoreRequest struct {

	// ObjectStoreId is the object store identifier to remove.
	ObjectStoreId string `protobuf:"bytes,1,opt,name=object_store_id,json=objectStoreId,proto3" json:"objectStoreId,omitempty"`
	// contains filtered or unexported fields
}

DeleteObjectStoreRequest requests to remove an object store and all contents.

func (*DeleteObjectStoreRequest) CloneMessageVT 

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

func (*DeleteObjectStoreRequest) CloneVT 

func (m *DeleteObjectStoreRequest) CloneVT() *DeleteObjectStoreRequest

func (*DeleteObjectStoreRequest) EqualMessageVT 

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

func (*DeleteObjectStoreRequest) EqualVT 

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

func (*DeleteObjectStoreRequest) GetObjectStoreId 

func (x *DeleteObjectStoreRequest) GetObjectStoreId() string

func (*DeleteObjectStoreRequest) MarshalJSON 

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

MarshalJSON marshals the DeleteObjectStoreRequest to JSON.

func (*DeleteObjectStoreRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the DeleteObjectStoreRequest message to JSON.

func (*DeleteObjectStoreRequest) MarshalProtoText 

func (x *DeleteObjectStoreRequest) MarshalProtoText() string

func (*DeleteObjectStoreRequest) MarshalToSizedBufferVT 

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

func (*DeleteObjectStoreRequest) MarshalToVT 

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

func (*DeleteObjectStoreRequest) MarshalVT 

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

func (*DeleteObjectStoreRequest) ProtoMessage 

func (*DeleteObjectStoreRequest) ProtoMessage()

func (*DeleteObjectStoreRequest) Reset 

func (x *DeleteObjectStoreRequest) Reset()

func (*DeleteObjectStoreRequest) SizeVT 

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

func (*DeleteObjectStoreRequest) String 

func (x *DeleteObjectStoreRequest) String() string

func (*DeleteObjectStoreRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the DeleteObjectStoreRequest from JSON.

func (*DeleteObjectStoreRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the DeleteObjectStoreRequest message from JSON.

func (*DeleteObjectStoreRequest) UnmarshalVT 

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

type DeleteObjectStoreResponse 

type DeleteObjectStoreResponse struct {

	// Error is any error removing the object store.
	// Will be empty if the store did not exist.
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

DeleteObjectStoreResponse is the response to removing an object store.

func (*DeleteObjectStoreResponse) CloneMessageVT 

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

func (*DeleteObjectStoreResponse) CloneVT 

func (m *DeleteObjectStoreResponse) CloneVT() *DeleteObjectStoreResponse

func (*DeleteObjectStoreResponse) EqualMessageVT 

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

func (*DeleteObjectStoreResponse) EqualVT 

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

func (*DeleteObjectStoreResponse) GetError 

func (x *DeleteObjectStoreResponse) GetError() string

func (*DeleteObjectStoreResponse) MarshalJSON 

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

MarshalJSON marshals the DeleteObjectStoreResponse to JSON.

func (*DeleteObjectStoreResponse) MarshalProtoJSON 

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

MarshalProtoJSON marshals the DeleteObjectStoreResponse message to JSON.

func (*DeleteObjectStoreResponse) MarshalProtoText 

func (x *DeleteObjectStoreResponse) MarshalProtoText() string

func (*DeleteObjectStoreResponse) MarshalToSizedBufferVT 

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

func (*DeleteObjectStoreResponse) MarshalToVT 

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

func (*DeleteObjectStoreResponse) MarshalVT 

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

func (*DeleteObjectStoreResponse) ProtoMessage 

func (*DeleteObjectStoreResponse) ProtoMessage()

func (*DeleteObjectStoreResponse) Reset 

func (x *DeleteObjectStoreResponse) Reset()

func (*DeleteObjectStoreResponse) SizeVT 

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

func (*DeleteObjectStoreResponse) String 

func (x *DeleteObjectStoreResponse) String() string

func (*DeleteObjectStoreResponse) UnmarshalJSON 

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

UnmarshalJSON unmarshals the DeleteObjectStoreResponse from JSON.

func (*DeleteObjectStoreResponse) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the DeleteObjectStoreResponse message from JSON.

func (*DeleteObjectStoreResponse) UnmarshalVT 

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

type SRPCObjectStoreClient 

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

	// ObjectStoreRpc is a rpc request for an ObjectStore Kvtx service by ID.
	// Corresponds to a call to BuildObjectStoreAPI.
	// If the ObjectStore doesn't exist, it will be created.
	// Exposes service: rpc.kvtx.Kvtx
	// Component ID: object store ID.
	ObjectStoreRpc(ctx context.Context) (SRPCObjectStore_ObjectStoreRpcClient, error)
	// DeleteObjectStore deletes the object store and all contents by ID.
	DeleteObjectStore(ctx context.Context, in *DeleteObjectStoreRequest) (*DeleteObjectStoreResponse, error)
}

func NewSRPCObjectStoreClient 

func NewSRPCObjectStoreClient(cc srpc.Client) SRPCObjectStoreClient

func NewSRPCObjectStoreClientWithServiceID 

func NewSRPCObjectStoreClientWithServiceID(cc srpc.Client, serviceID string) SRPCObjectStoreClient

type SRPCObjectStoreHandler 

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

func (SRPCObjectStoreHandler) GetMethodIDs 

func (SRPCObjectStoreHandler) GetMethodIDs() []string

func (*SRPCObjectStoreHandler) GetServiceID 

func (d *SRPCObjectStoreHandler) GetServiceID() string

func (*SRPCObjectStoreHandler) InvokeMethod 

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

func (SRPCObjectStoreHandler) InvokeMethod_DeleteObjectStore 

func (SRPCObjectStoreHandler) InvokeMethod_DeleteObjectStore(impl SRPCObjectStoreServer, strm srpc.Stream) error

func (SRPCObjectStoreHandler) InvokeMethod_ObjectStoreRpc 

func (SRPCObjectStoreHandler) InvokeMethod_ObjectStoreRpc(impl SRPCObjectStoreServer, strm srpc.Stream) error

type SRPCObjectStoreServer 

type SRPCObjectStoreServer interface {
	// ObjectStoreRpc is a rpc request for an ObjectStore Kvtx service by ID.
	// Corresponds to a call to BuildObjectStoreAPI.
	// If the ObjectStore doesn't exist, it will be created.
	// Exposes service: rpc.kvtx.Kvtx
	// Component ID: object store ID.
	ObjectStoreRpc(SRPCObjectStore_ObjectStoreRpcStream) error
	// DeleteObjectStore deletes the object store and all contents by ID.
	DeleteObjectStore(context.Context, *DeleteObjectStoreRequest) (*DeleteObjectStoreResponse, error)
}

type SRPCObjectStore_DeleteObjectStoreStream 

type SRPCObjectStore_DeleteObjectStoreStream interface {
	srpc.Stream
}

type SRPCObjectStore_ObjectStoreRpcClient 

type SRPCObjectStore_ObjectStoreRpcClient interface {
	srpc.Stream
	Send(*rpcstream.RpcStreamPacket) error
	Recv() (*rpcstream.RpcStreamPacket, error)
	RecvTo(*rpcstream.RpcStreamPacket) error
}

type SRPCObjectStore_ObjectStoreRpcStream 

type SRPCObjectStore_ObjectStoreRpcStream interface {
	srpc.Stream
	Send(*rpcstream.RpcStreamPacket) error
	SendAndClose(*rpcstream.RpcStreamPacket) error
	Recv() (*rpcstream.RpcStreamPacket, error)
	RecvTo(*rpcstream.RpcStreamPacket) error
}

Source Files

View all Source files

Directories

Path Synopsis

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.