spacesyncproto

package
v0.4.22 Latest Latest
Warning

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

 Go to latest Published: Jul 26, 2024 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 DiffType_name = map[int32]string{
	0: "Initial",
	1: "Precalculated",
}
View Source 
var DiffType_value = map[string]int32{
	"Initial":       0,
	"Precalculated": 1,
}
View Source 
var ErrCodes_name = map[int32]string{
	0:   "Unexpected",
	1:   "SpaceMissing",
	2:   "SpaceExists",
	3:   "SpaceNotInCache",
	4:   "SpaceIsDeleted",
	5:   "PeerIsNotResponsible",
	6:   "ReceiptIsInvalid",
	7:   "InvalidPayload",
	100: "ErrorOffset",
}
View Source 
var ErrCodes_value = map[string]int32{
	"Unexpected":           0,
	"SpaceMissing":         1,
	"SpaceExists":          2,
	"SpaceNotInCache":      3,
	"SpaceIsDeleted":       4,
	"PeerIsNotResponsible": 5,
	"ReceiptIsInvalid":     6,
	"InvalidPayload":       7,
	"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 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"`
}

AclAddRecordRequest contains marshaled consensusproto.RawRecord

func (*AclAddRecordRequest) Descriptor added in v0.2.15 

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

func (*AclAddRecordRequest) GetPayload added in v0.2.15 

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

func (*AclAddRecordRequest) GetSpaceId added in v0.2.15 

func (m *AclAddRecordRequest) GetSpaceId() string

func (*AclAddRecordRequest) Marshal added in v0.2.15 

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

func (*AclAddRecordRequest) MarshalTo added in v0.2.15 

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

func (*AclAddRecordRequest) MarshalToSizedBuffer added in v0.2.15 

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

func (*AclAddRecordRequest) ProtoMessage added in v0.2.15 

func (*AclAddRecordRequest) ProtoMessage()

func (*AclAddRecordRequest) Reset added in v0.2.15 

func (m *AclAddRecordRequest) Reset()

func (*AclAddRecordRequest) Size added in v0.2.15 

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

func (*AclAddRecordRequest) String added in v0.2.15 

func (m *AclAddRecordRequest) String() string

func (*AclAddRecordRequest) Unmarshal added in v0.2.15 

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

func (*AclAddRecordRequest) XXX_DiscardUnknown added in v0.2.15 

func (m *AclAddRecordRequest) XXX_DiscardUnknown()

func (*AclAddRecordRequest) XXX_Marshal added in v0.2.15 

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

func (*AclAddRecordRequest) XXX_Merge added in v0.2.15 

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

func (*AclAddRecordRequest) XXX_Size added in v0.2.15 

func (m *AclAddRecordRequest) XXX_Size() int

func (*AclAddRecordRequest) XXX_Unmarshal added in v0.2.15 

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

AclAddRecordResponse contains created record id and marshaled consensusproto.RawRecord

func (*AclAddRecordResponse) Descriptor added in v0.2.15 

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

func (*AclAddRecordResponse) GetPayload added in v0.2.15 

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

func (*AclAddRecordResponse) GetRecordId added in v0.2.15 

func (m *AclAddRecordResponse) GetRecordId() string

func (*AclAddRecordResponse) Marshal added in v0.2.15 

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

func (*AclAddRecordResponse) MarshalTo added in v0.2.15 

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

func (*AclAddRecordResponse) MarshalToSizedBuffer added in v0.2.15 

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

func (*AclAddRecordResponse) ProtoMessage added in v0.2.15 

func (*AclAddRecordResponse) ProtoMessage()

func (*AclAddRecordResponse) Reset added in v0.2.15 

func (m *AclAddRecordResponse) Reset()

func (*AclAddRecordResponse) Size added in v0.2.15 

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

func (*AclAddRecordResponse) String added in v0.2.15 

func (m *AclAddRecordResponse) String() string

func (*AclAddRecordResponse) Unmarshal added in v0.2.15 

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

func (*AclAddRecordResponse) XXX_DiscardUnknown added in v0.2.15 

func (m *AclAddRecordResponse) XXX_DiscardUnknown()

func (*AclAddRecordResponse) XXX_Marshal added in v0.2.15 

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

func (*AclAddRecordResponse) XXX_Merge added in v0.2.15 

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

func (*AclAddRecordResponse) XXX_Size added in v0.2.15 

func (m *AclAddRecordResponse) XXX_Size() int

func (*AclAddRecordResponse) XXX_Unmarshal added in v0.2.15 

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

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 added in v0.2.15 

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

func (*AclGetRecordsRequest) GetAclHead added in v0.2.15 

func (m *AclGetRecordsRequest) GetAclHead() string

func (*AclGetRecordsRequest) GetSpaceId added in v0.2.15 

func (m *AclGetRecordsRequest) GetSpaceId() string

func (*AclGetRecordsRequest) Marshal added in v0.2.15 

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

func (*AclGetRecordsRequest) MarshalTo added in v0.2.15 

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

func (*AclGetRecordsRequest) MarshalToSizedBuffer added in v0.2.15 

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

func (*AclGetRecordsRequest) ProtoMessage added in v0.2.15 

func (*AclGetRecordsRequest) ProtoMessage()

func (*AclGetRecordsRequest) Reset added in v0.2.15 

func (m *AclGetRecordsRequest) Reset()

func (*AclGetRecordsRequest) Size added in v0.2.15 

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

func (*AclGetRecordsRequest) String added in v0.2.15 

func (m *AclGetRecordsRequest) String() string

func (*AclGetRecordsRequest) Unmarshal added in v0.2.15 

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

func (*AclGetRecordsRequest) XXX_DiscardUnknown added in v0.2.15 

func (m *AclGetRecordsRequest) XXX_DiscardUnknown()

func (*AclGetRecordsRequest) XXX_Marshal added in v0.2.15 

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

func (*AclGetRecordsRequest) XXX_Merge added in v0.2.15 

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

func (*AclGetRecordsRequest) XXX_Size added in v0.2.15 

func (m *AclGetRecordsRequest) XXX_Size() int

func (*AclGetRecordsRequest) XXX_Unmarshal added in v0.2.15 

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

type AclGetRecordsResponse added in v0.2.15 

type AclGetRecordsResponse struct {
	Records [][]byte `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
}

