spacesyncproto

package
v0.10.1 Latest Latest
Warning

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

 Go to latest Published: Sep 16, 2025 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrUnexpected              = errGroup.Register(errors.New("unexpected error"), uint64(ErrCodes_Unexpected))
	ErrSpaceMissing            = errGroup.Register(errors.New("space is missing"), uint64(ErrCodes_SpaceMissing))
	ErrSpaceExists             = errGroup.Register(errors.New("space exists"), uint64(ErrCodes_SpaceExists))
	ErrSpaceNotInCache         = errGroup.Register(errors.New("space not in cache"), uint64(ErrCodes_SpaceNotInCache))
	ErrSpaceIsDeleted          = errGroup.Register(errors.New("space is deleted"), uint64(ErrCodes_SpaceIsDeleted))
	ErrPeerIsNotResponsible    = errGroup.Register(errors.New("peer is not responsible for space"), uint64(ErrCodes_PeerIsNotResponsible))
	ErrReceiptInvalid          = errGroup.Register(errors.New("space receipt is not valid"), uint64(ErrCodes_ReceiptIsInvalid))
	ErrDuplicateRequest        = errGroup.Register(errors.New("duplicate request"), uint64(ErrCodes_DuplicateRequest))
	ErrTooManyRequestsFromPeer = errGroup.Register(errors.New("too many requests from peer"), uint64(ErrCodes_TooManyRequestsFromPeer))
)
View Source 
var (
	ErrCodes_name = map[int32]string{
		0:   "Unexpected",
		1:   "SpaceMissing",
		2:   "SpaceExists",
		3:   "SpaceNotInCache",
		4:   "SpaceIsDeleted",
		5:   "PeerIsNotResponsible",
		6:   "ReceiptIsInvalid",
		7:   "InvalidPayload",
		8:   "DuplicateRequest",
		9:   "TooManyRequestsFromPeer",
		100: "ErrorOffset",
	}
	ErrCodes_value = map[string]int32{
		"Unexpected":              0,
		"SpaceMissing":            1,
		"SpaceExists":             2,
		"SpaceNotInCache":         3,
		"SpaceIsDeleted":          4,
		"PeerIsNotResponsible":    5,
		"ReceiptIsInvalid":        6,
		"InvalidPayload":          7,
		"DuplicateRequest":        8,
		"TooManyRequestsFromPeer": 9,
		"ErrorOffset":             100,
	}
)

Enum value maps for ErrCodes.

View Source 
var (
	SpaceSubscriptionAction_name = map[int32]string{
		0: "Subscribe",
		1: "Unsubscribe",
	}
	SpaceSubscriptionAction_value = map[string]int32{
		"Subscribe":   0,
		"Unsubscribe": 1,
	}
)

Enum value maps for SpaceSubscriptionAction.

View Source 
var (
	DiffType_name = map[int32]string{
		0: "Initial",
		1: "V1",
		2: "V2",
		3: "V3",
	}
	DiffType_value = map[string]int32{
		"Initial": 0,
		"V1":      1,
		"V2":      2,
		"V3":      3,
	}
)

Enum value maps for DiffType.

View Source 
var (
	ObjectType_name = map[int32]string{
		0: "Tree",
		1: "Acl",
		2: "KeyValue",
	}
	ObjectType_value = map[string]int32{
		"Tree":     0,
		"Acl":      1,
		"KeyValue": 2,
	}
)

Enum value maps for ObjectType.

View Source 
var File_commonspace_spacesyncproto_protos_spacesync_proto protoreflect.FileDescriptor

Functions

func DRPCRegisterSpaceSync 

func DRPCRegisterSpaceSync(mux drpc.Mux, impl DRPCSpaceSyncServer) error

Types

type AclAddRecordRequest added in v0.2.15 

type AclAddRecordRequest struct {
	SpaceId string `protobuf:"bytes,1,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

AclAddRecordRequest contains marshaled consensusproto.RawRecord

func (*AclAddRecordRequest) Descriptor deprecated added in v0.2.15 

func (*AclAddRecordRequest) Descriptor() ([]byte, []int)

Deprecated: Use AclAddRecordRequest.ProtoReflect.Descriptor instead.

func (*AclAddRecordRequest) GetPayload added in v0.2.15 

func (x *AclAddRecordRequest) GetPayload() []byte

func (*AclAddRecordRequest) GetSpaceId added in v0.2.15 

func (x *AclAddRecordRequest) GetSpaceId() string

func (*AclAddRecordRequest) MarshalToSizedBufferVT added in v0.9.0 

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

func (*AclAddRecordRequest) MarshalToVT added in v0.9.0 

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

func (*AclAddRecordRequest) MarshalVT added in v0.9.0 

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

func (*AclAddRecordRequest) ProtoMessage added in v0.2.15 

func (*AclAddRecordRequest) ProtoMessage()

func (*AclAddRecordRequest) ProtoReflect added in v0.9.0 

func (x *AclAddRecordRequest) ProtoReflect() protoreflect.Message

func (*AclAddRecordRequest) Reset added in v0.2.15 

func (x *AclAddRecordRequest) Reset()

func (*AclAddRecordRequest) SizeVT added in v0.9.0 

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

func (*AclAddRecordRequest) String added in v0.2.15 

func (x *AclAddRecordRequest) String() string

func (*AclAddRecordRequest) UnmarshalVT added in v0.9.0 

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

type AclAddRecordResponse added in v0.2.15 

type AclAddRecordResponse struct {
	RecordId string `protobuf:"bytes,1,opt,name=recordId,proto3" json:"recordId,omitempty"`
	Payload  []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

AclAddRecordResponse contains created record id and marshaled consensusproto.RawRecord

func (*AclAddRecordResponse) Descriptor deprecated added in v0.2.15 

func (*AclAddRecordResponse) Descriptor() ([]byte, []int)

Deprecated: Use AclAddRecordResponse.ProtoReflect.Descriptor instead.

func (*AclAddRecordResponse) GetPayload added in v0.2.15 

func (x *AclAddRecordResponse) GetPayload() []byte

func (*AclAddRecordResponse) GetRecordId added in v0.2.15 

func (x *AclAddRecordResponse) GetRecordId() string

func (*AclAddRecordResponse) MarshalToSizedBufferVT added in v0.9.0 

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

func (*AclAddRecordResponse) MarshalToVT added in v0.9.0 

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

func (*AclAddRecordResponse) MarshalVT added in v0.9.0 

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

func (*AclAddRecordResponse) ProtoMessage added in v0.2.15 

func (*AclAddRecordResponse) ProtoMessage()

func (*AclAddRecordResponse) ProtoReflect added in v0.9.0 

func (x *AclAddRecordResponse) ProtoReflect() protoreflect.Message

func (*AclAddRecordResponse) Reset added in v0.2.15 

func (x *AclAddRecordResponse) Reset()

func (*AclAddRecordResponse) SizeVT added in v0.9.0 

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

func (*AclAddRecordResponse) String added in v0.2.15 

func (x *AclAddRecordResponse) String() string

func (*AclAddRecordResponse) UnmarshalVT added in v0.9.0 

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

type AclGetRecordsRequest added in v0.2.15 

type AclGetRecordsRequest struct {
	SpaceId string `protobuf:"bytes,1,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
	AclHead string `protobuf:"bytes,2,opt,name=aclHead,proto3" json:"aclHead,omitempty"`
	// contains filtered or unexported fields
}

AclGetRecordsRequest can optionally contain the last known aclHead, the server will return only new records or an empty list if there are no new records. If aclHead is not provided the whole list will be returned.

func (*AclGetRecordsRequest) Descriptor deprecated added in v0.2.15 

func (*AclGetRecordsRequest) Descriptor() ([]byte, []int)

Deprecated: Use AclGetRecordsRequest.ProtoReflect.Descriptor instead.

func (*AclGetRecordsRequest) GetAclHead added in v0.2.15 

func (x *AclGetRecordsRequest) GetAclHead() string

func (*AclGetRecordsRequest) GetSpaceId added in v0.2.15 

func (x *AclGetRecordsRequest) GetSpaceId() string

func (*AclGetRecordsRequest) MarshalToSizedBufferVT added in v0.9.0 

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

func (*AclGetRecordsRequest) MarshalToVT added in v0.9.0 

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

func (*AclGetRecordsRequest) MarshalVT added in v0.9.0 

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

func (*AclGetRecordsRequest) ProtoMessage added in v0.2.15 

func (*AclGetRecordsRequest) ProtoMessage()

func (*AclGetRecordsRequest) ProtoReflect added in v0.9.0 

func (x *AclGetRecordsRequest) ProtoReflect() protoreflect.Message

func (*AclGetRecordsRequest) Reset added in v0.2.15 

func (x *AclGetRecordsRequest) Reset()

func (*AclGetRecordsRequest) SizeVT added in v0.9.0 

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

func (*AclGetRecordsRequest) String added in v0.2.15 

func (x *AclGetRecordsRequest) String() string

func (*AclGetRecordsRequest) UnmarshalVT added in v0.9.0 

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

type AclGetRecordsResponse added in v0.2.15 

