spacesyncproto

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: May 23, 2023 License: MIT Imports: 12 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))
)
View Source 
var (
	ErrInvalidLengthSpacesync        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSpacesync          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupSpacesync = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ErrCodes_name = map[int32]string{
	0:   "Unexpected",
	1:   "SpaceMissing",
	2:   "SpaceExists",
	3:   "SpaceNotInCache",
	4:   "SpaceIsDeleted",
	5:   "PeerIsNotResponsible",
	6:   "ReceiptIsInvalid",
	100: "ErrorOffset",
}
View Source 
var ErrCodes_value = map[string]int32{
	"Unexpected":           0,
	"SpaceMissing":         1,
	"SpaceExists":          2,
	"SpaceNotInCache":      3,
	"SpaceIsDeleted":       4,
	"PeerIsNotResponsible": 5,
	"ReceiptIsInvalid":     6,
	"ErrorOffset":          100,
}
View Source 
var SpaceSubscriptionAction_name = map[int32]string{
	0: "Subscribe",
	1: "Unsubscribe",
}
View Source 
var SpaceSubscriptionAction_value = map[string]int32{
	"Subscribe":   0,
	"Unsubscribe": 1,
}

Functions

func DRPCRegisterSpaceSync 

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

Types

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)
	SpacePush(ctx context.Context, in *SpacePushRequest) (*SpacePushResponse, error)
	SpacePull(ctx context.Context, in *SpacePullRequest) (*SpacePullResponse, error)
	ObjectSyncStream(ctx context.Context) (DRPCSpaceSync_ObjectSyncStreamClient, 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)
	SpacePush(context.Context, *SpacePushRequest) (*SpacePushResponse, error)
	SpacePull(context.Context, *SpacePullRequest) (*SpacePullResponse, error)
	ObjectSyncStream(DRPCSpaceSync_ObjectSyncStreamStream) error
}

type DRPCSpaceSyncUnimplementedServer 

type DRPCSpaceSyncUnimplementedServer struct{}

func (*DRPCSpaceSyncUnimplementedServer) HeadSync 

func (s *DRPCSpaceSyncUnimplementedServer) HeadSync(context.Context, *HeadSyncRequest) (*HeadSyncResponse, 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)

type DRPCSpaceSync_HeadSyncStream 

type DRPCSpaceSync_HeadSyncStream interface {
	drpc.Stream
	SendAndClose(*HeadSyncResponse) 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 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_ErrorOffset          ErrCodes = 100
)

func (ErrCodes) EnumDescriptor 

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

func (ErrCodes) String 

func (x ErrCodes) String() string

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"`
}

HeadSyncRange presenting a request for one range

func (*HeadSyncRange) Descriptor 

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

func (*HeadSyncRange) GetFrom 

func (m *HeadSyncRange) GetFrom() uint64

func (*HeadSyncRange) GetLimit 

func (m *HeadSyncRange) GetLimit() uint32

func (*HeadSyncRange) GetTo 

func (m *HeadSyncRange) GetTo() uint64

func (*HeadSyncRange) Marshal 

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

func (*HeadSyncRange) MarshalTo 

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

func (*HeadSyncRange) MarshalToSizedBuffer 

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

func (*HeadSyncRange) ProtoMessage 

func (*HeadSyncRange) ProtoMessage()

func (*HeadSyncRange) Reset 

func (m *HeadSyncRange) Reset()

func (*HeadSyncRange) Size 

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

func (*HeadSyncRange) String 

func (m *HeadSyncRange) String() string

func (*HeadSyncRange) Unmarshal 

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

func (*HeadSyncRange) XXX_DiscardUnknown 

func (m *HeadSyncRange) XXX_DiscardUnknown()

func (*HeadSyncRange) XXX_Marshal 

func (m *HeadSyncRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HeadSyncRange) XXX_Merge 

func (m *HeadSyncRange) XXX_Merge(src proto.Message)

func (*HeadSyncRange) XXX_Size 

func (m *HeadSyncRange) XXX_Size() int

func (*HeadSyncRange) XXX_Unmarshal 

func (m *HeadSyncRange) XXX_Unmarshal(b []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"`
}

HeadSyncRequest is a request for HeadSync

func (*HeadSyncRequest) Descriptor 

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