AclGetRecordsResponse contains list of marshaled consensusproto.RawRecordWithId

func (*AclGetRecordsResponse) Descriptor added in v0.2.15 

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

func (*AclGetRecordsResponse) GetRecords added in v0.2.15 

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

func (*AclGetRecordsResponse) Marshal added in v0.2.15 

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

func (*AclGetRecordsResponse) MarshalTo added in v0.2.15 

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

func (*AclGetRecordsResponse) MarshalToSizedBuffer added in v0.2.15 

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

func (*AclGetRecordsResponse) ProtoMessage added in v0.2.15 

func (*AclGetRecordsResponse) ProtoMessage()

func (*AclGetRecordsResponse) Reset added in v0.2.15 

func (m *AclGetRecordsResponse) Reset()

func (*AclGetRecordsResponse) Size added in v0.2.15 

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

func (*AclGetRecordsResponse) String added in v0.2.15 

func (m *AclGetRecordsResponse) String() string

func (*AclGetRecordsResponse) Unmarshal added in v0.2.15 

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

func (*AclGetRecordsResponse) XXX_DiscardUnknown added in v0.2.15 

func (m *AclGetRecordsResponse) XXX_DiscardUnknown()

func (*AclGetRecordsResponse) XXX_Marshal added in v0.2.15 

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

func (*AclGetRecordsResponse) XXX_Merge added in v0.2.15 

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

func (*AclGetRecordsResponse) XXX_Size added in v0.2.15 

func (m *AclGetRecordsResponse) XXX_Size() int

func (*AclGetRecordsResponse) XXX_Unmarshal added in v0.2.15 

func (m *AclGetRecordsResponse) XXX_Unmarshal(b []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)
	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)
	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)
	SpacePush(context.Context, *SpacePushRequest) (*SpacePushResponse, error)
	SpacePull(context.Context, *SpacePullRequest) (*SpacePullResponse, error)
	ObjectSyncStream(DRPCSpaceSync_ObjectSyncStreamStream) error
	ObjectSync(context.Context, *ObjectSyncMessage) (*ObjectSyncMessage, 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) 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_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_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 DiffType added in v0.3.11 

type DiffType int32

DiffType is a type of diff 

const (
	DiffType_Initial       DiffType = 0
	DiffType_Precalculated DiffType = 1
)

func (DiffType) EnumDescriptor added in v0.3.11 

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

func (DiffType) String added in v0.3.11 

func (x DiffType) String() string

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_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"`
	Elements bool   `protobuf:"varint,4,opt,name=elements,proto3" json:"elements,omitempty"`
}

HeadSyncRange presenting a request for one range

func (*HeadSyncRange) Descriptor 

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

func (*HeadSyncRange) GetElements added in v0.3.11 

func (m *HeadSyncRange) GetElements() bool

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"`
	DiffType DiffType         `protobuf:"varint,3,opt,name=diffType,proto3,enum=spacesync.DiffType" json:"diffType,omitempty"`
}

HeadSyncRequest is a request for HeadSync

func (*HeadSyncRequest) Descriptor 

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

func (*HeadSyncRequest) GetDiffType added in v0.3.11 

func (m *HeadSyncRequest) GetDiffType() DiffType

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"`
	DiffType DiffType          `protobuf:"varint,2,opt,name=diffType,proto3,enum=spacesync.DiffType" json:"diffType,omitempty"`
}

HeadSyncResponse is a response for HeadSync

func (*HeadSyncResponse) Descriptor 

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

func (*HeadSyncResponse) GetDiffType added in v0.3.11 

func (m *HeadSyncResponse) GetDiffType() DiffType

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 MarshallSyncMessage added in v0.2.15 

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

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.