type AclGetRecordsResponse struct {
	Records [][]byte `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

AclGetRecordsResponse contains list of marshaled consensusproto.RawRecordWithId

func (*AclGetRecordsResponse) Descriptor deprecated added in v0.2.15 

func (*AclGetRecordsResponse) Descriptor() ([]byte, []int)

Deprecated: Use AclGetRecordsResponse.ProtoReflect.Descriptor instead.

func (*AclGetRecordsResponse) GetRecords added in v0.2.15 

func (x *AclGetRecordsResponse) GetRecords() [][]byte

func (*AclGetRecordsResponse) MarshalToSizedBufferVT added in v0.9.0 

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

func (*AclGetRecordsResponse) MarshalToVT added in v0.9.0 

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

func (*AclGetRecordsResponse) MarshalVT added in v0.9.0 

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

func (*AclGetRecordsResponse) ProtoMessage added in v0.2.15 

func (*AclGetRecordsResponse) ProtoMessage()

func (*AclGetRecordsResponse) ProtoReflect added in v0.9.0 

func (x *AclGetRecordsResponse) ProtoReflect() protoreflect.Message

func (*AclGetRecordsResponse) Reset added in v0.2.15 

func (x *AclGetRecordsResponse) Reset()

func (*AclGetRecordsResponse) SizeVT added in v0.9.0 

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

func (*AclGetRecordsResponse) String added in v0.2.15 

func (x *AclGetRecordsResponse) String() string

func (*AclGetRecordsResponse) UnmarshalVT added in v0.9.0 

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

type AclRecord added in v0.8.6 

type AclRecord struct {
	AclPayload []byte `protobuf:"bytes,1,opt,name=aclPayload,proto3" json:"aclPayload,omitempty"`
	Id         string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*AclRecord) Descriptor deprecated added in v0.8.6 

func (*AclRecord) Descriptor() ([]byte, []int)

Deprecated: Use AclRecord.ProtoReflect.Descriptor instead.

func (*AclRecord) GetAclPayload added in v0.8.6 

func (x *AclRecord) GetAclPayload() []byte

func (*AclRecord) GetId added in v0.8.6 

func (x *AclRecord) GetId() string

func (*AclRecord) MarshalToSizedBufferVT added in v0.9.0 

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

func (*AclRecord) MarshalToVT added in v0.9.0 

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

func (*AclRecord) MarshalVT added in v0.9.0 

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

func (*AclRecord) ProtoMessage added in v0.8.6 

func (*AclRecord) ProtoMessage()

func (*AclRecord) ProtoReflect added in v0.9.0 

func (x *AclRecord) ProtoReflect() protoreflect.Message

func (*AclRecord) Reset added in v0.8.6 

func (x *AclRecord) Reset()

func (*AclRecord) SizeVT added in v0.9.0 

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

func (*AclRecord) String added in v0.8.6 

func (x *AclRecord) String() string

func (*AclRecord) UnmarshalVT added in v0.9.0 

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

type ClientFactory 

type ClientFactory interface {
	Client(cc drpc.Conn) DRPCSpaceSyncClient
}

type ClientFactoryFunc 

type ClientFactoryFunc func(cc drpc.Conn) DRPCSpaceSyncClient

func (ClientFactoryFunc) Client 

func (c ClientFactoryFunc) Client(cc drpc.Conn) DRPCSpaceSyncClient

type DRPCSpaceSyncClient 

type DRPCSpaceSyncClient interface {
	DRPCConn() drpc.Conn

	HeadSync(ctx context.Context, in *HeadSyncRequest) (*HeadSyncResponse, error)
	StoreDiff(ctx context.Context, in *StoreDiffRequest) (*StoreDiffResponse, error)
	StoreElements(ctx context.Context) (DRPCSpaceSync_StoreElementsClient, error)
	SpacePush(ctx context.Context, in *SpacePushRequest) (*SpacePushResponse, error)
	SpacePull(ctx context.Context, in *SpacePullRequest) (*SpacePullResponse, error)
	ObjectSyncStream(ctx context.Context) (DRPCSpaceSync_ObjectSyncStreamClient, error)
	ObjectSync(ctx context.Context, in *ObjectSyncMessage) (*ObjectSyncMessage, error)
	ObjectSyncRequestStream(ctx context.Context, in *ObjectSyncMessage) (DRPCSpaceSync_ObjectSyncRequestStreamClient, error)
	AclAddRecord(ctx context.Context, in *AclAddRecordRequest) (*AclAddRecordResponse, error)
	AclGetRecords(ctx context.Context, in *AclGetRecordsRequest) (*AclGetRecordsResponse, error)
}

func NewDRPCSpaceSyncClient 

func NewDRPCSpaceSyncClient(cc drpc.Conn) DRPCSpaceSyncClient

type DRPCSpaceSyncDescription 

type DRPCSpaceSyncDescription struct{}

func (DRPCSpaceSyncDescription) Method 

func (DRPCSpaceSyncDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool)

func (DRPCSpaceSyncDescription) NumMethods 

func (DRPCSpaceSyncDescription) NumMethods() int

type DRPCSpaceSyncServer 

type DRPCSpaceSyncServer interface {
	HeadSync(context.Context, *HeadSyncRequest) (*HeadSyncResponse, error)
	StoreDiff(context.Context, *StoreDiffRequest) (*StoreDiffResponse, error)
	StoreElements(DRPCSpaceSync_StoreElementsStream) error
	SpacePush(context.Context, *SpacePushRequest) (*SpacePushResponse, error)
	SpacePull(context.Context, *SpacePullRequest) (*SpacePullResponse, error)
	ObjectSyncStream(DRPCSpaceSync_ObjectSyncStreamStream) error
	ObjectSync(context.Context, *ObjectSyncMessage) (*ObjectSyncMessage, error)
	ObjectSyncRequestStream(*ObjectSyncMessage, DRPCSpaceSync_ObjectSyncRequestStreamStream) error
	AclAddRecord(context.Context, *AclAddRecordRequest) (*AclAddRecordResponse, error)
	AclGetRecords(context.Context, *AclGetRecordsRequest) (*AclGetRecordsResponse, error)
}

type DRPCSpaceSyncUnimplementedServer 

type DRPCSpaceSyncUnimplementedServer struct{}

func (*DRPCSpaceSyncUnimplementedServer) AclAddRecord added in v0.2.15 

func (s *DRPCSpaceSyncUnimplementedServer) AclAddRecord(context.Context, *AclAddRecordRequest) (*AclAddRecordResponse, error)

func (*DRPCSpaceSyncUnimplementedServer) AclGetRecords added in v0.2.15 

func (s *DRPCSpaceSyncUnimplementedServer) AclGetRecords(context.Context, *AclGetRecordsRequest) (*AclGetRecordsResponse, error)

func (*DRPCSpaceSyncUnimplementedServer) HeadSync 

func (s *DRPCSpaceSyncUnimplementedServer) HeadSync(context.Context, *HeadSyncRequest) (*HeadSyncResponse, error)

func (*DRPCSpaceSyncUnimplementedServer) ObjectSync added in v0.2.0 

func (s *DRPCSpaceSyncUnimplementedServer) ObjectSync(context.Context, *ObjectSyncMessage) (*ObjectSyncMessage, error)

func (*DRPCSpaceSyncUnimplementedServer) ObjectSyncRequestStream added in v0.5.0 

func (s *DRPCSpaceSyncUnimplementedServer) ObjectSyncRequestStream(*ObjectSyncMessage, DRPCSpaceSync_ObjectSyncRequestStreamStream) error

func (*DRPCSpaceSyncUnimplementedServer) ObjectSyncStream 

func (s *DRPCSpaceSyncUnimplementedServer) ObjectSyncStream(DRPCSpaceSync_ObjectSyncStreamStream) error

func (*DRPCSpaceSyncUnimplementedServer) SpacePull 

func (s *DRPCSpaceSyncUnimplementedServer) SpacePull(context.Context, *SpacePullRequest) (*SpacePullResponse, error)

func (*DRPCSpaceSyncUnimplementedServer) SpacePush 

func (s *DRPCSpaceSyncUnimplementedServer) SpacePush(context.Context, *SpacePushRequest) (*SpacePushResponse, error)

func (*DRPCSpaceSyncUnimplementedServer) StoreDiff added in v0.7.0 

func (s *DRPCSpaceSyncUnimplementedServer) StoreDiff(context.Context, *StoreDiffRequest) (*StoreDiffResponse, error)

func (*DRPCSpaceSyncUnimplementedServer) StoreElements added in v0.7.0 

func (s *DRPCSpaceSyncUnimplementedServer) StoreElements(DRPCSpaceSync_StoreElementsStream) error

type DRPCSpaceSync_AclAddRecordStream added in v0.2.15 

type DRPCSpaceSync_AclAddRecordStream interface {
	drpc.Stream
	SendAndClose(*AclAddRecordResponse) error
}

type DRPCSpaceSync_AclGetRecordsStream added in v0.2.15 

type DRPCSpaceSync_AclGetRecordsStream interface {
	drpc.Stream
	SendAndClose(*AclGetRecordsResponse) error
}

type DRPCSpaceSync_HeadSyncStream 

type DRPCSpaceSync_HeadSyncStream interface {
	drpc.Stream
	SendAndClose(*HeadSyncResponse) error
}

type DRPCSpaceSync_ObjectSyncRequestStreamClient added in v0.5.0 

type DRPCSpaceSync_ObjectSyncRequestStreamClient interface {
	drpc.Stream
	Recv() (*ObjectSyncMessage, error)
}

type DRPCSpaceSync_ObjectSyncRequestStreamStream added in v0.5.0 

type DRPCSpaceSync_ObjectSyncRequestStreamStream interface {
	drpc.Stream
	Send(*ObjectSyncMessage) error
}

type DRPCSpaceSync_ObjectSyncStream added in v0.2.0 

type DRPCSpaceSync_ObjectSyncStream interface {
	drpc.Stream
	SendAndClose(*ObjectSyncMessage) error
}

type DRPCSpaceSync_ObjectSyncStreamClient 

type DRPCSpaceSync_ObjectSyncStreamClient interface {
	drpc.Stream
	Send(*ObjectSyncMessage) error
	Recv() (*ObjectSyncMessage, error)
}

type DRPCSpaceSync_ObjectSyncStreamStream 

type DRPCSpaceSync_ObjectSyncStreamStream interface {
	drpc.Stream
	Send(*ObjectSyncMessage) error
	Recv() (*ObjectSyncMessage, error)
}

type DRPCSpaceSync_SpacePullStream 

type DRPCSpaceSync_SpacePullStream interface {
	drpc.Stream
	SendAndClose(*SpacePullResponse) error
}

type DRPCSpaceSync_SpacePushStream 

type DRPCSpaceSync_SpacePushStream interface {
	drpc.Stream
	SendAndClose(*SpacePushResponse) error
}

type DRPCSpaceSync_StoreDiffStream added in v0.7.0 

type DRPCSpaceSync_StoreDiffStream interface {
	drpc.Stream
	SendAndClose(*StoreDiffResponse) error
}

type DRPCSpaceSync_StoreElementsClient added in v0.7.0 

type DRPCSpaceSync_StoreElementsClient interface {
	drpc.Stream
	Send(*StoreKeyValue) error
	Recv() (*StoreKeyValue, error)
}

type DRPCSpaceSync_StoreElementsStream added in v0.7.0 

type DRPCSpaceSync_StoreElementsStream interface {
	drpc.Stream
	Send(*StoreKeyValue) error
	Recv() (*StoreKeyValue, error)
}

type DiffType added in v0.3.11 

type DiffType int32

DiffType is a type of diff 

const (
	DiffType_Initial DiffType = 0
	DiffType_V1      DiffType = 1
	DiffType_V2      DiffType = 2
	DiffType_V3      DiffType = 3
)

func (DiffType) Descriptor added in v0.9.0 

func (DiffType) Descriptor() protoreflect.EnumDescriptor

func (DiffType) Enum added in v0.9.0 

func (x DiffType) Enum() *DiffType

func (DiffType) EnumDescriptor deprecated added in v0.3.11 

func (DiffType) EnumDescriptor() ([]byte, []int)

Deprecated: Use DiffType.Descriptor instead.

func (DiffType) Number added in v0.9.0 

func (x DiffType) Number() protoreflect.EnumNumber

func (DiffType) String added in v0.3.11 

func (x DiffType) String() string

func (DiffType) Type added in v0.9.0 

func (DiffType) Type() protoreflect.EnumType

type ErrCodes 

type ErrCodes int32
const (
	ErrCodes_Unexpected              ErrCodes = 0
	ErrCodes_SpaceMissing            ErrCodes = 1
	ErrCodes_SpaceExists             ErrCodes = 2
	ErrCodes_SpaceNotInCache         ErrCodes = 3
	ErrCodes_SpaceIsDeleted          ErrCodes = 4
	ErrCodes_PeerIsNotResponsible    ErrCodes = 5
	ErrCodes_ReceiptIsInvalid        ErrCodes = 6
	ErrCodes_InvalidPayload          ErrCodes = 7
	ErrCodes_DuplicateRequest        ErrCodes = 8
	ErrCodes_TooManyRequestsFromPeer ErrCodes = 9
	ErrCodes_ErrorOffset             ErrCodes = 100
)

func (ErrCodes) Descriptor added in v0.9.0 

func (ErrCodes) Descriptor() protoreflect.EnumDescriptor

func (ErrCodes) Enum added in v0.9.0 

func (x ErrCodes) Enum() *ErrCodes

func (ErrCodes) EnumDescriptor deprecated 

func (ErrCodes) EnumDescriptor() ([]byte, []int)

Deprecated: Use ErrCodes.Descriptor instead.

func (ErrCodes) Number added in v0.9.0 

func (x ErrCodes) Number() protoreflect.EnumNumber

func (ErrCodes) String 

func (x ErrCodes) String() string

func (ErrCodes) Type added in v0.9.0 

func (ErrCodes) Type() protoreflect.EnumType

type HeadSyncRange 

type HeadSyncRange struct {
	From     uint64 `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"`
	To       uint64 `protobuf:"varint,2,opt,name=to,proto3" json:"to,omitempty"`
	Limit    uint32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	Elements bool   `protobuf:"varint,4,opt,name=elements,proto3" json:"elements,omitempty"`
	// contains filtered or unexported fields
}