func (*HeadSyncRequest) GetRanges 

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

func (*HeadSyncRequest) GetSpaceId 

func (m *HeadSyncRequest) GetSpaceId() string

func (*HeadSyncRequest) Marshal 

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

func (*HeadSyncRequest) MarshalTo 

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

func (*HeadSyncRequest) MarshalToSizedBuffer 

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

func (*HeadSyncRequest) ProtoMessage 

func (*HeadSyncRequest) ProtoMessage()

func (*HeadSyncRequest) Reset 

func (m *HeadSyncRequest) Reset()

func (*HeadSyncRequest) Size 

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

func (*HeadSyncRequest) String 

func (m *HeadSyncRequest) String() string

func (*HeadSyncRequest) Unmarshal 

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

func (*HeadSyncRequest) XXX_DiscardUnknown 

func (m *HeadSyncRequest) XXX_DiscardUnknown()

func (*HeadSyncRequest) XXX_Marshal 

func (m *HeadSyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HeadSyncRequest) XXX_Merge 

func (m *HeadSyncRequest) XXX_Merge(src proto.Message)

func (*HeadSyncRequest) XXX_Size 

func (m *HeadSyncRequest) XXX_Size() int

func (*HeadSyncRequest) XXX_Unmarshal 

func (m *HeadSyncRequest) XXX_Unmarshal(b []byte) error

type HeadSyncResponse 

type HeadSyncResponse struct {
	Results []*HeadSyncResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
}

HeadSyncResponse is a response for HeadSync

func (*HeadSyncResponse) Descriptor 

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

func (*HeadSyncResponse) GetResults 

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

func (*HeadSyncResponse) Marshal 

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

func (*HeadSyncResponse) MarshalTo 

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

func (*HeadSyncResponse) MarshalToSizedBuffer 

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

func (*HeadSyncResponse) ProtoMessage 

func (*HeadSyncResponse) ProtoMessage()

func (*HeadSyncResponse) Reset 

func (m *HeadSyncResponse) Reset()

func (*HeadSyncResponse) Size 

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

func (*HeadSyncResponse) String 

func (m *HeadSyncResponse) String() string

func (*HeadSyncResponse) Unmarshal 

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

func (*HeadSyncResponse) XXX_DiscardUnknown 

func (m *HeadSyncResponse) XXX_DiscardUnknown()

func (*HeadSyncResponse) XXX_Marshal 

func (m *HeadSyncResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HeadSyncResponse) XXX_Merge 

func (m *HeadSyncResponse) XXX_Merge(src proto.Message)

func (*HeadSyncResponse) XXX_Size 

func (m *HeadSyncResponse) XXX_Size() int

func (*HeadSyncResponse) XXX_Unmarshal 

func (m *HeadSyncResponse) XXX_Unmarshal(b []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"`
}

HeadSyncResult presenting a response for one range

func (*HeadSyncResult) Descriptor 

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

func (*HeadSyncResult) GetCount 

func (m *HeadSyncResult) GetCount() uint32

func (*HeadSyncResult) GetElements 

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

func (*HeadSyncResult) GetHash 

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

func (*HeadSyncResult) Marshal 

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

func (*HeadSyncResult) MarshalTo 

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

func (*HeadSyncResult) MarshalToSizedBuffer 

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

func (*HeadSyncResult) ProtoMessage 

func (*HeadSyncResult) ProtoMessage()

func (*HeadSyncResult) Reset 

func (m *HeadSyncResult) Reset()

func (*HeadSyncResult) Size 

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

func (*HeadSyncResult) String 

func (m *HeadSyncResult) String() string

func (*HeadSyncResult) Unmarshal 

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

func (*HeadSyncResult) XXX_DiscardUnknown 

func (m *HeadSyncResult) XXX_DiscardUnknown()

func (*HeadSyncResult) XXX_Marshal 

func (m *HeadSyncResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HeadSyncResult) XXX_Merge 

func (m *HeadSyncResult) XXX_Merge(src proto.Message)

func (*HeadSyncResult) XXX_Size 

func (m *HeadSyncResult) XXX_Size() int

func (*HeadSyncResult) XXX_Unmarshal 

