block_rpc

package
v0.56.0 Latest Latest
Warning

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

 Go to latest Published: Jul 11, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const SRPCBlockStoreServiceID = "block.rpc.BlockStore"

Variables

This section is empty.

Functions

func NewSRPCBlockStoreHandler 

func NewSRPCBlockStoreHandler(impl SRPCBlockStoreServer, serviceID string) srpc.Handler

NewSRPCBlockStoreHandler constructs a new RPC handler. serviceID: if empty, uses default: block.rpc.BlockStore

func SRPCRegisterBlockStore 

func SRPCRegisterBlockStore(mux srpc.Mux, impl SRPCBlockStoreServer) error

SRPCRegisterBlockStore registers the implementation with the mux. Uses the default serviceID: block.rpc.BlockStore

Types

type GetBlockExistsBatchRequest 

type GetBlockExistsBatchRequest struct {

	// Refs are the references to check.
	Refs []*block.BlockRef `protobuf:"bytes,1,rep,name=refs,proto3" json:"refs,omitempty"`
	// contains filtered or unexported fields
}

GetBlockExistsBatchRequest requests to check if blocks exist in the store.

func (*GetBlockExistsBatchRequest) CloneMessageVT 

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

func (*GetBlockExistsBatchRequest) CloneVT 

func (m *GetBlockExistsBatchRequest) CloneVT() *GetBlockExistsBatchRequest

func (*GetBlockExistsBatchRequest) EqualMessageVT 

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

func (*GetBlockExistsBatchRequest) EqualVT 

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

func (*GetBlockExistsBatchRequest) GetRefs 

func (x *GetBlockExistsBatchRequest) GetRefs() []*block.BlockRef

func (*GetBlockExistsBatchRequest) MarshalJSON 

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

MarshalJSON marshals the GetBlockExistsBatchRequest to JSON.