HeadSyncRange presenting a request for one range

func (*HeadSyncRange) Descriptor deprecated 

func (*HeadSyncRange) Descriptor() ([]byte, []int)

Deprecated: Use HeadSyncRange.ProtoReflect.Descriptor instead.

func (*HeadSyncRange) GetElements added in v0.3.11 

func (x *HeadSyncRange) GetElements() bool

func (*HeadSyncRange) GetFrom 

func (x *HeadSyncRange) GetFrom() uint64

func (*HeadSyncRange) GetLimit 

func (x *HeadSyncRange) GetLimit() uint32

func (*HeadSyncRange) GetTo 

func (x *HeadSyncRange) GetTo() uint64

func (*HeadSyncRange) MarshalToSizedBufferVT added in v0.9.0 

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

func (*HeadSyncRange) MarshalToVT added in v0.9.0 

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

func (*HeadSyncRange) MarshalVT added in v0.9.0 

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

func (*HeadSyncRange) ProtoMessage 

func (*HeadSyncRange) ProtoMessage()

func (*HeadSyncRange) ProtoReflect added in v0.9.0 

func (x *HeadSyncRange) ProtoReflect() protoreflect.Message

func (*HeadSyncRange) Reset 

func (x *HeadSyncRange) Reset()

func (*HeadSyncRange) SizeVT added in v0.9.0 

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

func (*HeadSyncRange) String 

func (x *HeadSyncRange) String() string

func (*HeadSyncRange) UnmarshalVT added in v0.9.0 

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

type HeadSyncRequest 