func (m *HeadSyncResult) XXX_Unmarshal(b []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"`
}

HeadSyncResultElement presenting state of one object

func (*HeadSyncResultElement) Descriptor 

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

func (*HeadSyncResultElement) GetHead 

func (m *HeadSyncResultElement) GetHead() string

func (*HeadSyncResultElement) GetId 

func (m *HeadSyncResultElement) GetId() string

func (*HeadSyncResultElement) Marshal 

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

func (*HeadSyncResultElement) MarshalTo 

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

func (*HeadSyncResultElement) MarshalToSizedBuffer 

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

func (*HeadSyncResultElement) ProtoMessage 

func (*HeadSyncResultElement) ProtoMessage()

func (*HeadSyncResultElement) Reset 

func (m *HeadSyncResultElement) Reset()

func (*HeadSyncResultElement) Size 

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

func (*HeadSyncResultElement) String 

func (m *HeadSyncResultElement) String() string

func (*HeadSyncResultElement) Unmarshal 

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

func (*HeadSyncResultElement) XXX_DiscardUnknown 

func (m *HeadSyncResultElement) XXX_DiscardUnknown()

func (*HeadSyncResultElement) XXX_Marshal 

func (m *HeadSyncResultElement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HeadSyncResultElement) XXX_Merge 

func (m *HeadSyncResultElement) XXX_Merge(src proto.Message)

func (*HeadSyncResultElement) XXX_Size 

func (m *HeadSyncResultElement) XXX_Size() int

func (*HeadSyncResultElement) XXX_Unmarshal 

func (m *HeadSyncResultElement) XXX_Unmarshal(b []byte) error

type ObjectDelete 

type ObjectDelete struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

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

func (*ObjectDelete) Descriptor 

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

func (*ObjectDelete) GetId 

func (m *ObjectDelete) GetId() string

func (*ObjectDelete) Marshal 

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

func (*ObjectDelete) MarshalTo 

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

func (*ObjectDelete) MarshalToSizedBuffer 

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

func (*ObjectDelete) ProtoMessage 

func (*ObjectDelete) ProtoMessage()

func (*ObjectDelete) Reset 

func (m *ObjectDelete) Reset()

func (*ObjectDelete) Size 

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

func (*ObjectDelete) String 

func (m *ObjectDelete) String() string

func (*ObjectDelete) Unmarshal 

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

func (*ObjectDelete) XXX_DiscardUnknown 

func (m *ObjectDelete) XXX_DiscardUnknown()

func (*ObjectDelete) XXX_Marshal 

func (m *ObjectDelete) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ObjectDelete) XXX_Merge 

func (m *ObjectDelete) XXX_Merge(src proto.Message)

func (*ObjectDelete) XXX_Size 

func (m *ObjectDelete) XXX_Size() int

func (*ObjectDelete) XXX_Unmarshal 

func (m *ObjectDelete) XXX_Unmarshal(b []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"`
}

ObjectSyncMessage is a message sent on object sync

func (*ObjectSyncMessage) Descriptor 

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

func (*ObjectSyncMessage) GetObjectId 

func (m *ObjectSyncMessage) GetObjectId() string

func (*ObjectSyncMessage) GetPayload 

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

func (*ObjectSyncMessage) GetReplyId 

func (m *ObjectSyncMessage) GetReplyId() string

func (*ObjectSyncMessage) GetRequestId 

func (m *ObjectSyncMessage) GetRequestId() string

func (*ObjectSyncMessage) GetSpaceId 

func (m *ObjectSyncMessage) GetSpaceId() string

func (*ObjectSyncMessage) Marshal 

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

func (*ObjectSyncMessage) MarshalTo 

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

func (*ObjectSyncMessage) MarshalToSizedBuffer 

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

func (*ObjectSyncMessage) ProtoMessage 

func (*ObjectSyncMessage) ProtoMessage()

func (*ObjectSyncMessage) Reset 

func (m *ObjectSyncMessage) Reset()

func (*ObjectSyncMessage) Size 

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

func (*ObjectSyncMessage) String 

func (m *ObjectSyncMessage) String() string

func (*ObjectSyncMessage) Unmarshal 

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

func (*ObjectSyncMessage) XXX_DiscardUnknown 