func (*GetBlockExistsBatchRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the GetBlockExistsBatchRequest message to JSON.

func (*GetBlockExistsBatchRequest) MarshalProtoText 

func (x *GetBlockExistsBatchRequest) MarshalProtoText() string

func (*GetBlockExistsBatchRequest) MarshalToSizedBufferVT 

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

func (*GetBlockExistsBatchRequest) MarshalToVT 

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

func (*GetBlockExistsBatchRequest) MarshalVT 

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

func (*GetBlockExistsBatchRequest) ProtoMessage 

func (*GetBlockExistsBatchRequest) ProtoMessage()

func (*GetBlockExistsBatchRequest) Reset 

func (x *GetBlockExistsBatchRequest) Reset()

func (*GetBlockExistsBatchRequest) SizeVT 

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

func (*GetBlockExistsBatchRequest) String 

func (x *GetBlockExistsBatchRequest) String() string

func (*GetBlockExistsBatchRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the GetBlockExistsBatchRequest from JSON.

func (*GetBlockExistsBatchRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the GetBlockExistsBatchRequest message from JSON.

func (*GetBlockExistsBatchRequest) UnmarshalVT 

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

type GetBlockExistsBatchResponse 

type GetBlockExistsBatchResponse struct {

	// Exists indicates existence for each requested ref.
	Exists []bool `protobuf:"varint,1,rep,packed,name=exists,proto3" json:"exists,omitempty"`
	// Error is any error checking blocks in the store.
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

GetBlockExistsBatchResponse is the response to checking if blocks are in the store.

func (*GetBlockExistsBatchResponse) CloneMessageVT 

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

func (*GetBlockExistsBatchResponse) CloneVT 

func (m *GetBlockExistsBatchResponse) CloneVT() *GetBlockExistsBatchResponse

func (*GetBlockExistsBatchResponse) EqualMessageVT 

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

func (*GetBlockExistsBatchResponse) EqualVT 

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

func (*GetBlockExistsBatchResponse) GetError 

func (x *GetBlockExistsBatchResponse) GetError() string

func (*GetBlockExistsBatchResponse) GetExists 

func (x *GetBlockExistsBatchResponse) GetExists() []bool

func (*GetBlockExistsBatchResponse) MarshalJSON 

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

MarshalJSON marshals the GetBlockExistsBatchResponse to JSON.

func (*GetBlockExistsBatchResponse) MarshalProtoJSON 

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

MarshalProtoJSON marshals the GetBlockExistsBatchResponse message to JSON.

func (*GetBlockExistsBatchResponse) MarshalProtoText 

func (x *GetBlockExistsBatchResponse) MarshalProtoText() string

func (*GetBlockExistsBatchResponse) MarshalToSizedBufferVT 

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

func (*GetBlockExistsBatchResponse) MarshalToVT 

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

func (*GetBlockExistsBatchResponse) MarshalVT 

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

func (*GetBlockExistsBatchResponse) ProtoMessage 

func (*GetBlockExistsBatchResponse) ProtoMessage()

func (*GetBlockExistsBatchResponse) Reset 

func (x *GetBlockExistsBatchResponse) Reset()

func (*GetBlockExistsBatchResponse) SizeVT 

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

func (*GetBlockExistsBatchResponse) String 

func (x *GetBlockExistsBatchResponse) String() string

func (*GetBlockExistsBatchResponse) UnmarshalJSON 

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

UnmarshalJSON unmarshals the GetBlockExistsBatchResponse from JSON.

func (*GetBlockExistsBatchResponse) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the GetBlockExistsBatchResponse message from JSON.

func (*GetBlockExistsBatchResponse) UnmarshalVT 

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

type GetBlockExistsRequest 

type GetBlockExistsRequest struct {

	// Ref is the reference to the block to check.
	Ref *block.BlockRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// contains filtered or unexported fields
}

GetBlockExistsRequest requests to check if a block exists in the store.

func (*GetBlockExistsRequest) CloneMessageVT 

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

func (*GetBlockExistsRequest) CloneVT 

func (m *GetBlockExistsRequest) CloneVT() *GetBlockExistsRequest

func (*GetBlockExistsRequest) EqualMessageVT 

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

func (*GetBlockExistsRequest) EqualVT 

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

func (*GetBlockExistsRequest) GetRef 

func (x *GetBlockExistsRequest) GetRef() *block.BlockRef

func (*GetBlockExistsRequest) MarshalJSON 

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

MarshalJSON marshals the GetBlockExistsRequest to JSON.

func (*GetBlockExistsRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the GetBlockExistsRequest message to JSON.

func (*GetBlockExistsRequest) MarshalProtoText 

func (x *GetBlockExistsRequest) MarshalProtoText() string

func (*GetBlockExistsRequest) MarshalToSizedBufferVT 

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

func (*GetBlockExistsRequest) MarshalToVT 

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

func (*GetBlockExistsRequest) MarshalVT 

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

func (*GetBlockExistsRequest) ProtoMessage 

func (*GetBlockExistsRequest) ProtoMessage()

func (*GetBlockExistsRequest) Reset 

func (x *GetBlockExistsRequest) Reset()

func (*GetBlockExistsRequest) SizeVT 

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

func (*GetBlockExistsRequest) String 

func (x *GetBlockExistsRequest) String() string

func (*GetBlockExistsRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the GetBlockExistsRequest from JSON.

func (*GetBlockExistsRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the GetBlockExistsRequest message from JSON.

func (*GetBlockExistsRequest) UnmarshalVT 

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

type GetBlockExistsResponse 

type GetBlockExistsResponse struct {

	// Exists indicates if the block exists or not.
	Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	// Error is any error checking the block in the store.
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

GetBlockExistsResponse is the response to checking if a block is in the store.

func (*GetBlockExistsResponse) CloneMessageVT 

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

func (*GetBlockExistsResponse) CloneVT 

func (m *GetBlockExistsResponse) CloneVT() *GetBlockExistsResponse

func (*GetBlockExistsResponse) EqualMessageVT 

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

func (*GetBlockExistsResponse) EqualVT 

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

func (*GetBlockExistsResponse) GetError 

func (x *GetBlockExistsResponse) GetError() string

func (*GetBlockExistsResponse) GetExists 

func (x *GetBlockExistsResponse) GetExists() bool

func (*GetBlockExistsResponse) MarshalJSON 

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

MarshalJSON marshals the GetBlockExistsResponse to JSON.

func (*GetBlockExistsResponse) MarshalProtoJSON 

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

MarshalProtoJSON marshals the GetBlockExistsResponse message to JSON.

func (*GetBlockExistsResponse) MarshalProtoText 

func (x *GetBlockExistsResponse) MarshalProtoText() string

func (*GetBlockExistsResponse) MarshalToSizedBufferVT 

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

func (*GetBlockExistsResponse) MarshalToVT 

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

func (*GetBlockExistsResponse) MarshalVT 

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

func (*GetBlockExistsResponse) ProtoMessage 

func (*GetBlockExistsResponse) ProtoMessage()

func (*GetBlockExistsResponse) Reset 

func (x *GetBlockExistsResponse) Reset()

func (*GetBlockExistsResponse) SizeVT 

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

func (*GetBlockExistsResponse) String 

func (x *GetBlockExistsResponse) String() string

func (*GetBlockExistsResponse) UnmarshalJSON 

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

UnmarshalJSON unmarshals the GetBlockExistsResponse from JSON.

func (*GetBlockExistsResponse) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the GetBlockExistsResponse message from JSON.

func (*GetBlockExistsResponse) UnmarshalVT 

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

type GetBlockRequest 

type GetBlockRequest struct {

	// Ref is the reference to the block to fetch.
	Ref *block.BlockRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// contains filtered or unexported fields
}

GetBlockRequest requests to get a block from the store.

func (*GetBlockRequest) CloneMessageVT 

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

func (*GetBlockRequest) CloneVT 

func (m *GetBlockRequest) CloneVT() *GetBlockRequest

func (*GetBlockRequest) EqualMessageVT 

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

func (*GetBlockRequest) EqualVT 

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

func (*GetBlockRequest) GetRef 

func (x *GetBlockRequest) GetRef() *block.BlockRef

func (*GetBlockRequest) MarshalJSON 

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

MarshalJSON marshals the GetBlockRequest to JSON.

func (*GetBlockRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the GetBlockRequest message to JSON.

func (*GetBlockRequest) MarshalProtoText 

func (x *GetBlockRequest) MarshalProtoText() string

func (*GetBlockRequest) MarshalToSizedBufferVT 

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

func (*GetBlockRequest) MarshalToVT 

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

func (*GetBlockRequest) MarshalVT 

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

func (*GetBlockRequest) ProtoMessage 

func (*GetBlockRequest) ProtoMessage()

func (*GetBlockRequest) Reset 

func (x *GetBlockRequest) Reset()

func (*GetBlockRequest) SizeVT 

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

func (*GetBlockRequest) String 

func (x *GetBlockRequest) String() string

func (*GetBlockRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the GetBlockRequest from JSON.

func (*GetBlockRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the GetBlockRequest message from JSON.

func (*GetBlockRequest) UnmarshalVT 

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

type GetBlockResponse 

type GetBlockResponse struct {

	// Exists indicates if the block exists or not.
	Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"`
	// Data is the data, if exists.
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// Error is any error getting the block from the store.
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

GetBlockResponse is the response to looking up a block in the store.

func (*GetBlockResponse) CloneMessageVT 

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

func (*GetBlockResponse) CloneVT 

func (m *GetBlockResponse) CloneVT() *GetBlockResponse

func (*GetBlockResponse) EqualMessageVT 

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

func (*GetBlockResponse) EqualVT 

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

func (*GetBlockResponse) GetData 

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

func (*GetBlockResponse) GetError 

func (x *GetBlockResponse) GetError() string

func (*GetBlockResponse) GetExists 

func (x *GetBlockResponse) GetExists() bool

func (*GetBlockResponse) MarshalJSON 

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

MarshalJSON marshals the GetBlockResponse to JSON.

func (*GetBlockResponse) MarshalProtoJSON 

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

MarshalProtoJSON marshals the GetBlockResponse message to JSON.

func (*GetBlockResponse) MarshalProtoText 

func (x *GetBlockResponse) MarshalProtoText() string

func (*GetBlockResponse) MarshalToSizedBufferVT 

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

func (*GetBlockResponse) MarshalToVT 

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

func (*GetBlockResponse) MarshalVT 

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

func (*GetBlockResponse) ProtoMessage 

func (*GetBlockResponse) ProtoMessage()

func (*GetBlockResponse) Reset 

func (x *GetBlockResponse) Reset()

func (*GetBlockResponse) SizeVT 

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

func (*GetBlockResponse) String 

func (x *GetBlockResponse) String() string

func (*GetBlockResponse) UnmarshalJSON 

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

UnmarshalJSON unmarshals the GetBlockResponse from JSON.

func (*GetBlockResponse) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the GetBlockResponse message from JSON.

func (*GetBlockResponse) UnmarshalVT 

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

type GetHashTypeRequest 

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

GetHashTypeRequest requests the preferred hash type for the store.

func (*GetHashTypeRequest) CloneMessageVT 

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

func (*GetHashTypeRequest) CloneVT 

func (m *GetHashTypeRequest) CloneVT() *GetHashTypeRequest

func (*GetHashTypeRequest) EqualMessageVT 

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

func (*GetHashTypeRequest) EqualVT 

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

func (*GetHashTypeRequest) MarshalJSON 

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

MarshalJSON marshals the GetHashTypeRequest to JSON.

func (*GetHashTypeRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the GetHashTypeRequest message to JSON.

func (*GetHashTypeRequest) MarshalProtoText 

func (x *GetHashTypeRequest) MarshalProtoText() string

func (*GetHashTypeRequest) MarshalToSizedBufferVT 

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

func (*GetHashTypeRequest) MarshalToVT 

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

func (*GetHashTypeRequest) MarshalVT 

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

func (*GetHashTypeRequest) ProtoMessage 

func (*GetHashTypeRequest) ProtoMessage()

func (*GetHashTypeRequest) Reset 

func (x *GetHashTypeRequest) Reset()

func (*GetHashTypeRequest) SizeVT 

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

func (*GetHashTypeRequest) String 

func (x *GetHashTypeRequest) String() string

func (*GetHashTypeRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the GetHashTypeRequest from JSON.

func (*GetHashTypeRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the GetHashTypeRequest message from JSON.

func (*GetHashTypeRequest) UnmarshalVT 

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

type GetHashTypeResponse 

type GetHashTypeResponse struct {

	// HashType is the store's preferred hash type.
	HashType hash.HashType `protobuf:"varint,1,opt,name=hash_type,json=hashType,proto3" json:"hashType,omitempty"`
	// contains filtered or unexported fields
}

GetHashTypeResponse is the response to requesting the preferred hash type.

func (*GetHashTypeResponse) CloneMessageVT 

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

func (*GetHashTypeResponse) CloneVT 

func (m *GetHashTypeResponse) CloneVT() *GetHashTypeResponse

func (*GetHashTypeResponse) EqualMessageVT 

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

func (*GetHashTypeResponse) EqualVT 

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

func (*GetHashTypeResponse) GetHashType 

func (x *GetHashTypeResponse) GetHashType() hash.HashType

func (*GetHashTypeResponse) MarshalJSON 

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

MarshalJSON marshals the GetHashTypeResponse to JSON.

func (*GetHashTypeResponse) MarshalProtoJSON 

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

MarshalProtoJSON marshals the GetHashTypeResponse message to JSON.

func (*GetHashTypeResponse) MarshalProtoText 

func (x *GetHashTypeResponse) MarshalProtoText() string

func (*GetHashTypeResponse) MarshalToSizedBufferVT 

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

func (*GetHashTypeResponse) MarshalToVT 

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

func (*GetHashTypeResponse) MarshalVT 

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

func (*GetHashTypeResponse) ProtoMessage 

func (*GetHashTypeResponse) ProtoMessage()

func (*GetHashTypeResponse) Reset 

func (x *GetHashTypeResponse) Reset()

func (*GetHashTypeResponse) SizeVT 

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

func (*GetHashTypeResponse) String 

func (x *GetHashTypeResponse) String() string

func (*GetHashTypeResponse) UnmarshalJSON 

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

UnmarshalJSON unmarshals the GetHashTypeResponse from JSON.

func (*GetHashTypeResponse) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the GetHashTypeResponse message from JSON.

func (*GetHashTypeResponse) UnmarshalVT 

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

type GetSupportedFeaturesRequest 

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

GetSupportedFeaturesRequest requests the native feature bitmask for the store.

func (*GetSupportedFeaturesRequest) CloneMessageVT 

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

func (*GetSupportedFeaturesRequest) CloneVT 

func (m *GetSupportedFeaturesRequest) CloneVT() *GetSupportedFeaturesRequest

func (*GetSupportedFeaturesRequest) EqualMessageVT 

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

func (*GetSupportedFeaturesRequest) EqualVT 

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

func (*GetSupportedFeaturesRequest) MarshalJSON 

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

MarshalJSON marshals the GetSupportedFeaturesRequest to JSON.

func (*GetSupportedFeaturesRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the GetSupportedFeaturesRequest message to JSON.

func (*GetSupportedFeaturesRequest) MarshalProtoText 

func (x *GetSupportedFeaturesRequest) MarshalProtoText() string

func (*GetSupportedFeaturesRequest) MarshalToSizedBufferVT 

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

func (*GetSupportedFeaturesRequest) MarshalToVT 

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

func (*GetSupportedFeaturesRequest) MarshalVT 

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

func (*GetSupportedFeaturesRequest) ProtoMessage 

func (*GetSupportedFeaturesRequest) ProtoMessage()

func (*GetSupportedFeaturesRequest) Reset 

func (x *GetSupportedFeaturesRequest) Reset()

func (*GetSupportedFeaturesRequest) SizeVT 

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

func (*GetSupportedFeaturesRequest) String 

func (x *GetSupportedFeaturesRequest) String() string

func (*GetSupportedFeaturesRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the GetSupportedFeaturesRequest from JSON.

func (*GetSupportedFeaturesRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the GetSupportedFeaturesRequest message from JSON.

func (*GetSupportedFeaturesRequest) UnmarshalVT 

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

type GetSupportedFeaturesResponse 

type GetSupportedFeaturesResponse struct {

	// Features is the native feature bitmask.
	Features block.StoreFeature `protobuf:"varint,1,opt,name=features,proto3" json:"features,omitempty"`
	// contains filtered or unexported fields
}

GetSupportedFeaturesResponse is the response to requesting native features.

func (*GetSupportedFeaturesResponse) CloneMessageVT 

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

func (*GetSupportedFeaturesResponse) CloneVT 

func (m *GetSupportedFeaturesResponse) CloneVT() *GetSupportedFeaturesResponse

func (*GetSupportedFeaturesResponse) EqualMessageVT 

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

func (*GetSupportedFeaturesResponse) EqualVT 

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

func (*GetSupportedFeaturesResponse) GetFeatures 

func (x *GetSupportedFeaturesResponse) GetFeatures() block.StoreFeature

func (*GetSupportedFeaturesResponse) MarshalJSON 

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

MarshalJSON marshals the GetSupportedFeaturesResponse to JSON.

func (*GetSupportedFeaturesResponse) MarshalProtoJSON 

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

MarshalProtoJSON marshals the GetSupportedFeaturesResponse message to JSON.

func (*GetSupportedFeaturesResponse) MarshalProtoText 

func (x *GetSupportedFeaturesResponse) MarshalProtoText() string

func (*GetSupportedFeaturesResponse) MarshalToSizedBufferVT 

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

func (*GetSupportedFeaturesResponse) MarshalToVT 

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

func (*GetSupportedFeaturesResponse) MarshalVT 

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

func (*GetSupportedFeaturesResponse) ProtoMessage 

func (*GetSupportedFeaturesResponse) ProtoMessage()

func (*GetSupportedFeaturesResponse) Reset 

func (x *GetSupportedFeaturesResponse) Reset()

func (*GetSupportedFeaturesResponse) SizeVT 

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

func (*GetSupportedFeaturesResponse) String 

func (x *GetSupportedFeaturesResponse) String() string

func (*GetSupportedFeaturesResponse) UnmarshalJSON 

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

UnmarshalJSON unmarshals the GetSupportedFeaturesResponse from JSON.

func (*GetSupportedFeaturesResponse) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the GetSupportedFeaturesResponse message from JSON.

func (*GetSupportedFeaturesResponse) UnmarshalVT 

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

type PutBlockBatchEntry 

type PutBlockBatchEntry struct {

	// Ref is the expected content-addressed block reference.
	Ref *block.BlockRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// Data is the encoded block payload.
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// Refs are outgoing refs for GC bookkeeping.
	Refs []*block.BlockRef `protobuf:"bytes,3,rep,name=refs,proto3" json:"refs,omitempty"`
	// Tombstone marks the block ref as deleted.
	Tombstone bool `protobuf:"varint,4,opt,name=tombstone,proto3" json:"tombstone,omitempty"`
	// contains filtered or unexported fields
}

PutBlockBatchEntry is one block write in a batch request.

func (*PutBlockBatchEntry) CloneMessageVT 

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

func (*PutBlockBatchEntry) CloneVT 

func (m *PutBlockBatchEntry) CloneVT() *PutBlockBatchEntry

func (*PutBlockBatchEntry) EqualMessageVT 

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

func (*PutBlockBatchEntry) EqualVT 

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

func (*PutBlockBatchEntry) GetData 

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

func (*PutBlockBatchEntry) GetRef 

func (x *PutBlockBatchEntry) GetRef() *block.BlockRef

func (*PutBlockBatchEntry) GetRefs 

func (x *PutBlockBatchEntry) GetRefs() []*block.BlockRef

func (*PutBlockBatchEntry) GetTombstone 

func (x *PutBlockBatchEntry) GetTombstone() bool

func (*PutBlockBatchEntry) MarshalJSON 

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

MarshalJSON marshals the PutBlockBatchEntry to JSON.

func (*PutBlockBatchEntry) MarshalProtoJSON 

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

MarshalProtoJSON marshals the PutBlockBatchEntry message to JSON.

func (*PutBlockBatchEntry) MarshalProtoText 

func (x *PutBlockBatchEntry) MarshalProtoText() string

func (*PutBlockBatchEntry) MarshalToSizedBufferVT 

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

func (*PutBlockBatchEntry) MarshalToVT 

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

func (*PutBlockBatchEntry) MarshalVT 

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

func (*PutBlockBatchEntry) ProtoMessage 

func (*PutBlockBatchEntry) ProtoMessage()

func (*PutBlockBatchEntry) Reset 

func (x *PutBlockBatchEntry) Reset()

func (*PutBlockBatchEntry) SizeVT 

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

func (*PutBlockBatchEntry) String 

func (x *PutBlockBatchEntry) String() string

func (*PutBlockBatchEntry) UnmarshalJSON 

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

UnmarshalJSON unmarshals the PutBlockBatchEntry from JSON.

func (*PutBlockBatchEntry) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the PutBlockBatchEntry message from JSON.

func (*PutBlockBatchEntry) UnmarshalVT 

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

type PutBlockBatchRequest 

type PutBlockBatchRequest struct {

	// Entries are the batch write entries.
	Entries []*PutBlockBatchEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

PutBlockBatchRequest requests to put blocks into the store as a batch.

func (*PutBlockBatchRequest) CloneMessageVT 

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

func (*PutBlockBatchRequest) CloneVT 

func (m *PutBlockBatchRequest) CloneVT() *PutBlockBatchRequest

func (*PutBlockBatchRequest) EqualMessageVT 

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

func (*PutBlockBatchRequest) EqualVT 

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

func (*PutBlockBatchRequest) GetEntries 

func (x *PutBlockBatchRequest) GetEntries() []*PutBlockBatchEntry

func (*PutBlockBatchRequest) MarshalJSON 

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

MarshalJSON marshals the PutBlockBatchRequest to JSON.

func (*PutBlockBatchRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the PutBlockBatchRequest message to JSON.

func (*PutBlockBatchRequest) MarshalProtoText 

func (x *PutBlockBatchRequest) MarshalProtoText() string

func (*PutBlockBatchRequest) MarshalToSizedBufferVT 

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

func (*PutBlockBatchRequest) MarshalToVT 

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

func (*PutBlockBatchRequest) MarshalVT 

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

func (*PutBlockBatchRequest) ProtoMessage 

func (*PutBlockBatchRequest) ProtoMessage()

func (*PutBlockBatchRequest) Reset 

func (x *PutBlockBatchRequest) Reset()

func (*PutBlockBatchRequest) SizeVT 

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

func (*PutBlockBatchRequest) String 

func (x *PutBlockBatchRequest) String() string

func (*PutBlockBatchRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the PutBlockBatchRequest from JSON.

func (*PutBlockBatchRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the PutBlockBatchRequest message from JSON.

func (*PutBlockBatchRequest) UnmarshalVT 

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

type PutBlockBatchResponse 

type PutBlockBatchResponse struct {

	// Error is any error adding blocks to the store.
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

PutBlockBatchResponse is the response to putting blocks as a batch.

func (*PutBlockBatchResponse) CloneMessageVT 

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

func (*PutBlockBatchResponse) CloneVT 

func (m *PutBlockBatchResponse) CloneVT() *PutBlockBatchResponse

func (*PutBlockBatchResponse) EqualMessageVT 

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

func (*PutBlockBatchResponse) EqualVT 

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

func (*PutBlockBatchResponse) GetError 

func (x *PutBlockBatchResponse) GetError() string

func (*PutBlockBatchResponse) MarshalJSON 

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

MarshalJSON marshals the PutBlockBatchResponse to JSON.

func (*PutBlockBatchResponse) MarshalProtoJSON 

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

MarshalProtoJSON marshals the PutBlockBatchResponse message to JSON.

func (*PutBlockBatchResponse) MarshalProtoText 

func (x *PutBlockBatchResponse) MarshalProtoText() string

func (*PutBlockBatchResponse) MarshalToSizedBufferVT 

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

func (*PutBlockBatchResponse) MarshalToVT 

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

func (*PutBlockBatchResponse) MarshalVT 

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

func (*PutBlockBatchResponse) ProtoMessage 

func (*PutBlockBatchResponse) ProtoMessage()

func (*PutBlockBatchResponse) Reset 

func (x *PutBlockBatchResponse) Reset()

func (*PutBlockBatchResponse) SizeVT 

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

func (*PutBlockBatchResponse) String 

func (x *PutBlockBatchResponse) String() string

func (*PutBlockBatchResponse) UnmarshalJSON 

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

UnmarshalJSON unmarshals the PutBlockBatchResponse from JSON.

func (*PutBlockBatchResponse) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the PutBlockBatchResponse message from JSON.

func (*PutBlockBatchResponse) UnmarshalVT 

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

type PutBlockRequest 

type PutBlockRequest struct {

	// Data is the data to put into the store.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// PutOpts are any options when putting the block into the store.
	PutOpts *block.PutOpts `protobuf:"bytes,2,opt,name=put_opts,json=putOpts,proto3" json:"putOpts,omitempty"`
	// contains filtered or unexported fields
}

PutBlockRequest requests to put a block into the store.

func (*PutBlockRequest) CloneMessageVT 

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

func (*PutBlockRequest) CloneVT 

func (m *PutBlockRequest) CloneVT() *PutBlockRequest

func (*PutBlockRequest) EqualMessageVT 

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

func (*PutBlockRequest) EqualVT 

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

func (*PutBlockRequest) GetData 

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

func (*PutBlockRequest) GetPutOpts 

func (x *PutBlockRequest) GetPutOpts() *block.PutOpts

func (*PutBlockRequest) MarshalJSON 

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

MarshalJSON marshals the PutBlockRequest to JSON.

func (*PutBlockRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the PutBlockRequest message to JSON.

func (*PutBlockRequest) MarshalProtoText 

func (x *PutBlockRequest) MarshalProtoText() string

func (*PutBlockRequest) MarshalToSizedBufferVT 

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

func (*PutBlockRequest) MarshalToVT 

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

func (*PutBlockRequest) MarshalVT 

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

func (*PutBlockRequest) ProtoMessage 

func (*PutBlockRequest) ProtoMessage()

func (*PutBlockRequest) Reset 

func (x *PutBlockRequest) Reset()

func (*PutBlockRequest) SizeVT 

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

func (*PutBlockRequest) String 

func (x *PutBlockRequest) String() string

func (*PutBlockRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the PutBlockRequest from JSON.

func (*PutBlockRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the PutBlockRequest message from JSON.

func (*PutBlockRequest) UnmarshalVT 

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

type PutBlockResponse 

type PutBlockResponse struct {

	// Ref is the reference of the added block.
	Ref *block.BlockRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// Existed indicates the block already existed.
	Existed bool `protobuf:"varint,2,opt,name=existed,proto3" json:"existed,omitempty"`
	// Error is any error adding the block to the store.
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

PutBlockResponse is the response to putting a block in the store.

func (*PutBlockResponse) CloneMessageVT 

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

func (*PutBlockResponse) CloneVT 

func (m *PutBlockResponse) CloneVT() *PutBlockResponse

func (*PutBlockResponse) EqualMessageVT 

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

func (*PutBlockResponse) EqualVT 

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

func (*PutBlockResponse) GetError 

func (x *PutBlockResponse) GetError() string

func (*PutBlockResponse) GetExisted 

func (x *PutBlockResponse) GetExisted() bool

func (*PutBlockResponse) GetRef 

func (x *PutBlockResponse) GetRef() *block.BlockRef

func (*PutBlockResponse) MarshalJSON 

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

MarshalJSON marshals the PutBlockResponse to JSON.

func (*PutBlockResponse) MarshalProtoJSON 

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

MarshalProtoJSON marshals the PutBlockResponse message to JSON.

func (*PutBlockResponse) MarshalProtoText 

func (x *PutBlockResponse) MarshalProtoText() string

func (*PutBlockResponse) MarshalToSizedBufferVT 

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

func (*PutBlockResponse) MarshalToVT 

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

func (*PutBlockResponse) MarshalVT 

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

func (*PutBlockResponse) ProtoMessage 

func (*PutBlockResponse) ProtoMessage()

func (*PutBlockResponse) Reset 

func (x *PutBlockResponse) Reset()

func (*PutBlockResponse) SizeVT 

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

func (*PutBlockResponse) String 

func (x *PutBlockResponse) String() string

func (*PutBlockResponse) UnmarshalJSON 

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

UnmarshalJSON unmarshals the PutBlockResponse from JSON.

func (*PutBlockResponse) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the PutBlockResponse message from JSON.

func (*PutBlockResponse) UnmarshalVT 

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

type RmBlockRequest 

type RmBlockRequest struct {

	// Ref is the reference to the block to remove.
	Ref *block.BlockRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// contains filtered or unexported fields
}

RmBlockRequest requests to remove a block from the store.

func (*RmBlockRequest) CloneMessageVT 

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

func (*RmBlockRequest) CloneVT 

func (m *RmBlockRequest) CloneVT() *RmBlockRequest

func (*RmBlockRequest) EqualMessageVT 

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

func (*RmBlockRequest) EqualVT 

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

func (*RmBlockRequest) GetRef 

func (x *RmBlockRequest) GetRef() *block.BlockRef

func (*RmBlockRequest) MarshalJSON 

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

MarshalJSON marshals the RmBlockRequest to JSON.

func (*RmBlockRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the RmBlockRequest message to JSON.

func (*RmBlockRequest) MarshalProtoText 

func (x *RmBlockRequest) MarshalProtoText() string

func (*RmBlockRequest) MarshalToSizedBufferVT 

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

func (*RmBlockRequest) MarshalToVT 

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

func (*RmBlockRequest) MarshalVT 

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

func (*RmBlockRequest) ProtoMessage 

func (*RmBlockRequest) ProtoMessage()

func (*RmBlockRequest) Reset 

func (x *RmBlockRequest) Reset()

func (*RmBlockRequest) SizeVT 

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

func (*RmBlockRequest) String 

func (x *RmBlockRequest) String() string

func (*RmBlockRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the RmBlockRequest from JSON.

func (*RmBlockRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the RmBlockRequest message from JSON.

func (*RmBlockRequest) UnmarshalVT 

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

type RmBlockResponse 

type RmBlockResponse struct {

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

RmBlockResponse is the response to removing a block from the store.

func (*RmBlockResponse) CloneMessageVT 

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

func (*RmBlockResponse) CloneVT 

func (m *RmBlockResponse) CloneVT() *RmBlockResponse

func (*RmBlockResponse) EqualMessageVT 

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

func (*RmBlockResponse) EqualVT 

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

func (*RmBlockResponse) GetError 

func (x *RmBlockResponse) GetError() string

func (*RmBlockResponse) MarshalJSON 

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

MarshalJSON marshals the RmBlockResponse to JSON.

func (*RmBlockResponse) MarshalProtoJSON 

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

MarshalProtoJSON marshals the RmBlockResponse message to JSON.

func (*RmBlockResponse) MarshalProtoText 

func (x *RmBlockResponse) MarshalProtoText() string

func (*RmBlockResponse) MarshalToSizedBufferVT 

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

func (*RmBlockResponse) MarshalToVT 

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

func (*RmBlockResponse) MarshalVT 

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

func (*RmBlockResponse) ProtoMessage 

func (*RmBlockResponse) ProtoMessage()

func (*RmBlockResponse) Reset 

func (x *RmBlockResponse) Reset()

func (*RmBlockResponse) SizeVT 

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

func (*RmBlockResponse) String 

func (x *RmBlockResponse) String() string

func (*RmBlockResponse) UnmarshalJSON 

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

UnmarshalJSON unmarshals the RmBlockResponse from JSON.

func (*RmBlockResponse) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the RmBlockResponse message from JSON.

func (*RmBlockResponse) UnmarshalVT 

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

type SRPCBlockStoreClient 

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

	// GetHashType requests the preferred hash type for the store.
	GetHashType(ctx context.Context, in *GetHashTypeRequest) (*GetHashTypeResponse, error)
	// GetSupportedFeatures requests the native feature bitmask for the store.
	GetSupportedFeatures(ctx context.Context, in *GetSupportedFeaturesRequest) (*GetSupportedFeaturesResponse, error)
	// PutBlock requests to put a block into the store.
	PutBlock(ctx context.Context, in *PutBlockRequest) (*PutBlockResponse, error)
	// PutBlockBatch requests to put blocks into the store as a batch.
	PutBlockBatch(ctx context.Context, in *PutBlockBatchRequest) (*PutBlockBatchResponse, error)
	// GetBlock requests to lookup a block from the store.
	GetBlock(ctx context.Context, in *GetBlockRequest) (*GetBlockResponse, error)
	// GetBlockExists requests to check if a block exists in the store.
	GetBlockExists(ctx context.Context, in *GetBlockExistsRequest) (*GetBlockExistsResponse, error)
	// GetBlockExistsBatch requests to check if blocks exist in the store.
	GetBlockExistsBatch(ctx context.Context, in *GetBlockExistsBatchRequest) (*GetBlockExistsBatchResponse, error)
	// RmBlock requests to remove a block from the store.
	// Does not return an error if the block was not present.
	// In some cases, will return before confirming delete.
	RmBlock(ctx context.Context, in *RmBlockRequest) (*RmBlockResponse, error)
	// StatBlock requests block metadata without reading block data.
	StatBlock(ctx context.Context, in *StatBlockRequest) (*StatBlockResponse, error)
	// Sync is the durability barrier: it drains buffered writes and blocks until
	// every prior write is durable.
	Sync(ctx context.Context, in *SyncRequest) (*SyncResponse, error)
}

func NewSRPCBlockStoreClient 

func NewSRPCBlockStoreClient(cc srpc.Client) SRPCBlockStoreClient

func NewSRPCBlockStoreClientWithServiceID 

func NewSRPCBlockStoreClientWithServiceID(cc srpc.Client, serviceID string) SRPCBlockStoreClient

type SRPCBlockStoreHandler 

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

func (SRPCBlockStoreHandler) GetMethodIDs 

func (SRPCBlockStoreHandler) GetMethodIDs() []string

func (*SRPCBlockStoreHandler) GetServiceID 

func (d *SRPCBlockStoreHandler) GetServiceID() string

func (*SRPCBlockStoreHandler) InvokeMethod 

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

func (SRPCBlockStoreHandler) InvokeMethod_GetBlock 

func (SRPCBlockStoreHandler) InvokeMethod_GetBlock(impl SRPCBlockStoreServer, strm srpc.Stream) error

func (SRPCBlockStoreHandler) InvokeMethod_GetBlockExists 

func (SRPCBlockStoreHandler) InvokeMethod_GetBlockExists(impl SRPCBlockStoreServer, strm srpc.Stream) error

func (SRPCBlockStoreHandler) InvokeMethod_GetBlockExistsBatch 

func (SRPCBlockStoreHandler) InvokeMethod_GetBlockExistsBatch(impl SRPCBlockStoreServer, strm srpc.Stream) error

func (SRPCBlockStoreHandler) InvokeMethod_GetHashType 

func (SRPCBlockStoreHandler) InvokeMethod_GetHashType(impl SRPCBlockStoreServer, strm srpc.Stream) error

func (SRPCBlockStoreHandler) InvokeMethod_GetSupportedFeatures 

func (SRPCBlockStoreHandler) InvokeMethod_GetSupportedFeatures(impl SRPCBlockStoreServer, strm srpc.Stream) error

func (SRPCBlockStoreHandler) InvokeMethod_PutBlock 

func (SRPCBlockStoreHandler) InvokeMethod_PutBlock(impl SRPCBlockStoreServer, strm srpc.Stream) error

func (SRPCBlockStoreHandler) InvokeMethod_PutBlockBatch 

func (SRPCBlockStoreHandler) InvokeMethod_PutBlockBatch(impl SRPCBlockStoreServer, strm srpc.Stream) error

func (SRPCBlockStoreHandler) InvokeMethod_RmBlock 

func (SRPCBlockStoreHandler) InvokeMethod_RmBlock(impl SRPCBlockStoreServer, strm srpc.Stream) error

func (SRPCBlockStoreHandler) InvokeMethod_StatBlock 

func (SRPCBlockStoreHandler) InvokeMethod_StatBlock(impl SRPCBlockStoreServer, strm srpc.Stream) error

func (SRPCBlockStoreHandler) InvokeMethod_Sync added in v0.52.0 

func (SRPCBlockStoreHandler) InvokeMethod_Sync(impl SRPCBlockStoreServer, strm srpc.Stream) error

type SRPCBlockStoreServer 

type SRPCBlockStoreServer interface {
	// GetHashType requests the preferred hash type for the store.
	GetHashType(context.Context, *GetHashTypeRequest) (*GetHashTypeResponse, error)
	// GetSupportedFeatures requests the native feature bitmask for the store.
	GetSupportedFeatures(context.Context, *GetSupportedFeaturesRequest) (*GetSupportedFeaturesResponse, error)
	// PutBlock requests to put a block into the store.
	PutBlock(context.Context, *PutBlockRequest) (*PutBlockResponse, error)
	// PutBlockBatch requests to put blocks into the store as a batch.
	PutBlockBatch(context.Context, *PutBlockBatchRequest) (*PutBlockBatchResponse, error)
	// GetBlock requests to lookup a block from the store.
	GetBlock(context.Context, *GetBlockRequest) (*GetBlockResponse, error)
	// GetBlockExists requests to check if a block exists in the store.
	GetBlockExists(context.Context, *GetBlockExistsRequest) (*GetBlockExistsResponse, error)
	// GetBlockExistsBatch requests to check if blocks exist in the store.
	GetBlockExistsBatch(context.Context, *GetBlockExistsBatchRequest) (*GetBlockExistsBatchResponse, error)
	// RmBlock requests to remove a block from the store.
	// Does not return an error if the block was not present.
	// In some cases, will return before confirming delete.
	RmBlock(context.Context, *RmBlockRequest) (*RmBlockResponse, error)
	// StatBlock requests block metadata without reading block data.
	StatBlock(context.Context, *StatBlockRequest) (*StatBlockResponse, error)
	// Sync is the durability barrier: it drains buffered writes and blocks until
	// every prior write is durable.
	Sync(context.Context, *SyncRequest) (*SyncResponse, error)
}

type SRPCBlockStore_GetBlockExistsBatchStream 

type SRPCBlockStore_GetBlockExistsBatchStream interface {
	srpc.Stream
}

type SRPCBlockStore_GetBlockExistsStream 

type SRPCBlockStore_GetBlockExistsStream interface {
	srpc.Stream
}

type SRPCBlockStore_GetBlockStream 

type SRPCBlockStore_GetBlockStream interface {
	srpc.Stream
}

type SRPCBlockStore_GetHashTypeStream 

type SRPCBlockStore_GetHashTypeStream interface {
	srpc.Stream
}

type SRPCBlockStore_GetSupportedFeaturesStream 

type SRPCBlockStore_GetSupportedFeaturesStream interface {
	srpc.Stream
}

type SRPCBlockStore_PutBlockBatchStream 

type SRPCBlockStore_PutBlockBatchStream interface {
	srpc.Stream
}

type SRPCBlockStore_PutBlockStream 

type SRPCBlockStore_PutBlockStream interface {
	srpc.Stream
}

type SRPCBlockStore_RmBlockStream 

type SRPCBlockStore_RmBlockStream interface {
	srpc.Stream
}

type SRPCBlockStore_StatBlockStream 

type SRPCBlockStore_StatBlockStream interface {
	srpc.Stream
}

type SRPCBlockStore_SyncStream added in v0.52.0 

type SRPCBlockStore_SyncStream interface {
	srpc.Stream
}

type StatBlockRequest 

type StatBlockRequest struct {

	// Ref is the reference to the block to stat.
	Ref *block.BlockRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// contains filtered or unexported fields
}

StatBlockRequest requests metadata about a block.

func (*StatBlockRequest) CloneMessageVT 

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

func (*StatBlockRequest) CloneVT 

func (m *StatBlockRequest) CloneVT() *StatBlockRequest

func (*StatBlockRequest) EqualMessageVT 

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

func (*StatBlockRequest) EqualVT 

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

func (*StatBlockRequest) GetRef 

func (x *StatBlockRequest) GetRef() *block.BlockRef

func (*StatBlockRequest) MarshalJSON 

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

MarshalJSON marshals the StatBlockRequest to JSON.

func (*StatBlockRequest) MarshalProtoJSON 

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

MarshalProtoJSON marshals the StatBlockRequest message to JSON.

func (*StatBlockRequest) MarshalProtoText 

func (x *StatBlockRequest) MarshalProtoText() string

func (*StatBlockRequest) MarshalToSizedBufferVT 

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

func (*StatBlockRequest) MarshalToVT 

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

func (*StatBlockRequest) MarshalVT 

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

func (*StatBlockRequest) ProtoMessage 

func (*StatBlockRequest) ProtoMessage()

func (*StatBlockRequest) Reset 

func (x *StatBlockRequest) Reset()

func (*StatBlockRequest) SizeVT 

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

func (*StatBlockRequest) String 

func (x *StatBlockRequest) String() string

func (*StatBlockRequest) UnmarshalJSON 

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

UnmarshalJSON unmarshals the StatBlockRequest from JSON.

func (*StatBlockRequest) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the StatBlockRequest message from JSON.

func (*StatBlockRequest) UnmarshalVT 

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

type StatBlockResponse 

type StatBlockResponse struct {

	// Ref is the block reference.
	Ref *block.BlockRef `protobuf:"bytes,1,opt,name=ref,proto3" json:"ref,omitempty"`
	// Size is the block data size in bytes, or -1 if unknown.
	Size int64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// Exists indicates if the block exists.
	Exists bool `protobuf:"varint,3,opt,name=exists,proto3" json:"exists,omitempty"`
	// Error is any error statting the block.
	Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

StatBlockResponse is the response to statting a block.

func (*StatBlockResponse) CloneMessageVT 

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

func (*StatBlockResponse) CloneVT 

func (m *StatBlockResponse) CloneVT() *StatBlockResponse

func (*StatBlockResponse) EqualMessageVT 

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

func (*StatBlockResponse) EqualVT 

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

func (*StatBlockResponse) GetError 

func (x *StatBlockResponse) GetError() string

func (*StatBlockResponse) GetExists 

func (x *StatBlockResponse) GetExists() bool

func (*StatBlockResponse) GetRef 

func (x *StatBlockResponse) GetRef() *block.BlockRef

func (*StatBlockResponse) GetSize 

func (x *StatBlockResponse) GetSize() int64

func (*StatBlockResponse) MarshalJSON 

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

MarshalJSON marshals the StatBlockResponse to JSON.

func (*StatBlockResponse) MarshalProtoJSON 

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

MarshalProtoJSON marshals the StatBlockResponse message to JSON.

func (*StatBlockResponse) MarshalProtoText 

func (x *StatBlockResponse) MarshalProtoText() string

func (*StatBlockResponse) MarshalToSizedBufferVT 

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

func (*StatBlockResponse) MarshalToVT 

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

func (*StatBlockResponse) MarshalVT 

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

func (*StatBlockResponse) ProtoMessage 

func (*StatBlockResponse) ProtoMessage()

func (*StatBlockResponse) Reset 

func (x *StatBlockResponse) Reset()

func (*StatBlockResponse) SizeVT 

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

func (*StatBlockResponse) String 

func (x *StatBlockResponse) String() string

func (*StatBlockResponse) UnmarshalJSON 

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

UnmarshalJSON unmarshals the StatBlockResponse from JSON.

func (*StatBlockResponse) UnmarshalProtoJSON 

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

UnmarshalProtoJSON unmarshals the StatBlockResponse message from JSON.

func (*StatBlockResponse) UnmarshalVT 

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

type SyncRequest added in v0.52.0 

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

SyncRequest requests a durability barrier on the store.

func (*SyncRequest) CloneMessageVT added in v0.52.0 

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

func (*SyncRequest) CloneVT added in v0.52.0 

func (m *SyncRequest) CloneVT() *SyncRequest

func (*SyncRequest) EqualMessageVT added in v0.52.0 

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

func (*SyncRequest) EqualVT added in v0.52.0 

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

func (*SyncRequest) MarshalJSON added in v0.52.0 

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

MarshalJSON marshals the SyncRequest to JSON.

func (*SyncRequest) MarshalProtoJSON added in v0.52.0 

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

MarshalProtoJSON marshals the SyncRequest message to JSON.

func (*SyncRequest) MarshalProtoText added in v0.52.0 

func (x *SyncRequest) MarshalProtoText() string

func (*SyncRequest) MarshalToSizedBufferVT added in v0.52.0 

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

func (*SyncRequest) MarshalToVT added in v0.52.0 

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

func (*SyncRequest) MarshalVT added in v0.52.0 

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

func (*SyncRequest) ProtoMessage added in v0.52.0 

func (*SyncRequest) ProtoMessage()

func (*SyncRequest) Reset added in v0.52.0 

func (x *SyncRequest) Reset()

func (*SyncRequest) SizeVT added in v0.52.0 

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

func (*SyncRequest) String added in v0.52.0 

func (x *SyncRequest) String() string

func (*SyncRequest) UnmarshalJSON added in v0.52.0 

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

UnmarshalJSON unmarshals the SyncRequest from JSON.

func (*SyncRequest) UnmarshalProtoJSON added in v0.52.0 

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

UnmarshalProtoJSON unmarshals the SyncRequest message from JSON.

func (*SyncRequest) UnmarshalVT added in v0.52.0 

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

type SyncResponse added in v0.52.0 

type SyncResponse struct {

	// Fenced reports whether a durability fence was applied.
	Fenced bool `protobuf:"varint,1,opt,name=fenced,proto3" json:"fenced,omitempty"`
	// Error is any error fencing the store.
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

SyncResponse is the response to a durability barrier.

func (*SyncResponse) CloneMessageVT added in v0.52.0 

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

func (*SyncResponse) CloneVT added in v0.52.0 

func (m *SyncResponse) CloneVT() *SyncResponse

func (*SyncResponse) EqualMessageVT added in v0.52.0 

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

func (*SyncResponse) EqualVT added in v0.52.0 

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

func (*SyncResponse) GetError added in v0.52.0 

func (x *SyncResponse) GetError() string

func (*SyncResponse) GetFenced added in v0.52.0 

func (x *SyncResponse) GetFenced() bool

func (*SyncResponse) MarshalJSON added in v0.52.0 

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

MarshalJSON marshals the SyncResponse to JSON.

func (*SyncResponse) MarshalProtoJSON added in v0.52.0 

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

MarshalProtoJSON marshals the SyncResponse message to JSON.

func (*SyncResponse) MarshalProtoText added in v0.52.0 

func (x *SyncResponse) MarshalProtoText() string

func (*SyncResponse) MarshalToSizedBufferVT added in v0.52.0 

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

func (*SyncResponse) MarshalToVT added in v0.52.0 

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

func (*SyncResponse) MarshalVT added in v0.52.0 

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

func (*SyncResponse) ProtoMessage added in v0.52.0 

func (*SyncResponse) ProtoMessage()

func (*SyncResponse) Reset added in v0.52.0 

func (x *SyncResponse) Reset()

func (*SyncResponse) SizeVT added in v0.52.0 

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

func (*SyncResponse) String added in v0.52.0 

func (x *SyncResponse) String() string

func (*SyncResponse) UnmarshalJSON added in v0.52.0 

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

UnmarshalJSON unmarshals the SyncResponse from JSON.

func (*SyncResponse) UnmarshalProtoJSON added in v0.52.0 

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

UnmarshalProtoJSON unmarshals the SyncResponse message from JSON.

func (*SyncResponse) UnmarshalVT added in v0.52.0 

func (m *SyncResponse) UnmarshalVT(dAtA []byte) 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.