type HeadSyncRequest struct {
	SpaceId  string           `protobuf:"bytes,1,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
	Ranges   []*HeadSyncRange `protobuf:"bytes,2,rep,name=ranges,proto3" json:"ranges,omitempty"`
	DiffType DiffType         `protobuf:"varint,3,opt,name=diffType,proto3,enum=spacesync.DiffType" json:"diffType,omitempty"`
	// contains filtered or unexported fields
}

HeadSyncRequest is a request for HeadSync

func (*HeadSyncRequest) Descriptor deprecated 

func (*HeadSyncRequest) Descriptor() ([]byte, []int)

Deprecated: Use HeadSyncRequest.ProtoReflect.Descriptor instead.

func (*HeadSyncRequest) GetDiffType added in v0.3.11 

func (x *HeadSyncRequest) GetDiffType() DiffType

func (*HeadSyncRequest) GetRanges 

func (x *HeadSyncRequest) GetRanges() []*HeadSyncRange

func (*HeadSyncRequest) GetSpaceId 

func (x *HeadSyncRequest) GetSpaceId() string

func (*HeadSyncRequest) MarshalToSizedBufferVT added in v0.9.0 

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

func (*HeadSyncRequest) MarshalToVT added in v0.9.0 

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

func (*HeadSyncRequest) MarshalVT added in v0.9.0 

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

func (*HeadSyncRequest) ProtoMessage 

func (*HeadSyncRequest) ProtoMessage()

func (*HeadSyncRequest) ProtoReflect added in v0.9.0 

func (x *HeadSyncRequest) ProtoReflect() protoreflect.Message

func (*HeadSyncRequest) Reset 

func (x *HeadSyncRequest) Reset()

func (*HeadSyncRequest) SizeVT added in v0.9.0 

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

func (*HeadSyncRequest) String 

func (x *HeadSyncRequest) String() string

func (*HeadSyncRequest) UnmarshalVT added in v0.9.0 

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

type HeadSyncResponse 

type HeadSyncResponse struct {
	Results  []*HeadSyncResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	DiffType DiffType          `protobuf:"varint,2,opt,name=diffType,proto3,enum=spacesync.DiffType" json:"diffType,omitempty"`
	// contains filtered or unexported fields
}

HeadSyncResponse is a response for HeadSync

func (*HeadSyncResponse) Descriptor deprecated 

func (*HeadSyncResponse) Descriptor() ([]byte, []int)

Deprecated: Use HeadSyncResponse.ProtoReflect.Descriptor instead.

func (*HeadSyncResponse) GetDiffType added in v0.3.11 

func (x *HeadSyncResponse) GetDiffType() DiffType

func (*HeadSyncResponse) GetResults 

func (x *HeadSyncResponse) GetResults() []*HeadSyncResult

func (*HeadSyncResponse) MarshalToSizedBufferVT added in v0.9.0 

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

func (*HeadSyncResponse) MarshalToVT added in v0.9.0 

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

func (*HeadSyncResponse) MarshalVT added in v0.9.0 

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

func (*HeadSyncResponse) ProtoMessage 

func (*HeadSyncResponse) ProtoMessage()

func (*HeadSyncResponse) ProtoReflect added in v0.9.0 

func (x *HeadSyncResponse) ProtoReflect() protoreflect.Message

func (*HeadSyncResponse) Reset 

func (x *HeadSyncResponse) Reset()

func (*HeadSyncResponse) SizeVT added in v0.9.0 

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

func (*HeadSyncResponse) String 

func (x *HeadSyncResponse) String() string

func (*HeadSyncResponse) UnmarshalVT added in v0.9.0 

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

type HeadSyncResult 

type HeadSyncResult struct {
	Hash     []byte                   `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	Elements []*HeadSyncResultElement `protobuf:"bytes,2,rep,name=elements,proto3" json:"elements,omitempty"`
	Count    uint32                   `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

HeadSyncResult presenting a response for one range

func (*HeadSyncResult) Descriptor deprecated 

func (*HeadSyncResult) Descriptor() ([]byte, []int)

Deprecated: Use HeadSyncResult.ProtoReflect.Descriptor instead.

func (*HeadSyncResult) GetCount 

func (x *HeadSyncResult) GetCount() uint32

func (*HeadSyncResult) GetElements 

func (x *HeadSyncResult) GetElements() []*HeadSyncResultElement

func (*HeadSyncResult) GetHash 

func (x *HeadSyncResult) GetHash() []byte

func (*HeadSyncResult) MarshalToSizedBufferVT added in v0.9.0 

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

func (*HeadSyncResult) MarshalToVT added in v0.9.0 

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

func (*HeadSyncResult) MarshalVT added in v0.9.0 

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

func (*HeadSyncResult) ProtoMessage 

func (*HeadSyncResult) ProtoMessage()

func (*HeadSyncResult) ProtoReflect added in v0.9.0 

func (x *HeadSyncResult) ProtoReflect() protoreflect.Message

func (*HeadSyncResult) Reset 

func (x *HeadSyncResult) Reset()

func (*HeadSyncResult) SizeVT added in v0.9.0 

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

func (*HeadSyncResult) String 

func (x *HeadSyncResult) String() string

func (*HeadSyncResult) UnmarshalVT added in v0.9.0 

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

type HeadSyncResultElement 

type HeadSyncResultElement struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Head string `protobuf:"bytes,2,opt,name=head,proto3" json:"head,omitempty"`
	// contains filtered or unexported fields
}

HeadSyncResultElement presenting state of one object

func (*HeadSyncResultElement) Descriptor deprecated 

func (*HeadSyncResultElement) Descriptor() ([]byte, []int)

Deprecated: Use HeadSyncResultElement.ProtoReflect.Descriptor instead.

func (*HeadSyncResultElement) GetHead 

func (x *HeadSyncResultElement) GetHead() string

func (*HeadSyncResultElement) GetId 

func (x *HeadSyncResultElement) GetId() string

func (*HeadSyncResultElement) MarshalToSizedBufferVT added in v0.9.0 

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

func (*HeadSyncResultElement) MarshalToVT added in v0.9.0 

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

func (*HeadSyncResultElement) MarshalVT added in v0.9.0 

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

func (*HeadSyncResultElement) ProtoMessage 

func (*HeadSyncResultElement) ProtoMessage()

func (*HeadSyncResultElement) ProtoReflect added in v0.9.0 

func (x *HeadSyncResultElement) ProtoReflect() protoreflect.Message

func (*HeadSyncResultElement) Reset 

func (x *HeadSyncResultElement) Reset()

func (*HeadSyncResultElement) SizeVT added in v0.9.0 

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

func (*HeadSyncResultElement) String 

func (x *HeadSyncResultElement) String() string

func (*HeadSyncResultElement) UnmarshalVT added in v0.9.0 

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

type ObjectDelete 

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

ObjectDelete is a message containing an object id which should be deleted

func (*ObjectDelete) Descriptor deprecated 

func (*ObjectDelete) Descriptor() ([]byte, []int)

Deprecated: Use ObjectDelete.ProtoReflect.Descriptor instead.

func (*ObjectDelete) GetId 

func (x *ObjectDelete) GetId() string

func (*ObjectDelete) MarshalToSizedBufferVT added in v0.9.0 

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

func (*ObjectDelete) MarshalToVT added in v0.9.0 

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

func (*ObjectDelete) MarshalVT added in v0.9.0 

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

func (*ObjectDelete) ProtoMessage 

func (*ObjectDelete) ProtoMessage()

func (*ObjectDelete) ProtoReflect added in v0.9.0 

func (x *ObjectDelete) ProtoReflect() protoreflect.Message

func (*ObjectDelete) Reset 

func (x *ObjectDelete) Reset()

func (*ObjectDelete) SizeVT added in v0.9.0 

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

func (*ObjectDelete) String 

func (x *ObjectDelete) String() string

func (*ObjectDelete) UnmarshalVT added in v0.9.0 

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

type ObjectSyncMessage 

type ObjectSyncMessage struct {
	SpaceId    string     `protobuf:"bytes,1,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
	RequestId  string     `protobuf:"bytes,2,opt,name=requestId,proto3" json:"requestId,omitempty"`
	ReplyId    string     `protobuf:"bytes,3,opt,name=replyId,proto3" json:"replyId,omitempty"`
	Payload    []byte     `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	ObjectId   string     `protobuf:"bytes,5,opt,name=objectId,proto3" json:"objectId,omitempty"`
	ObjectType ObjectType `protobuf:"varint,6,opt,name=objectType,proto3,enum=spacesync.ObjectType" json:"objectType,omitempty"`
	// contains filtered or unexported fields
}

ObjectSyncMessage is a message sent on object sync

func MarshallSyncMessage added in v0.2.15 

func MarshallSyncMessage(message proto.Message, spaceId, objectId string) (objMsg *ObjectSyncMessage, err error)

func (*ObjectSyncMessage) Descriptor deprecated 

func (*ObjectSyncMessage) Descriptor() ([]byte, []int)

Deprecated: Use ObjectSyncMessage.ProtoReflect.Descriptor instead.

func (*ObjectSyncMessage) GetObjectId 

func (x *ObjectSyncMessage) GetObjectId() string

func (*ObjectSyncMessage) GetObjectType added in v0.6.12 

func (x *ObjectSyncMessage) GetObjectType() ObjectType

func (*ObjectSyncMessage) GetPayload 

func (x *ObjectSyncMessage) GetPayload() []byte

func (*ObjectSyncMessage) GetReplyId 

func (x *ObjectSyncMessage) GetReplyId() string

func (*ObjectSyncMessage) GetRequestId 

func (x *ObjectSyncMessage) GetRequestId() string

func (*ObjectSyncMessage) GetSpaceId 

func (x *ObjectSyncMessage) GetSpaceId() string

func (*ObjectSyncMessage) MarshalToSizedBufferVT added in v0.9.0 

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

func (*ObjectSyncMessage) MarshalToVT added in v0.9.0 

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

func (*ObjectSyncMessage) MarshalVT added in v0.9.0 

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

func (*ObjectSyncMessage) ProtoMessage 

func (*ObjectSyncMessage) ProtoMessage()

func (*ObjectSyncMessage) ProtoReflect added in v0.9.0 

func (x *ObjectSyncMessage) ProtoReflect() protoreflect.Message

func (*ObjectSyncMessage) Reset 

func (x *ObjectSyncMessage) Reset()

func (*ObjectSyncMessage) SizeVT added in v0.9.0 

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

func (*ObjectSyncMessage) String 

func (x *ObjectSyncMessage) String() string

func (*ObjectSyncMessage) UnmarshalVT added in v0.9.0 

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

type ObjectSyncStream 

type ObjectSyncStream = DRPCSpaceSync_ObjectSyncStreamStream

type ObjectType added in v0.6.12 

type ObjectType int32

ObjectType is a type of object 

const (
	ObjectType_Tree     ObjectType = 0
	ObjectType_Acl      ObjectType = 1
	ObjectType_KeyValue ObjectType = 2
)

func (ObjectType) Descriptor added in v0.9.0 

func (ObjectType) Descriptor() protoreflect.EnumDescriptor

func (ObjectType) Enum added in v0.9.0 

func (x ObjectType) Enum() *ObjectType

func (ObjectType) EnumDescriptor deprecated added in v0.6.12 

func (ObjectType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ObjectType.Descriptor instead.

func (ObjectType) Number added in v0.9.0 

func (x ObjectType) Number() protoreflect.EnumNumber

func (ObjectType) String added in v0.6.12 

func (x ObjectType) String() string

func (ObjectType) Type added in v0.9.0 

func (ObjectType) Type() protoreflect.EnumType

type RawSpaceHeader 

type RawSpaceHeader struct {
	SpaceHeader []byte `protobuf:"bytes,1,opt,name=spaceHeader,proto3" json:"spaceHeader,omitempty"`
	Signature   []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

RawSpaceHeader is raw header for SpaceHeader

func (*RawSpaceHeader) Descriptor deprecated 

func (*RawSpaceHeader) Descriptor() ([]byte, []int)

Deprecated: Use RawSpaceHeader.ProtoReflect.Descriptor instead.

func (*RawSpaceHeader) GetSignature 

func (x *RawSpaceHeader) GetSignature() []byte

func (*RawSpaceHeader) GetSpaceHeader 

func (x *RawSpaceHeader) GetSpaceHeader() []byte

func (*RawSpaceHeader) MarshalToSizedBufferVT added in v0.9.0 

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

func (*RawSpaceHeader) MarshalToVT added in v0.9.0 

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

func (*RawSpaceHeader) MarshalVT added in v0.9.0 

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

func (*RawSpaceHeader) ProtoMessage 

func (*RawSpaceHeader) ProtoMessage()

func (*RawSpaceHeader) ProtoReflect added in v0.9.0 

func (x *RawSpaceHeader) ProtoReflect() protoreflect.Message

func (*RawSpaceHeader) Reset 

func (x *RawSpaceHeader) Reset()

func (*RawSpaceHeader) SizeVT added in v0.9.0 

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

func (*RawSpaceHeader) String 

func (x *RawSpaceHeader) String() string

func (*RawSpaceHeader) UnmarshalVT added in v0.9.0 

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

type RawSpaceHeaderWithId 

type RawSpaceHeaderWithId struct {
	RawHeader []byte `protobuf:"bytes,1,opt,name=rawHeader,proto3" json:"rawHeader,omitempty"`
	Id        string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

RawSpaceHeaderWithId is a marshalled RawSpaceHeader with its content id

func (*RawSpaceHeaderWithId) Descriptor deprecated 

func (*RawSpaceHeaderWithId) Descriptor() ([]byte, []int)

Deprecated: Use RawSpaceHeaderWithId.ProtoReflect.Descriptor instead.

func (*RawSpaceHeaderWithId) GetId 

func (x *RawSpaceHeaderWithId) GetId() string

func (*RawSpaceHeaderWithId) GetRawHeader 

func (x *RawSpaceHeaderWithId) GetRawHeader() []byte

func (*RawSpaceHeaderWithId) MarshalToSizedBufferVT added in v0.9.0 

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

func (*RawSpaceHeaderWithId) MarshalToVT added in v0.9.0 

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

func (*RawSpaceHeaderWithId) MarshalVT added in v0.9.0 

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

func (*RawSpaceHeaderWithId) ProtoMessage 

func (*RawSpaceHeaderWithId) ProtoMessage()

func (*RawSpaceHeaderWithId) ProtoReflect added in v0.9.0 

func (x *RawSpaceHeaderWithId) ProtoReflect() protoreflect.Message

func (*RawSpaceHeaderWithId) Reset 

func (x *RawSpaceHeaderWithId) Reset()

func (*RawSpaceHeaderWithId) SizeVT added in v0.9.0 

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

func (*RawSpaceHeaderWithId) String 

func (x *RawSpaceHeaderWithId) String() string

func (*RawSpaceHeaderWithId) UnmarshalVT added in v0.9.0 

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

type SettingsData 

type SettingsData struct {
	Content  []*SpaceSettingsContent `protobuf:"bytes,1,rep,name=content,proto3" json:"content,omitempty"`
	Snapshot *SpaceSettingsSnapshot  `protobuf:"bytes,2,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	// contains filtered or unexported fields
}