func (m *ObjectSyncMessage) XXX_DiscardUnknown()

func (*ObjectSyncMessage) XXX_Marshal 

func (m *ObjectSyncMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ObjectSyncMessage) XXX_Merge 

func (m *ObjectSyncMessage) XXX_Merge(src proto.Message)

func (*ObjectSyncMessage) XXX_Size 

func (m *ObjectSyncMessage) XXX_Size() int

func (*ObjectSyncMessage) XXX_Unmarshal 

func (m *ObjectSyncMessage) XXX_Unmarshal(b []byte) error

type ObjectSyncStream 

type ObjectSyncStream = DRPCSpaceSync_ObjectSyncStreamStream

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"`
}

RawSpaceHeader is raw header for SpaceHeader

func (*RawSpaceHeader) Descriptor 

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

func (*RawSpaceHeader) GetSignature 

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

func (*RawSpaceHeader) GetSpaceHeader 

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

func (*RawSpaceHeader) Marshal 

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

func (*RawSpaceHeader) MarshalTo 

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

func (*RawSpaceHeader) MarshalToSizedBuffer 

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

func (*RawSpaceHeader) ProtoMessage 

func (*RawSpaceHeader) ProtoMessage()

func (*RawSpaceHeader) Reset 

func (m *RawSpaceHeader) Reset()

func (*RawSpaceHeader) Size 

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

func (*RawSpaceHeader) String 

func (m *RawSpaceHeader) String() string

func (*RawSpaceHeader) Unmarshal 

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

func (*RawSpaceHeader) XXX_DiscardUnknown 

func (m *RawSpaceHeader) XXX_DiscardUnknown()

func (*RawSpaceHeader) XXX_Marshal 

func (m *RawSpaceHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RawSpaceHeader) XXX_Merge 

func (m *RawSpaceHeader) XXX_Merge(src proto.Message)

func (*RawSpaceHeader) XXX_Size 

func (m *RawSpaceHeader) XXX_Size() int

func (*RawSpaceHeader) XXX_Unmarshal 

func (m *RawSpaceHeader) XXX_Unmarshal(b []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"`
}

RawSpaceHeaderWithId is a marshalled RawSpaceHeader with its content id

func (*RawSpaceHeaderWithId) Descriptor 

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

func (*RawSpaceHeaderWithId) GetId 

func (m *RawSpaceHeaderWithId) GetId() string

func (*RawSpaceHeaderWithId) GetRawHeader 

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

func (*RawSpaceHeaderWithId) Marshal 

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

func (*RawSpaceHeaderWithId) MarshalTo 

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

func (*RawSpaceHeaderWithId) MarshalToSizedBuffer 

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

func (*RawSpaceHeaderWithId) ProtoMessage 

func (*RawSpaceHeaderWithId) ProtoMessage()

func (*RawSpaceHeaderWithId) Reset 

func (m *RawSpaceHeaderWithId) Reset()

func (*RawSpaceHeaderWithId) Size 

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

func (*RawSpaceHeaderWithId) String 

func (m *RawSpaceHeaderWithId) String() string

func (*RawSpaceHeaderWithId) Unmarshal 

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

func (*RawSpaceHeaderWithId) XXX_DiscardUnknown 

func (m *RawSpaceHeaderWithId) XXX_DiscardUnknown()

func (*RawSpaceHeaderWithId) XXX_Marshal 

func (m *RawSpaceHeaderWithId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RawSpaceHeaderWithId) XXX_Merge 

func (m *RawSpaceHeaderWithId) XXX_Merge(src proto.Message)

func (*RawSpaceHeaderWithId) XXX_Size 

func (m *RawSpaceHeaderWithId) XXX_Size() int

func (*RawSpaceHeaderWithId) XXX_Unmarshal 

func (m *RawSpaceHeaderWithId) XXX_Unmarshal(b []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"`
}

SettingsData contains ObjectTree change payload

func (*SettingsData) Descriptor 

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

func (*SettingsData) GetContent 

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

func (*SettingsData) GetSnapshot 

func (m *SettingsData) GetSnapshot() *SpaceSettingsSnapshot

func (*SettingsData) Marshal 

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

func (*SettingsData) MarshalTo 

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

func (*SettingsData) MarshalToSizedBuffer 

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