SettingsData contains ObjectTree change payload

func (*SettingsData) Descriptor deprecated 

func (*SettingsData) Descriptor() ([]byte, []int)

Deprecated: Use SettingsData.ProtoReflect.Descriptor instead.

func (*SettingsData) GetContent 

func (x *SettingsData) GetContent() []*SpaceSettingsContent

func (*SettingsData) GetSnapshot 

func (x *SettingsData) GetSnapshot() *SpaceSettingsSnapshot

func (*SettingsData) MarshalToSizedBufferVT added in v0.9.0 

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

func (*SettingsData) MarshalToVT added in v0.9.0 

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

func (*SettingsData) MarshalVT added in v0.9.0 

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

func (*SettingsData) ProtoMessage 

func (*SettingsData) ProtoMessage()

func (*SettingsData) ProtoReflect added in v0.9.0 

func (x *SettingsData) ProtoReflect() protoreflect.Message

func (*SettingsData) Reset 

func (x *SettingsData) Reset()

func (*SettingsData) SizeVT added in v0.9.0 

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

func (*SettingsData) String 

func (x *SettingsData) String() string

func (*SettingsData) UnmarshalVT added in v0.9.0 

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

type SpaceDelete 

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

SpaceDelete is a message containing deleter peer id

func (*SpaceDelete) Descriptor deprecated 

func (*SpaceDelete) Descriptor() ([]byte, []int)

Deprecated: Use SpaceDelete.ProtoReflect.Descriptor instead.

func (*SpaceDelete) GetDeleterPeerId 

func (x *SpaceDelete) GetDeleterPeerId() string

func (*SpaceDelete) MarshalToSizedBufferVT added in v0.9.0 

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

func (*SpaceDelete) MarshalToVT added in v0.9.0 

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

func (*SpaceDelete) MarshalVT added in v0.9.0 

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

func (*SpaceDelete) ProtoMessage 

func (*SpaceDelete) ProtoMessage()

func (*SpaceDelete) ProtoReflect added in v0.9.0 

func (x *SpaceDelete) ProtoReflect() protoreflect.Message

func (*SpaceDelete) Reset 

func (x *SpaceDelete) Reset()

func (*SpaceDelete) SizeVT added in v0.9.0 

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

func (*SpaceDelete) String 

func (x *SpaceDelete) String() string

func (*SpaceDelete) UnmarshalVT added in v0.9.0 

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

type SpaceHeader 