func (*SettingsData) ProtoMessage 

func (*SettingsData) ProtoMessage()

func (*SettingsData) Reset 

func (m *SettingsData) Reset()

func (*SettingsData) Size 

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

func (*SettingsData) String 

func (m *SettingsData) String() string

func (*SettingsData) Unmarshal 

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

func (*SettingsData) XXX_DiscardUnknown 

func (m *SettingsData) XXX_DiscardUnknown()

func (*SettingsData) XXX_Marshal 

func (m *SettingsData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SettingsData) XXX_Merge 

func (m *SettingsData) XXX_Merge(src proto.Message)

func (*SettingsData) XXX_Size 

func (m *SettingsData) XXX_Size() int

func (*SettingsData) XXX_Unmarshal 

func (m *SettingsData) XXX_Unmarshal(b []byte) error

type SpaceDelete 

type SpaceDelete struct {
	DeleterPeerId string `protobuf:"bytes,1,opt,name=deleterPeerId,proto3" json:"deleterPeerId,omitempty"`
}

SpaceDelete is a message containing deleter peer id

func (*SpaceDelete) Descriptor 

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

func (*SpaceDelete) GetDeleterPeerId 

func (m *SpaceDelete) GetDeleterPeerId() string

func (*SpaceDelete) Marshal 

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

func (*SpaceDelete) MarshalTo 

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

func (*SpaceDelete) MarshalToSizedBuffer 

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

func (*SpaceDelete) ProtoMessage 

func (*SpaceDelete) ProtoMessage()

func (*SpaceDelete) Reset 

func (m *SpaceDelete) Reset()

func (*SpaceDelete) Size 

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

func (*SpaceDelete) String 

func (m *SpaceDelete) String() string

func (*SpaceDelete) Unmarshal 

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

func (*SpaceDelete) XXX_DiscardUnknown 

func (m *SpaceDelete) XXX_DiscardUnknown()

func (*SpaceDelete) XXX_Marshal 

func (m *SpaceDelete) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SpaceDelete) XXX_Merge 

func (m *SpaceDelete) XXX_Merge(src proto.Message)

func (*SpaceDelete) XXX_Size 

func (m *SpaceDelete) XXX_Size() int

func (*SpaceDelete) XXX_Unmarshal 

func (m *SpaceDelete) XXX_Unmarshal(b []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"`
}

SpaceHeader is a header for a space

func (*SpaceHeader) Descriptor 

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

func (*SpaceHeader) GetIdentity 

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

func (*SpaceHeader) GetReplicationKey 

func (m *SpaceHeader) GetReplicationKey() uint64

func (*SpaceHeader) GetSeed 

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

func (*SpaceHeader) GetSpaceHeaderPayload 

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

func (*SpaceHeader) GetSpaceType 

func (m *SpaceHeader) GetSpaceType() string

func (*SpaceHeader) GetTimestamp 

func (m *SpaceHeader) GetTimestamp() int64

func (*SpaceHeader) Marshal 

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

func (*SpaceHeader) MarshalTo 

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

func (*SpaceHeader) MarshalToSizedBuffer 

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

func (*SpaceHeader) ProtoMessage 

func (*SpaceHeader) ProtoMessage()

func (*SpaceHeader) Reset 

func (m *SpaceHeader) Reset()

func (*SpaceHeader) Size 

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

func (*SpaceHeader) String 

func (m *SpaceHeader) String() string

func (*SpaceHeader) Unmarshal 

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

func (*SpaceHeader) XXX_DiscardUnknown 

func (m *SpaceHeader) XXX_DiscardUnknown()

func (*SpaceHeader) XXX_Marshal 

func (m *SpaceHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SpaceHeader) XXX_Merge 

func (m *SpaceHeader) XXX_Merge(src proto.Message)

func (*SpaceHeader) XXX_Size 

func (m *SpaceHeader) XXX_Size() int

func (*SpaceHeader) XXX_Unmarshal 

func (m *SpaceHeader) XXX_Unmarshal(b []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"`
}

SpacePayload is a payload for pushing a space

func (*SpacePayload) Descriptor 

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

func (*SpacePayload) GetAclPayload 

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

func (*SpacePayload) GetAclPayloadId 

func (m *SpacePayload) GetAclPayloadId() string

func (*SpacePayload) GetSpaceHeader 

func (m *SpacePayload) GetSpaceHeader() *RawSpaceHeaderWithId

func (*SpacePayload) GetSpaceSettingsPayload 

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

func (*SpacePayload) GetSpaceSettingsPayloadId 

func (m *SpacePayload) GetSpaceSettingsPayloadId() string

func (*SpacePayload) Marshal 

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

func (*SpacePayload) MarshalTo 

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

func (*SpacePayload) MarshalToSizedBuffer 

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

func (*SpacePayload) ProtoMessage 

func (*SpacePayload) ProtoMessage()

func (*SpacePayload) Reset 

func (m *SpacePayload) Reset()

func (*SpacePayload) Size 

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

func (*SpacePayload) String 

func (m *SpacePayload) String() string

func (*SpacePayload) Unmarshal 

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

func (*SpacePayload) XXX_DiscardUnknown 

func (m *SpacePayload) XXX_DiscardUnknown()

func (*SpacePayload) XXX_Marshal 

func (m *SpacePayload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SpacePayload) XXX_Merge 

func (m *SpacePayload) XXX_Merge(src proto.Message)

func (*SpacePayload) XXX_Size 

func (m *SpacePayload) XXX_Size() int

func (*SpacePayload) XXX_Unmarshal 

func (m *SpacePayload) XXX_Unmarshal(b []byte) error

type SpacePullRequest 

type SpacePullRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

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

func (*SpacePullRequest) Descriptor 

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

func (*SpacePullRequest) GetId 

func (m *SpacePullRequest) GetId() string

func (*SpacePullRequest) Marshal 

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

func (*SpacePullRequest) MarshalTo 

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

func (*SpacePullRequest) MarshalToSizedBuffer 

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

func (*SpacePullRequest) ProtoMessage 

func (*SpacePullRequest) ProtoMessage()

func (*SpacePullRequest) Reset 

func (m *SpacePullRequest) Reset()

func (*SpacePullRequest) Size 

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

func (*SpacePullRequest) String 

func (m *SpacePullRequest) String() string

func (*SpacePullRequest) Unmarshal 

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

func (*SpacePullRequest) XXX_DiscardUnknown 

func (m *SpacePullRequest) XXX_DiscardUnknown()

func (*SpacePullRequest) XXX_Marshal 

func (m *SpacePullRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SpacePullRequest) XXX_Merge 

func (m *SpacePullRequest) XXX_Merge(src proto.Message)

func (*SpacePullRequest) XXX_Size 

func (m *SpacePullRequest) XXX_Size() int

func (*SpacePullRequest) XXX_Unmarshal 

func (m *SpacePullRequest) XXX_Unmarshal(b []byte) error

type SpacePullResponse 

type SpacePullResponse struct {
	Payload *SpacePayload `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
}

SpacePullResponse is a response with header and acl root

func (*SpacePullResponse) Descriptor 

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

func (*SpacePullResponse) GetPayload 

func (m *SpacePullResponse) GetPayload() *SpacePayload

func (*SpacePullResponse) Marshal 

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

func (*SpacePullResponse) MarshalTo 

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

func (*SpacePullResponse) MarshalToSizedBuffer 

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

func (*SpacePullResponse) ProtoMessage 

func (*SpacePullResponse) ProtoMessage()

func (*SpacePullResponse) Reset 

func (m *SpacePullResponse) Reset()

func (*SpacePullResponse) Size 

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

func (*SpacePullResponse) String 

func (m *SpacePullResponse) String() string

func (*SpacePullResponse) Unmarshal 

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

func (*SpacePullResponse) XXX_DiscardUnknown 

func (m *SpacePullResponse) XXX_DiscardUnknown()

func (*SpacePullResponse) XXX_Marshal 

func (m *SpacePullResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SpacePullResponse) XXX_Merge 

func (m *SpacePullResponse) XXX_Merge(src proto.Message)

func (*SpacePullResponse) XXX_Size 

func (m *SpacePullResponse) XXX_Size() int

func (*SpacePullResponse) XXX_Unmarshal 

func (m *SpacePullResponse) XXX_Unmarshal(b []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"`
}

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