type SpaceHeader struct {
	Identity           []byte `protobuf:"bytes,1,opt,name=identity,proto3" json:"identity,omitempty"`
	Timestamp          int64  `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	SpaceType          string `protobuf:"bytes,3,opt,name=spaceType,proto3" json:"spaceType,omitempty"`
	ReplicationKey     uint64 `protobuf:"varint,4,opt,name=replicationKey,proto3" json:"replicationKey,omitempty"`
	Seed               []byte `protobuf:"bytes,5,opt,name=seed,proto3" json:"seed,omitempty"`
	SpaceHeaderPayload []byte `protobuf:"bytes,6,opt,name=spaceHeaderPayload,proto3" json:"spaceHeaderPayload,omitempty"`
	// contains filtered or unexported fields
}

SpaceHeader is a header for a space

func (*SpaceHeader) Descriptor deprecated 

func (*SpaceHeader) Descriptor() ([]byte, []int)

Deprecated: Use SpaceHeader.ProtoReflect.Descriptor instead.

func (*SpaceHeader) GetIdentity 

func (x *SpaceHeader) GetIdentity() []byte

func (*SpaceHeader) GetReplicationKey 

func (x *SpaceHeader) GetReplicationKey() uint64

func (*SpaceHeader) GetSeed 

func (x *SpaceHeader) GetSeed() []byte

func (*SpaceHeader) GetSpaceHeaderPayload 

func (x *SpaceHeader) GetSpaceHeaderPayload() []byte

func (*SpaceHeader) GetSpaceType 

func (x *SpaceHeader) GetSpaceType() string

func (*SpaceHeader) GetTimestamp 

func (x *SpaceHeader) GetTimestamp() int64

func (*SpaceHeader) MarshalToSizedBufferVT added in v0.9.0 

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

func (*SpaceHeader) MarshalToVT added in v0.9.0 

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

func (*SpaceHeader) MarshalVT added in v0.9.0 

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

func (*SpaceHeader) ProtoMessage 

func (*SpaceHeader) ProtoMessage()

func (*SpaceHeader) ProtoReflect added in v0.9.0 

func (x *SpaceHeader) ProtoReflect() protoreflect.Message

func (*SpaceHeader) Reset 

func (x *SpaceHeader) Reset()

func (*SpaceHeader) SizeVT added in v0.9.0 

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

func (*SpaceHeader) String 

func (x *SpaceHeader) String() string

func (*SpaceHeader) UnmarshalVT added in v0.9.0 

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

type SpacePayload 

type SpacePayload struct {
	SpaceHeader            *RawSpaceHeaderWithId `protobuf:"bytes,1,opt,name=spaceHeader,proto3" json:"spaceHeader,omitempty"`
	AclPayload             []byte                `protobuf:"bytes,2,opt,name=aclPayload,proto3" json:"aclPayload,omitempty"`
	AclPayloadId           string                `protobuf:"bytes,3,opt,name=aclPayloadId,proto3" json:"aclPayloadId,omitempty"`
	SpaceSettingsPayload   []byte                `protobuf:"bytes,4,opt,name=spaceSettingsPayload,proto3" json:"spaceSettingsPayload,omitempty"`
	SpaceSettingsPayloadId string                `protobuf:"bytes,5,opt,name=spaceSettingsPayloadId,proto3" json:"spaceSettingsPayloadId,omitempty"`
	// contains filtered or unexported fields
}

SpacePayload is a payload for pushing a space

func (*SpacePayload) Descriptor deprecated 

func (*SpacePayload) Descriptor() ([]byte, []int)

Deprecated: Use SpacePayload.ProtoReflect.Descriptor instead.

func (*SpacePayload) GetAclPayload 

func (x *SpacePayload) GetAclPayload() []byte

func (*SpacePayload) GetAclPayloadId 

func (x *SpacePayload) GetAclPayloadId() string

func (*SpacePayload) GetSpaceHeader 

func (x *SpacePayload) GetSpaceHeader() *RawSpaceHeaderWithId

func (*SpacePayload) GetSpaceSettingsPayload 

func (x *SpacePayload) GetSpaceSettingsPayload() []byte

func (*SpacePayload) GetSpaceSettingsPayloadId 

func (x *SpacePayload) GetSpaceSettingsPayloadId() string

func (*SpacePayload) MarshalToSizedBufferVT added in v0.9.0 

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

func (*SpacePayload) MarshalToVT added in v0.9.0 

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

func (*SpacePayload) MarshalVT added in v0.9.0 

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

func (*SpacePayload) ProtoMessage 

func (*SpacePayload) ProtoMessage()

func (*SpacePayload) ProtoReflect added in v0.9.0 

func (x *SpacePayload) ProtoReflect() protoreflect.Message

func (*SpacePayload) Reset 

func (x *SpacePayload) Reset()

func (*SpacePayload) SizeVT added in v0.9.0 

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

func (*SpacePayload) String 

func (x *SpacePayload) String() string

func (*SpacePayload) UnmarshalVT added in v0.9.0 

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

type SpacePullRequest 

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

SpacePullRequest is a request to request a space on a node that doesn't have it

func (*SpacePullRequest) Descriptor deprecated 

func (*SpacePullRequest) Descriptor() ([]byte, []int)

Deprecated: Use SpacePullRequest.ProtoReflect.Descriptor instead.

func (*SpacePullRequest) GetId 

func (x *SpacePullRequest) GetId() string

func (*SpacePullRequest) MarshalToSizedBufferVT added in v0.9.0 

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

func (*SpacePullRequest) MarshalToVT added in v0.9.0 

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

func (*SpacePullRequest) MarshalVT added in v0.9.0 

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

func (*SpacePullRequest) ProtoMessage 

func (*SpacePullRequest) ProtoMessage()

func (*SpacePullRequest) ProtoReflect added in v0.9.0 

func (x *SpacePullRequest) ProtoReflect() protoreflect.Message

func (*SpacePullRequest) Reset 

func (x *SpacePullRequest) Reset()

func (*SpacePullRequest) SizeVT added in v0.9.0 

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

func (*SpacePullRequest) String 

func (x *SpacePullRequest) String() string

func (*SpacePullRequest) UnmarshalVT added in v0.9.0 

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

type SpacePullResponse 

type SpacePullResponse struct {
	Payload    *SpacePayload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	AclRecords []*AclRecord  `protobuf:"bytes,2,rep,name=aclRecords,proto3" json:"aclRecords,omitempty"`
	// contains filtered or unexported fields
}

SpacePullResponse is a response with header and acl root

func (*SpacePullResponse) Descriptor deprecated 

func (*SpacePullResponse) Descriptor() ([]byte, []int)

Deprecated: Use SpacePullResponse.ProtoReflect.Descriptor instead.

func (*SpacePullResponse) GetAclRecords added in v0.8.6 

func (x *SpacePullResponse) GetAclRecords() []*AclRecord

func (*SpacePullResponse) GetPayload 

func (x *SpacePullResponse) GetPayload() *SpacePayload

func (*SpacePullResponse) MarshalToSizedBufferVT added in v0.9.0 

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

func (*SpacePullResponse) MarshalToVT added in v0.9.0 

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

func (*SpacePullResponse) MarshalVT added in v0.9.0 

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

func (*SpacePullResponse) ProtoMessage 

func (*SpacePullResponse) ProtoMessage()

func (*SpacePullResponse) ProtoReflect added in v0.9.0 

func (x *SpacePullResponse) ProtoReflect() protoreflect.Message

func (*SpacePullResponse) Reset 

func (x *SpacePullResponse) Reset()

func (*SpacePullResponse) SizeVT added in v0.9.0 

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

func (*SpacePullResponse) String 

func (x *SpacePullResponse) String() string

func (*SpacePullResponse) UnmarshalVT added in v0.9.0 

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

type SpacePushRequest 

type SpacePushRequest struct {
	Payload    *SpacePayload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Credential []byte        `protobuf:"bytes,2,opt,name=Credential,proto3" json:"Credential,omitempty"`
	// contains filtered or unexported fields
}

SpacePushRequest is a request to add space on a node containing only one acl record

func (*SpacePushRequest) Descriptor deprecated 

func (*SpacePushRequest) Descriptor() ([]byte, []int)

Deprecated: Use SpacePushRequest.ProtoReflect.Descriptor instead.

func (*SpacePushRequest) GetCredential 

func (x *SpacePushRequest) GetCredential() []byte

func (*SpacePushRequest) GetPayload 

func (x *SpacePushRequest) GetPayload() *SpacePayload

func (*SpacePushRequest) MarshalToSizedBufferVT added in v0.9.0 

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

func (*SpacePushRequest) MarshalToVT added in v0.9.0 

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

func (*SpacePushRequest) MarshalVT added in v0.9.0 

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

func (*SpacePushRequest) ProtoMessage 

func (*SpacePushRequest) ProtoMessage()

func (*SpacePushRequest) ProtoReflect added in v0.9.0 

func (x *SpacePushRequest) ProtoReflect() protoreflect.Message

func (*SpacePushRequest) Reset 

func (x *SpacePushRequest) Reset()

func (*SpacePushRequest) SizeVT added in v0.9.0 

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

func (*SpacePushRequest) String 

func (x *SpacePushRequest) String() string

func (*SpacePushRequest) UnmarshalVT added in v0.9.0 

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

type SpacePushResponse 

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

SpacePushResponse is an empty response

func (*SpacePushResponse) Descriptor deprecated 

func (*SpacePushResponse) Descriptor() ([]byte, []int)

Deprecated: Use SpacePushResponse.ProtoReflect.Descriptor instead.

func (*SpacePushResponse) MarshalToSizedBufferVT added in v0.9.0 

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

func (*SpacePushResponse) MarshalToVT added in v0.9.0 

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

func (*SpacePushResponse) MarshalVT added in v0.9.0 

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

func (*SpacePushResponse) ProtoMessage 

func (*SpacePushResponse) ProtoMessage()

func (*SpacePushResponse) ProtoReflect added in v0.9.0 

func (x *SpacePushResponse) ProtoReflect() protoreflect.Message

func (*SpacePushResponse) Reset 

func (x *SpacePushResponse) Reset()

func (*SpacePushResponse) SizeVT added in v0.9.0 

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

func (*SpacePushResponse) String 

func (x *SpacePushResponse) String() string

func (*SpacePushResponse) UnmarshalVT added in v0.9.0 

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

type SpaceSettingsContent 

type SpaceSettingsContent struct {

	// Types that are valid to be assigned to Value:
	//
	//	*SpaceSettingsContent_ObjectDelete
	//	*SpaceSettingsContent_SpaceDelete
	Value isSpaceSettingsContent_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

SpaceSettingsContent is a payload for a space settings object

func (*SpaceSettingsContent) Descriptor deprecated 

func (*SpaceSettingsContent) Descriptor() ([]byte, []int)

Deprecated: Use SpaceSettingsContent.ProtoReflect.Descriptor instead.

func (*SpaceSettingsContent) GetObjectDelete 

func (x *SpaceSettingsContent) GetObjectDelete() *ObjectDelete

func (*SpaceSettingsContent) GetSpaceDelete 

func (x *SpaceSettingsContent) GetSpaceDelete() *SpaceDelete

func (*SpaceSettingsContent) GetValue 

func (x *SpaceSettingsContent) GetValue() isSpaceSettingsContent_Value

func (*SpaceSettingsContent) MarshalToSizedBufferVT added in v0.9.0 

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

func (*SpaceSettingsContent) MarshalToVT added in v0.9.0 

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

func (*SpaceSettingsContent) MarshalVT added in v0.9.0 

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

func (*SpaceSettingsContent) ProtoMessage 

func (*SpaceSettingsContent) ProtoMessage()

func (*SpaceSettingsContent) ProtoReflect added in v0.9.0 

func (x *SpaceSettingsContent) ProtoReflect() protoreflect.Message

func (*SpaceSettingsContent) Reset 

func (x *SpaceSettingsContent) Reset()

func (*SpaceSettingsContent) SizeVT added in v0.9.0 

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

func (*SpaceSettingsContent) String 

func (x *SpaceSettingsContent) String() string

func (*SpaceSettingsContent) UnmarshalVT added in v0.9.0 

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

type SpaceSettingsContent_ObjectDelete 

type SpaceSettingsContent_ObjectDelete struct {
	ObjectDelete *ObjectDelete `protobuf:"bytes,1,opt,name=objectDelete,proto3,oneof"`
}

func (*SpaceSettingsContent_ObjectDelete) MarshalToSizedBufferVT added in v0.9.0 

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

func (*SpaceSettingsContent_ObjectDelete) MarshalToVT added in v0.9.0 

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

func (*SpaceSettingsContent_ObjectDelete) SizeVT added in v0.9.0 

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

type SpaceSettingsContent_SpaceDelete 

type SpaceSettingsContent_SpaceDelete struct {
	SpaceDelete *SpaceDelete `protobuf:"bytes,2,opt,name=spaceDelete,proto3,oneof"`
}

func (*SpaceSettingsContent_SpaceDelete) MarshalToSizedBufferVT added in v0.9.0 

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

func (*SpaceSettingsContent_SpaceDelete) MarshalToVT added in v0.9.0 

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

func (*SpaceSettingsContent_SpaceDelete) SizeVT added in v0.9.0 

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

type SpaceSettingsSnapshot 

type SpaceSettingsSnapshot struct {
	DeletedIds    []string `protobuf:"bytes,1,rep,name=deletedIds,proto3" json:"deletedIds,omitempty"`
	DeleterPeerId string   `protobuf:"bytes,2,opt,name=deleterPeerId,proto3" json:"deleterPeerId,omitempty"`
	// contains filtered or unexported fields
}

SpaceSettingsSnapshot contains all the deleted ids in a snapshot

func (*SpaceSettingsSnapshot) Descriptor deprecated 

func (*SpaceSettingsSnapshot) Descriptor() ([]byte, []int)

Deprecated: Use SpaceSettingsSnapshot.ProtoReflect.Descriptor instead.

func (*SpaceSettingsSnapshot) GetDeletedIds 

func (x *SpaceSettingsSnapshot) GetDeletedIds() []string

func (*SpaceSettingsSnapshot) GetDeleterPeerId 

func (x *SpaceSettingsSnapshot) GetDeleterPeerId() string

func (*SpaceSettingsSnapshot) MarshalToSizedBufferVT added in v0.9.0 

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

func (*SpaceSettingsSnapshot) MarshalToVT added in v0.9.0 

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

func (*SpaceSettingsSnapshot) MarshalVT added in v0.9.0 

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

func (*SpaceSettingsSnapshot) ProtoMessage 

func (*SpaceSettingsSnapshot) ProtoMessage()

func (*SpaceSettingsSnapshot) ProtoReflect added in v0.9.0 

func (x *SpaceSettingsSnapshot) ProtoReflect() protoreflect.Message

func (*SpaceSettingsSnapshot) Reset 

func (x *SpaceSettingsSnapshot) Reset()

func (*SpaceSettingsSnapshot) SizeVT added in v0.9.0 

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

func (*SpaceSettingsSnapshot) String 

func (x *SpaceSettingsSnapshot) String() string

func (*SpaceSettingsSnapshot) UnmarshalVT added in v0.9.0 

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

type SpaceSubscription 

type SpaceSubscription struct {
	SpaceIds []string                `protobuf:"bytes,1,rep,name=spaceIds,proto3" json:"spaceIds,omitempty"`
	Action   SpaceSubscriptionAction `protobuf:"varint,2,opt,name=action,proto3,enum=spacesync.SpaceSubscriptionAction" json:"action,omitempty"`
	// contains filtered or unexported fields
}

func (*SpaceSubscription) Descriptor deprecated 

func (*SpaceSubscription) Descriptor() ([]byte, []int)

Deprecated: Use SpaceSubscription.ProtoReflect.Descriptor instead.

func (*SpaceSubscription) GetAction 

func (x *SpaceSubscription) GetAction() SpaceSubscriptionAction

func (*SpaceSubscription) GetSpaceIds 

func (x *SpaceSubscription) GetSpaceIds() []string

func (*SpaceSubscription) MarshalToSizedBufferVT added in v0.9.0 

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

func (*SpaceSubscription) MarshalToVT added in v0.9.0 

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

func (*SpaceSubscription) MarshalVT added in v0.9.0 

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

func (*SpaceSubscription) ProtoMessage 

func (*SpaceSubscription) ProtoMessage()

func (*SpaceSubscription) ProtoReflect added in v0.9.0 

func (x *SpaceSubscription) ProtoReflect() protoreflect.Message

func (*SpaceSubscription) Reset 

func (x *SpaceSubscription) Reset()

func (*SpaceSubscription) SizeVT added in v0.9.0 

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

func (*SpaceSubscription) String 

func (x *SpaceSubscription) String() string

func (*SpaceSubscription) UnmarshalVT added in v0.9.0 

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

type SpaceSubscriptionAction 

type SpaceSubscriptionAction int32

SpaceSubscription contains in ObjectSyncMessage.Payload and indicates that we need to subscribe or unsubscribe the current stream to this space 

const (
	SpaceSubscriptionAction_Subscribe   SpaceSubscriptionAction = 0
	SpaceSubscriptionAction_Unsubscribe SpaceSubscriptionAction = 1
)

func (SpaceSubscriptionAction) Descriptor added in v0.9.0 

func (SpaceSubscriptionAction) Descriptor() protoreflect.EnumDescriptor

func (SpaceSubscriptionAction) Enum added in v0.9.0 

func (x SpaceSubscriptionAction) Enum() *SpaceSubscriptionAction

func (SpaceSubscriptionAction) EnumDescriptor deprecated 

func (SpaceSubscriptionAction) EnumDescriptor() ([]byte, []int)

Deprecated: Use SpaceSubscriptionAction.Descriptor instead.

func (SpaceSubscriptionAction) Number added in v0.9.0 

func (x SpaceSubscriptionAction) Number() protoreflect.EnumNumber

func (SpaceSubscriptionAction) String 

func (x SpaceSubscriptionAction) String() string

func (SpaceSubscriptionAction) Type added in v0.9.0 

func (SpaceSubscriptionAction) Type() protoreflect.EnumType

type StorageHeader added in v0.7.0 

type StorageHeader struct {
	SpaceId     string `protobuf:"bytes,1,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
	StorageName string `protobuf:"bytes,2,opt,name=storageName,proto3" json:"storageName,omitempty"`
	// contains filtered or unexported fields
}