func (*SpacePushRequest) Descriptor 

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

func (*SpacePushRequest) GetCredential 

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

func (*SpacePushRequest) GetPayload 

func (m *SpacePushRequest) GetPayload() *SpacePayload

func (*SpacePushRequest) Marshal 

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

func (*SpacePushRequest) MarshalTo 

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

func (*SpacePushRequest) MarshalToSizedBuffer 

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

func (*SpacePushRequest) ProtoMessage 

func (*SpacePushRequest) ProtoMessage()

func (*SpacePushRequest) Reset 

func (m *SpacePushRequest) Reset()

func (*SpacePushRequest) Size 

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

func (*SpacePushRequest) String 

func (m *SpacePushRequest) String() string

func (*SpacePushRequest) Unmarshal 

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

func (*SpacePushRequest) XXX_DiscardUnknown 

func (m *SpacePushRequest) XXX_DiscardUnknown()

func (*SpacePushRequest) XXX_Marshal 

func (m *SpacePushRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SpacePushRequest) XXX_Merge 

func (m *SpacePushRequest) XXX_Merge(src proto.Message)

func (*SpacePushRequest) XXX_Size 

func (m *SpacePushRequest) XXX_Size() int

func (*SpacePushRequest) XXX_Unmarshal 

func (m *SpacePushRequest) XXX_Unmarshal(b []byte) error

type SpacePushResponse 

type SpacePushResponse struct {
}

SpacePushResponse is an empty response

func (*SpacePushResponse) Descriptor 

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

func (*SpacePushResponse) Marshal 

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

func (*SpacePushResponse) MarshalTo 

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

func (*SpacePushResponse) MarshalToSizedBuffer 

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

func (*SpacePushResponse) ProtoMessage 

func (*SpacePushResponse) ProtoMessage()

func (*SpacePushResponse) Reset 

func (m *SpacePushResponse) Reset()

func (*SpacePushResponse) Size 

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

func (*SpacePushResponse) String 

func (m *SpacePushResponse) String() string

func (*SpacePushResponse) Unmarshal 

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

func (*SpacePushResponse) XXX_DiscardUnknown 

func (m *SpacePushResponse) XXX_DiscardUnknown()

func (*SpacePushResponse) XXX_Marshal 

func (m *SpacePushResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SpacePushResponse) XXX_Merge 

func (m *SpacePushResponse) XXX_Merge(src proto.Message)

func (*SpacePushResponse) XXX_Size 

func (m *SpacePushResponse) XXX_Size() int

func (*SpacePushResponse) XXX_Unmarshal 

func (m *SpacePushResponse) XXX_Unmarshal(b []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"`
}

SpaceSettingsContent is a payload for a space settings object

func (*SpaceSettingsContent) Descriptor 

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

func (*SpaceSettingsContent) GetObjectDelete 

func (m *SpaceSettingsContent) GetObjectDelete() *ObjectDelete

func (*SpaceSettingsContent) GetSpaceDelete 

func (m *SpaceSettingsContent) GetSpaceDelete() *SpaceDelete

func (*SpaceSettingsContent) GetValue 

func (m *SpaceSettingsContent) GetValue() isSpaceSettingsContent_Value

func (*SpaceSettingsContent) Marshal 

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

func (*SpaceSettingsContent) MarshalTo 

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

func (*SpaceSettingsContent) MarshalToSizedBuffer 

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

func (*SpaceSettingsContent) ProtoMessage 

func (*SpaceSettingsContent) ProtoMessage()

func (*SpaceSettingsContent) Reset 

func (m *SpaceSettingsContent) Reset()

func (*SpaceSettingsContent) Size 

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

func (*SpaceSettingsContent) String 

func (m *SpaceSettingsContent) String() string

func (*SpaceSettingsContent) Unmarshal 

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

func (*SpaceSettingsContent) XXX_DiscardUnknown 

func (m *SpaceSettingsContent) XXX_DiscardUnknown()

func (*SpaceSettingsContent) XXX_Marshal 

func (m *SpaceSettingsContent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SpaceSettingsContent) XXX_Merge 

func (m *SpaceSettingsContent) XXX_Merge(src proto.Message)

func (*SpaceSettingsContent) XXX_OneofWrappers 

func (*SpaceSettingsContent) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*SpaceSettingsContent) XXX_Size 

func (m *SpaceSettingsContent) XXX_Size() int

func (*SpaceSettingsContent) XXX_Unmarshal 

func (m *SpaceSettingsContent) XXX_Unmarshal(b []byte) error

type SpaceSettingsContent_ObjectDelete 

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

func (*SpaceSettingsContent_ObjectDelete) MarshalTo 

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

func (*SpaceSettingsContent_ObjectDelete) MarshalToSizedBuffer 

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

func (*SpaceSettingsContent_ObjectDelete) Size 

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

type SpaceSettingsContent_SpaceDelete 

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

func (*SpaceSettingsContent_SpaceDelete) MarshalTo 

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

func (*SpaceSettingsContent_SpaceDelete) MarshalToSizedBuffer 

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

func (*SpaceSettingsContent_SpaceDelete) Size 

func (m *SpaceSettingsContent_SpaceDelete) Size() (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"`
}

SpaceSettingsSnapshot contains all the deleted ids in a snapshot

func (*SpaceSettingsSnapshot) Descriptor 

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

func (*SpaceSettingsSnapshot) GetDeletedIds 

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

func (*SpaceSettingsSnapshot) GetDeleterPeerId 

func (m *SpaceSettingsSnapshot) GetDeleterPeerId() string

func (*SpaceSettingsSnapshot) Marshal 

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

func (*SpaceSettingsSnapshot) MarshalTo 

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

func (*SpaceSettingsSnapshot) MarshalToSizedBuffer 

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

func (*SpaceSettingsSnapshot) ProtoMessage 

func (*SpaceSettingsSnapshot) ProtoMessage()

func (*SpaceSettingsSnapshot) Reset 

func (m *SpaceSettingsSnapshot) Reset()

func (*SpaceSettingsSnapshot) Size 

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

func (*SpaceSettingsSnapshot) String 

func (m *SpaceSettingsSnapshot) String() string

func (*SpaceSettingsSnapshot) Unmarshal 

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

func (*SpaceSettingsSnapshot) XXX_DiscardUnknown 

func (m *SpaceSettingsSnapshot) XXX_DiscardUnknown()

func (*SpaceSettingsSnapshot) XXX_Marshal 

func (m *SpaceSettingsSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SpaceSettingsSnapshot) XXX_Merge 

func (m *SpaceSettingsSnapshot) XXX_Merge(src proto.Message)

func (*SpaceSettingsSnapshot) XXX_Size 

func (m *SpaceSettingsSnapshot) XXX_Size() int

func (*SpaceSettingsSnapshot) XXX_Unmarshal 

func (m *SpaceSettingsSnapshot) XXX_Unmarshal(b []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"`
}

func (*SpaceSubscription) Descriptor 

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

func (*SpaceSubscription) GetAction 

func (m *SpaceSubscription) GetAction() SpaceSubscriptionAction

func (*SpaceSubscription) GetSpaceIds 

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

func (*SpaceSubscription) Marshal 

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

func (*SpaceSubscription) MarshalTo 

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

func (*SpaceSubscription) MarshalToSizedBuffer 

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

func (*SpaceSubscription) ProtoMessage 

func (*SpaceSubscription) ProtoMessage()

func (*SpaceSubscription) Reset 

func (m *SpaceSubscription) Reset()

func (*SpaceSubscription) Size 

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

func (*SpaceSubscription) String 

func (m *SpaceSubscription) String() string

func (*SpaceSubscription) Unmarshal 

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

func (*SpaceSubscription) XXX_DiscardUnknown 

func (m *SpaceSubscription) XXX_DiscardUnknown()

func (*SpaceSubscription) XXX_Marshal 

func (m *SpaceSubscription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SpaceSubscription) XXX_Merge 

func (m *SpaceSubscription) XXX_Merge(src proto.Message)

func (*SpaceSubscription) XXX_Size 

func (m *SpaceSubscription) XXX_Size() int

func (*SpaceSubscription) XXX_Unmarshal 

func (m *SpaceSubscription) XXX_Unmarshal(b []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) EnumDescriptor 

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

func (SpaceSubscriptionAction) String 

func (x SpaceSubscriptionAction) String() string

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.