func (*StorageHeader) Descriptor deprecated added in v0.7.0 

func (*StorageHeader) Descriptor() ([]byte, []int)

Deprecated: Use StorageHeader.ProtoReflect.Descriptor instead.

func (*StorageHeader) GetSpaceId added in v0.7.0 

func (x *StorageHeader) GetSpaceId() string

func (*StorageHeader) GetStorageName added in v0.7.0 

func (x *StorageHeader) GetStorageName() string

func (*StorageHeader) MarshalToSizedBufferVT added in v0.9.0 

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

func (*StorageHeader) MarshalToVT added in v0.9.0 

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

func (*StorageHeader) MarshalVT added in v0.9.0 

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

func (*StorageHeader) ProtoMessage added in v0.7.0 

func (*StorageHeader) ProtoMessage()

func (*StorageHeader) ProtoReflect added in v0.9.0 

func (x *StorageHeader) ProtoReflect() protoreflect.Message

func (*StorageHeader) Reset added in v0.7.0 

func (x *StorageHeader) Reset()

func (*StorageHeader) SizeVT added in v0.9.0 

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

func (*StorageHeader) String added in v0.7.0 

func (x *StorageHeader) String() string

func (*StorageHeader) UnmarshalVT added in v0.9.0 

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

type StoreDiffRequest added in v0.7.0 

type StoreDiffRequest struct {
	SpaceId string           `protobuf:"bytes,1,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
	Ranges  []*HeadSyncRange `protobuf:"bytes,2,rep,name=ranges,proto3" json:"ranges,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreDiffRequest) Descriptor deprecated added in v0.7.0 

func (*StoreDiffRequest) Descriptor() ([]byte, []int)

Deprecated: Use StoreDiffRequest.ProtoReflect.Descriptor instead.

func (*StoreDiffRequest) GetRanges added in v0.7.0 

func (x *StoreDiffRequest) GetRanges() []*HeadSyncRange

func (*StoreDiffRequest) GetSpaceId added in v0.7.0 

func (x *StoreDiffRequest) GetSpaceId() string

func (*StoreDiffRequest) MarshalToSizedBufferVT added in v0.9.0 

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

func (*StoreDiffRequest) MarshalToVT added in v0.9.0 

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

func (*StoreDiffRequest) MarshalVT added in v0.9.0 

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

func (*StoreDiffRequest) ProtoMessage added in v0.7.0 

func (*StoreDiffRequest) ProtoMessage()

func (*StoreDiffRequest) ProtoReflect added in v0.9.0 

func (x *StoreDiffRequest) ProtoReflect() protoreflect.Message

func (*StoreDiffRequest) Reset added in v0.7.0 

func (x *StoreDiffRequest) Reset()

func (*StoreDiffRequest) SizeVT added in v0.9.0 

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

func (*StoreDiffRequest) String added in v0.7.0 

func (x *StoreDiffRequest) String() string

func (*StoreDiffRequest) UnmarshalVT added in v0.9.0 

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

type StoreDiffResponse added in v0.7.0 

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

func (*StoreDiffResponse) Descriptor deprecated added in v0.7.0 

func (*StoreDiffResponse) Descriptor() ([]byte, []int)

Deprecated: Use StoreDiffResponse.ProtoReflect.Descriptor instead.

func (*StoreDiffResponse) GetResults added in v0.7.0 

func (x *StoreDiffResponse) GetResults() []*HeadSyncResult

func (*StoreDiffResponse) MarshalToSizedBufferVT added in v0.9.0 

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

func (*StoreDiffResponse) MarshalToVT added in v0.9.0 

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

func (*StoreDiffResponse) MarshalVT added in v0.9.0 

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

func (*StoreDiffResponse) ProtoMessage added in v0.7.0 

func (*StoreDiffResponse) ProtoMessage()

func (*StoreDiffResponse) ProtoReflect added in v0.9.0 

func (x *StoreDiffResponse) ProtoReflect() protoreflect.Message

func (*StoreDiffResponse) Reset added in v0.7.0 

func (x *StoreDiffResponse) Reset()

func (*StoreDiffResponse) SizeVT added in v0.9.0 

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

func (*StoreDiffResponse) String added in v0.7.0 

func (x *StoreDiffResponse) String() string

func (*StoreDiffResponse) UnmarshalVT added in v0.9.0 

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

type StoreHeader added in v0.7.0 

type StoreHeader struct {
	SpaceId     string `protobuf:"bytes,1,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
	StorageName string `protobuf:"bytes,2,opt,name=storageName,proto3" json:"storageName,omitempty"`
	// contains filtered or unexported fields
}

StoreHeader is a header for a store

func (*StoreHeader) Descriptor deprecated added in v0.7.0 

func (*StoreHeader) Descriptor() ([]byte, []int)

Deprecated: Use StoreHeader.ProtoReflect.Descriptor instead.

func (*StoreHeader) GetSpaceId added in v0.7.0 

func (x *StoreHeader) GetSpaceId() string

func (*StoreHeader) GetStorageName added in v0.7.0 

func (x *StoreHeader) GetStorageName() string

func (*StoreHeader) MarshalToSizedBufferVT added in v0.9.0 

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

func (*StoreHeader) MarshalToVT added in v0.9.0 

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

func (*StoreHeader) MarshalVT added in v0.9.0 

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

func (*StoreHeader) ProtoMessage added in v0.7.0 

func (*StoreHeader) ProtoMessage()

func (*StoreHeader) ProtoReflect added in v0.9.0 

func (x *StoreHeader) ProtoReflect() protoreflect.Message

func (*StoreHeader) Reset added in v0.7.0 

func (x *StoreHeader) Reset()

func (*StoreHeader) SizeVT added in v0.9.0 

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

func (*StoreHeader) String added in v0.7.0 

func (x *StoreHeader) String() string

func (*StoreHeader) UnmarshalVT added in v0.9.0 

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

type StoreKeyInner added in v0.7.0 

type StoreKeyInner struct {
	Peer           []byte `protobuf:"bytes,1,opt,name=peer,proto3" json:"peer,omitempty"`
	Identity       []byte `protobuf:"bytes,2,opt,name=identity,proto3" json:"identity,omitempty"`
	Value          []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	TimestampMicro int64  `protobuf:"varint,4,opt,name=timestampMicro,proto3" json:"timestampMicro,omitempty"`
	AclHeadId      string `protobuf:"bytes,5,opt,name=aclHeadId,proto3" json:"aclHeadId,omitempty"`
	Key            string `protobuf:"bytes,6,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreKeyInner) Descriptor deprecated added in v0.7.0 

func (*StoreKeyInner) Descriptor() ([]byte, []int)

Deprecated: Use StoreKeyInner.ProtoReflect.Descriptor instead.

func (*StoreKeyInner) GetAclHeadId added in v0.7.0 

func (x *StoreKeyInner) GetAclHeadId() string

func (*StoreKeyInner) GetIdentity added in v0.7.0 

func (x *StoreKeyInner) GetIdentity() []byte

func (*StoreKeyInner) GetKey added in v0.7.0 

func (x *StoreKeyInner) GetKey() string

func (*StoreKeyInner) GetPeer added in v0.7.0 

func (x *StoreKeyInner) GetPeer() []byte

func (*StoreKeyInner) GetTimestampMicro added in v0.7.0 

func (x *StoreKeyInner) GetTimestampMicro() int64

func (*StoreKeyInner) GetValue added in v0.7.0 

func (x *StoreKeyInner) GetValue() []byte

func (*StoreKeyInner) MarshalToSizedBufferVT added in v0.9.0 

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

func (*StoreKeyInner) MarshalToVT added in v0.9.0 

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

func (*StoreKeyInner) MarshalVT added in v0.9.0 

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

func (*StoreKeyInner) ProtoMessage added in v0.7.0 

func (*StoreKeyInner) ProtoMessage()

func (*StoreKeyInner) ProtoReflect added in v0.9.0 

func (x *StoreKeyInner) ProtoReflect() protoreflect.Message

func (*StoreKeyInner) Reset added in v0.7.0 

func (x *StoreKeyInner) Reset()

func (*StoreKeyInner) SizeVT added in v0.9.0 

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

func (*StoreKeyInner) String added in v0.7.0 

func (x *StoreKeyInner) String() string

func (*StoreKeyInner) UnmarshalVT added in v0.9.0 

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

type StoreKeyValue added in v0.7.0 

type StoreKeyValue struct {
	KeyPeerId         string `protobuf:"bytes,1,opt,name=keyPeerId,proto3" json:"keyPeerId,omitempty"`
	Value             []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	IdentitySignature []byte `protobuf:"bytes,3,opt,name=identitySignature,proto3" json:"identitySignature,omitempty"`
	PeerSignature     []byte `protobuf:"bytes,4,opt,name=peerSignature,proto3" json:"peerSignature,omitempty"`
	SpaceId           string `protobuf:"bytes,5,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreKeyValue) Descriptor deprecated added in v0.7.0 

func (*StoreKeyValue) Descriptor() ([]byte, []int)

Deprecated: Use StoreKeyValue.ProtoReflect.Descriptor instead.

func (*StoreKeyValue) GetIdentitySignature added in v0.7.0 

func (x *StoreKeyValue) GetIdentitySignature() []byte

func (*StoreKeyValue) GetKeyPeerId added in v0.7.0 

func (x *StoreKeyValue) GetKeyPeerId() string

func (*StoreKeyValue) GetPeerSignature added in v0.7.0 

func (x *StoreKeyValue) GetPeerSignature() []byte

func (*StoreKeyValue) GetSpaceId added in v0.7.0 

func (x *StoreKeyValue) GetSpaceId() string

func (*StoreKeyValue) GetValue added in v0.7.0 

func (x *StoreKeyValue) GetValue() []byte

func (*StoreKeyValue) MarshalToSizedBufferVT added in v0.9.0 

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

func (*StoreKeyValue) MarshalToVT added in v0.9.0 

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

func (*StoreKeyValue) MarshalVT added in v0.9.0 

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

func (*StoreKeyValue) ProtoMessage added in v0.7.0 

func (*StoreKeyValue) ProtoMessage()

func (*StoreKeyValue) ProtoReflect added in v0.9.0 

func (x *StoreKeyValue) ProtoReflect() protoreflect.Message

func (*StoreKeyValue) Reset added in v0.7.0 

func (x *StoreKeyValue) Reset()

func (*StoreKeyValue) SizeVT added in v0.9.0 

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

func (*StoreKeyValue) String added in v0.7.0 

func (x *StoreKeyValue) String() string

func (*StoreKeyValue) UnmarshalVT added in v0.9.0 

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

type StoreKeyValues added in v0.7.0 

type StoreKeyValues struct {
	KeyValues []*StoreKeyValue `protobuf:"bytes,1,rep,name=keyValues,proto3" json:"keyValues,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreKeyValues) Descriptor deprecated added in v0.7.0 

func (*StoreKeyValues) Descriptor() ([]byte, []int)

Deprecated: Use StoreKeyValues.ProtoReflect.Descriptor instead.

func (*StoreKeyValues) GetKeyValues added in v0.7.0 

func (x *StoreKeyValues) GetKeyValues() []*StoreKeyValue

func (*StoreKeyValues) MarshalToSizedBufferVT added in v0.9.0 

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

func (*StoreKeyValues) MarshalToVT added in v0.9.0 

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

func (*StoreKeyValues) MarshalVT added in v0.9.0 

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

func (*StoreKeyValues) ProtoMessage added in v0.7.0 

func (*StoreKeyValues) ProtoMessage()

func (*StoreKeyValues) ProtoReflect added in v0.9.0 

func (x *StoreKeyValues) ProtoReflect() protoreflect.Message

func (*StoreKeyValues) Reset added in v0.7.0 

func (x *StoreKeyValues) Reset()

func (*StoreKeyValues) SizeVT added in v0.9.0 

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

func (*StoreKeyValues) String added in v0.7.0 

func (x *StoreKeyValues) String() string

func (*StoreKeyValues) UnmarshalVT added in v0.9.0 

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

Source Files

View all Source files

Directories

Path Synopsis
Package mock_spacesyncproto is a generated GoMock package.
 Package mock_spacesyncproto is a generated GoMock package.

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.