coordinatorproto

package
v0.2.21 Latest Latest
Warning

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

 Go to latest Published: Aug 14, 2023 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCoordinator        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCoordinator          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCoordinator = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrUnexpected           = errGroup.Register(errors.New("unexpected error"), uint64(ErrorCodes_Unexpected))
	ErrSpaceIsCreated       = errGroup.Register(errors.New("space is missing"), uint64(ErrorCodes_SpaceCreated))
	ErrSpaceIsDeleted       = errGroup.Register(errors.New("space is deleted"), uint64(ErrorCodes_SpaceDeleted))
	ErrSpaceDeletionPending = errGroup.Register(errors.New("space is set out for deletion"), uint64(ErrorCodes_SpaceDeletionPending))
	ErrSpaceNotExists       = errGroup.Register(errors.New("space not exists"), uint64(ErrorCodes_SpaceNotExists))
)
View Source 
var ErrorCodes_name = map[int32]string{
	0:   "Unexpected",
	1:   "SpaceDeleted",
	2:   "SpaceDeletionPending",
	3:   "SpaceCreated",
	4:   "SpaceNotExists",
	300: "ErrorOffset",
}
View Source 
var ErrorCodes_value = map[string]int32{
	"Unexpected":           0,
	"SpaceDeleted":         1,
	"SpaceDeletionPending": 2,
	"SpaceCreated":         3,
	"SpaceNotExists":       4,
	"ErrorOffset":          300,
}
View Source 
var NodeType_name = map[int32]string{
	0: "TreeAPI",
	1: "FileAPI",
	2: "CoordinatorAPI",
}
View Source 
var NodeType_value = map[string]int32{
	"TreeAPI":        0,
	"FileAPI":        1,
	"CoordinatorAPI": 2,
}
View Source 
var SpaceStatus_name = map[int32]string{
	0: "SpaceStatusCreated",
	1: "SpaceStatusPendingDeletion",
	2: "SpaceStatusDeletionStarted",
	3: "SpaceStatusDeleted",
}
View Source 
var SpaceStatus_value = map[string]int32{
	"SpaceStatusCreated":         0,
	"SpaceStatusPendingDeletion": 1,
	"SpaceStatusDeletionStarted": 2,
	"SpaceStatusDeleted":         3,
}

Functions

func CheckReceipt 

func CheckReceipt(peerId, spaceId string, accountIdentity []byte, networkId string, receipt *SpaceReceiptWithSignature) (err error)

func DRPCRegisterCoordinator 

func DRPCRegisterCoordinator(mux drpc.Mux, impl DRPCCoordinatorServer) error

Types

type DRPCCoordinatorClient 

type DRPCCoordinatorClient interface {
	DRPCConn() drpc.Conn

	SpaceSign(ctx context.Context, in *SpaceSignRequest) (*SpaceSignResponse, error)
	FileLimitCheck(ctx context.Context, in *FileLimitCheckRequest) (*FileLimitCheckResponse, error)
	SpaceStatusCheck(ctx context.Context, in *SpaceStatusCheckRequest) (*SpaceStatusCheckResponse, error)
	SpaceStatusChange(ctx context.Context, in *SpaceStatusChangeRequest) (*SpaceStatusChangeResponse, error)
	NetworkConfiguration(ctx context.Context, in *NetworkConfigurationRequest) (*NetworkConfigurationResponse, error)
}

func NewDRPCCoordinatorClient 

func NewDRPCCoordinatorClient(cc drpc.Conn) DRPCCoordinatorClient

type DRPCCoordinatorDescription 

type DRPCCoordinatorDescription struct{}

func (DRPCCoordinatorDescription) Method 

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

func (DRPCCoordinatorDescription) NumMethods 

func (DRPCCoordinatorDescription) NumMethods() int

type DRPCCoordinatorServer 

type DRPCCoordinatorServer interface {
	SpaceSign(context.Context, *SpaceSignRequest) (*SpaceSignResponse, error)
	FileLimitCheck(context.Context, *FileLimitCheckRequest) (*FileLimitCheckResponse, error)
	SpaceStatusCheck(context.Context, *SpaceStatusCheckRequest) (*SpaceStatusCheckResponse, error)
	SpaceStatusChange(context.Context, *SpaceStatusChangeRequest) (*SpaceStatusChangeResponse, error)
	NetworkConfiguration(context.Context, *NetworkConfigurationRequest) (*NetworkConfigurationResponse, error)
}

type DRPCCoordinatorUnimplementedServer 

type DRPCCoordinatorUnimplementedServer struct{}

func (*DRPCCoordinatorUnimplementedServer) FileLimitCheck 

func (s *DRPCCoordinatorUnimplementedServer) FileLimitCheck(context.Context, *FileLimitCheckRequest) (*FileLimitCheckResponse, error)

func (*DRPCCoordinatorUnimplementedServer) NetworkConfiguration 

func (s *DRPCCoordinatorUnimplementedServer) NetworkConfiguration(context.Context, *NetworkConfigurationRequest) (*NetworkConfigurationResponse, error)

func (*DRPCCoordinatorUnimplementedServer) SpaceSign 

func (s *DRPCCoordinatorUnimplementedServer) SpaceSign(context.Context, *SpaceSignRequest) (*SpaceSignResponse, error)

func (*DRPCCoordinatorUnimplementedServer) SpaceStatusChange 

func (s *DRPCCoordinatorUnimplementedServer) SpaceStatusChange(context.Context, *SpaceStatusChangeRequest) (*SpaceStatusChangeResponse, error)

func (*DRPCCoordinatorUnimplementedServer) SpaceStatusCheck 

func (s *DRPCCoordinatorUnimplementedServer) SpaceStatusCheck(context.Context, *SpaceStatusCheckRequest) (*SpaceStatusCheckResponse, error)

type DRPCCoordinator_FileLimitCheckStream 

type DRPCCoordinator_FileLimitCheckStream interface {
	drpc.Stream
	SendAndClose(*FileLimitCheckResponse) error
}

type DRPCCoordinator_NetworkConfigurationStream 

type DRPCCoordinator_NetworkConfigurationStream interface {
	drpc.Stream
	SendAndClose(*NetworkConfigurationResponse) error
}

type DRPCCoordinator_SpaceSignStream 

type DRPCCoordinator_SpaceSignStream interface {
	drpc.Stream
	SendAndClose(*SpaceSignResponse) error
}

type DRPCCoordinator_SpaceStatusChangeStream 

type DRPCCoordinator_SpaceStatusChangeStream interface {
	drpc.Stream
	SendAndClose(*SpaceStatusChangeResponse) error
}

type DRPCCoordinator_SpaceStatusCheckStream 

type DRPCCoordinator_SpaceStatusCheckStream interface {
	drpc.Stream
	SendAndClose(*SpaceStatusCheckResponse) error
}

type ErrorCodes 

type ErrorCodes int32
const (
	ErrorCodes_Unexpected           ErrorCodes = 0
	ErrorCodes_SpaceDeleted         ErrorCodes = 1
	ErrorCodes_SpaceDeletionPending ErrorCodes = 2
	ErrorCodes_SpaceCreated         ErrorCodes = 3
	ErrorCodes_SpaceNotExists       ErrorCodes = 4
	ErrorCodes_ErrorOffset          ErrorCodes = 300
)

func (ErrorCodes) EnumDescriptor 

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

func (ErrorCodes) String 

func (x ErrorCodes) String() string

type FileLimitCheckRequest 

type FileLimitCheckRequest struct {
	AccountIdentity []byte `protobuf:"bytes,1,opt,name=accountIdentity,proto3" json:"accountIdentity,omitempty"`
	SpaceId         string `protobuf:"bytes,2,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
}

FileLimitCheckRequest contains an account identity and spaceId control node checks that identity owns a given space

func (*FileLimitCheckRequest) Descriptor 

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

func (*FileLimitCheckRequest) GetAccountIdentity 

func (m *FileLimitCheckRequest) GetAccountIdentity() []byte

func (*FileLimitCheckRequest) GetSpaceId 

func (m *FileLimitCheckRequest) GetSpaceId() string

func (*FileLimitCheckRequest) Marshal 

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

func (*FileLimitCheckRequest) MarshalTo 

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

func (*FileLimitCheckRequest) MarshalToSizedBuffer 

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

func (*FileLimitCheckRequest) ProtoMessage 

func (*FileLimitCheckRequest) ProtoMessage()

func (*FileLimitCheckRequest) Reset 

func (m *FileLimitCheckRequest) Reset()

func (*FileLimitCheckRequest) Size 

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

func (*FileLimitCheckRequest) String 

func (m *FileLimitCheckRequest) String() string

func (*FileLimitCheckRequest) Unmarshal 

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

func (*FileLimitCheckRequest) XXX_DiscardUnknown 

func (m *FileLimitCheckRequest) XXX_DiscardUnknown()

func (*FileLimitCheckRequest) XXX_Marshal 

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

func (*FileLimitCheckRequest) XXX_Merge 

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

func (*FileLimitCheckRequest) XXX_Size 

func (m *FileLimitCheckRequest) XXX_Size() int

func (*FileLimitCheckRequest) XXX_Unmarshal 

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

type FileLimitCheckResponse 

type FileLimitCheckResponse struct {
	Limit uint64 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
}

FileLimitCheckResponse returns a current space limit in bytes

func (*FileLimitCheckResponse) Descriptor 

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

func (*FileLimitCheckResponse) GetLimit 

func (m *FileLimitCheckResponse) GetLimit() uint64

func (*FileLimitCheckResponse) Marshal 

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

func (*FileLimitCheckResponse) MarshalTo 

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

func (*FileLimitCheckResponse) MarshalToSizedBuffer 

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

func (*FileLimitCheckResponse) ProtoMessage 

func (*FileLimitCheckResponse) ProtoMessage()

func (*FileLimitCheckResponse) Reset 

func (m *FileLimitCheckResponse) Reset()

func (*FileLimitCheckResponse) Size 

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

func (*FileLimitCheckResponse) String 

func (m *FileLimitCheckResponse) String() string

func (*FileLimitCheckResponse) Unmarshal 

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

func (*FileLimitCheckResponse) XXX_DiscardUnknown 

func (m *FileLimitCheckResponse) XXX_DiscardUnknown()

func (*FileLimitCheckResponse) XXX_Marshal 

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

func (*FileLimitCheckResponse) XXX_Merge 

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

func (*FileLimitCheckResponse) XXX_Size 

func (m *FileLimitCheckResponse) XXX_Size() int

func (*FileLimitCheckResponse) XXX_Unmarshal 

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

type NetworkConfigurationRequest 

type NetworkConfigurationRequest struct {
	// currenId of the client configuration
	// if the currentId is equal to the latest configuration id then the response will not contain a nodes list
	CurrentId string `protobuf:"bytes,1,opt,name=currentId,proto3" json:"currentId,omitempty"`
}

NetworkConfigurationRequest contains currenId of the client configuration, it can be empty

func (*NetworkConfigurationRequest) Descriptor 

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

func (*NetworkConfigurationRequest) GetCurrentId 

func (m *NetworkConfigurationRequest) GetCurrentId() string

func (*NetworkConfigurationRequest) Marshal 

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

func (*NetworkConfigurationRequest) MarshalTo 

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

func (*NetworkConfigurationRequest) MarshalToSizedBuffer 

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

func (*NetworkConfigurationRequest) ProtoMessage 

func (*NetworkConfigurationRequest) ProtoMessage()

func (*NetworkConfigurationRequest) Reset 

func (m *NetworkConfigurationRequest) Reset()

func (*NetworkConfigurationRequest) Size 

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

func (*NetworkConfigurationRequest) String 

func (m *NetworkConfigurationRequest) String() string

func (*NetworkConfigurationRequest) Unmarshal 

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

func (*NetworkConfigurationRequest) XXX_DiscardUnknown 

func (m *NetworkConfigurationRequest) XXX_DiscardUnknown()

func (*NetworkConfigurationRequest) XXX_Marshal 

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

func (*NetworkConfigurationRequest) XXX_Merge 

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

func (*NetworkConfigurationRequest) XXX_Size 

func (m *NetworkConfigurationRequest) XXX_Size() int

func (*NetworkConfigurationRequest) XXX_Unmarshal 

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

type NetworkConfigurationResponse 

type NetworkConfigurationResponse struct {
	// id of current configuration
	ConfigurationId string `protobuf:"bytes,1,opt,name=configurationId,proto3" json:"configurationId,omitempty"`
	// network id
	NetworkId string `protobuf:"bytes,2,opt,name=networkId,proto3" json:"networkId,omitempty"`
	// nodes list - it will be empty if the client's currentId is equal configurationId
	Nodes []*Node `protobuf:"bytes,3,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// unix timestamp of the creation time of configuration
	CreationTimeUnix uint64 `protobuf:"varint,4,opt,name=creationTimeUnix,proto3" json:"creationTimeUnix,omitempty"`
}

NetworkConfigurationResponse contains list of nodes

func (*NetworkConfigurationResponse) Descriptor 

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

func (*NetworkConfigurationResponse) GetConfigurationId 

func (m *NetworkConfigurationResponse) GetConfigurationId() string

func (*NetworkConfigurationResponse) GetCreationTimeUnix 

func (m *NetworkConfigurationResponse) GetCreationTimeUnix() uint64

func (*NetworkConfigurationResponse) GetNetworkId 

func (m *NetworkConfigurationResponse) GetNetworkId() string

func (*NetworkConfigurationResponse) GetNodes 

func (m *NetworkConfigurationResponse) GetNodes() []*Node

func (*NetworkConfigurationResponse) Marshal 

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

func (*NetworkConfigurationResponse) MarshalTo 

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

func (*NetworkConfigurationResponse) MarshalToSizedBuffer 

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

func (*NetworkConfigurationResponse) ProtoMessage 

func (*NetworkConfigurationResponse) ProtoMessage()

func (*NetworkConfigurationResponse) Reset 

func (m *NetworkConfigurationResponse) Reset()

func (*NetworkConfigurationResponse) Size 

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

func (*NetworkConfigurationResponse) String 

func (m *NetworkConfigurationResponse) String() string

func (*NetworkConfigurationResponse) Unmarshal 

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

func (*NetworkConfigurationResponse) XXX_DiscardUnknown 

func (m *NetworkConfigurationResponse) XXX_DiscardUnknown()

func (*NetworkConfigurationResponse) XXX_Marshal 

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

func (*NetworkConfigurationResponse) XXX_Merge 

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

func (*NetworkConfigurationResponse) XXX_Size 

func (m *NetworkConfigurationResponse) XXX_Size() int

func (*NetworkConfigurationResponse) XXX_Unmarshal 

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

type Node 

type Node struct {
	// peerId - it's a peer identifier (libp2p format string) so it's an encoded publicKey
	PeerId string `protobuf:"bytes,1,opt,name=peerId,proto3" json:"peerId,omitempty"`
	// list of node addresses
	Addresses []string `protobuf:"bytes,2,rep,name=addresses,proto3" json:"addresses,omitempty"`
	// list of supported APIs
	Types []NodeType `protobuf:"varint,3,rep,packed,name=types,proto3,enum=coordinator.NodeType" json:"types,omitempty"`
}

Node describes one node in the network

func (*Node) Descriptor 

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

func (*Node) GetAddresses 

func (m *Node) GetAddresses() []string

func (*Node) GetPeerId 

func (m *Node) GetPeerId() string

func (*Node) GetTypes 

func (m *Node) GetTypes() []NodeType

func (*Node) Marshal 

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

func (*Node) MarshalTo 

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

func (*Node) MarshalToSizedBuffer 

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

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) Size 

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

func (*Node) String 

func (m *Node) String() string

func (*Node) Unmarshal 

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

func (*Node) XXX_DiscardUnknown 

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal 

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

func (*Node) XXX_Merge 

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

func (*Node) XXX_Size 

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal 

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

type NodeType 

type NodeType int32

NodeType determines the type of API that a node supports 

const (
	// TreeAPI supports space/tree sync api
	NodeType_TreeAPI NodeType = 0
	// FileAPI support file api
	NodeType_FileAPI NodeType = 1
	// CoordinatorAPI supports coordinator api
	NodeType_CoordinatorAPI NodeType = 2
)

func (NodeType) EnumDescriptor 

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

func (NodeType) String 

func (x NodeType) String() string

type SpaceReceipt 

type SpaceReceipt struct {
	// SpaceId is the identifier of space
	SpaceId string `protobuf:"bytes,1,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
	// PeerId of receipt requester
	PeerId string `protobuf:"bytes,2,opt,name=peerId,proto3" json:"peerId,omitempty"`
	// AccountIdentity is an identity of a space owner
	AccountIdentity []byte `protobuf:"bytes,3,opt,name=accountIdentity,proto3" json:"accountIdentity,omitempty"`
	// NetworkId is the id of a network where the receipt is issued
	NetworkId string `protobuf:"bytes,4,opt,name=networkId,proto3" json:"networkId,omitempty"`
	// ValidUntil is a unix-timestamp with a deadline time of receipt validity
	ValidUntil uint64 `protobuf:"varint,5,opt,name=validUntil,proto3" json:"validUntil,omitempty"`
}

SpaceReceipt contains permission to SpacePush operation

func (*SpaceReceipt) Descriptor 

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

func (*SpaceReceipt) GetAccountIdentity 

func (m *SpaceReceipt) GetAccountIdentity() []byte

func (*SpaceReceipt) GetNetworkId 

func (m *SpaceReceipt) GetNetworkId() string

func (*SpaceReceipt) GetPeerId 

func (m *SpaceReceipt) GetPeerId() string

func (*SpaceReceipt) GetSpaceId 

func (m *SpaceReceipt) GetSpaceId() string

func (*SpaceReceipt) GetValidUntil 

func (m *SpaceReceipt) GetValidUntil() uint64

func (*SpaceReceipt) Marshal 

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

func (*SpaceReceipt) MarshalTo 

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

func (*SpaceReceipt) MarshalToSizedBuffer 

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

func (*SpaceReceipt) ProtoMessage 

func (*SpaceReceipt) ProtoMessage()

func (*SpaceReceipt) Reset 

func (m *SpaceReceipt) Reset()

func (*SpaceReceipt) Size 

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

func (*SpaceReceipt) String 

func (m *SpaceReceipt) String() string

func (*SpaceReceipt) Unmarshal 

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

func (*SpaceReceipt) XXX_DiscardUnknown 

func (m *SpaceReceipt) XXX_DiscardUnknown()

func (*SpaceReceipt) XXX_Marshal 

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

func (*SpaceReceipt) XXX_Merge 

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

func (*SpaceReceipt) XXX_Size 

func (m *SpaceReceipt) XXX_Size() int

func (*SpaceReceipt) XXX_Unmarshal 

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

type SpaceReceiptWithSignature 

type SpaceReceiptWithSignature struct {
	SpaceReceiptPayload []byte `protobuf:"bytes,1,opt,name=spaceReceiptPayload,proto3" json:"spaceReceiptPayload,omitempty"`
	Signature           []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
}

SpaceReceiptWithSignature contains protobuf encoded receipt and its signature

func PrepareSpaceReceipt 

func PrepareSpaceReceipt(spaceId, peerId string, validPeriod time.Duration, accountPubKey crypto.PubKey, networkKey crypto.PrivKey) (signedReceipt *SpaceReceiptWithSignature, err error)

func (*SpaceReceiptWithSignature) Descriptor 

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

func (*SpaceReceiptWithSignature) GetSignature 

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

func (*SpaceReceiptWithSignature) GetSpaceReceiptPayload 

func (m *SpaceReceiptWithSignature) GetSpaceReceiptPayload() []byte

func (*SpaceReceiptWithSignature) Marshal 

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

func (*SpaceReceiptWithSignature) MarshalTo 

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

func (*SpaceReceiptWithSignature) MarshalToSizedBuffer 

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

func (*SpaceReceiptWithSignature) ProtoMessage 

func (*SpaceReceiptWithSignature) ProtoMessage()

func (*SpaceReceiptWithSignature) Reset 

func (m *SpaceReceiptWithSignature) Reset()

func (*SpaceReceiptWithSignature) Size 

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

func (*SpaceReceiptWithSignature) String 

func (m *SpaceReceiptWithSignature) String() string

func (*SpaceReceiptWithSignature) Unmarshal 

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

func (*SpaceReceiptWithSignature) XXX_DiscardUnknown 

func (m *SpaceReceiptWithSignature) XXX_DiscardUnknown()

func (*SpaceReceiptWithSignature) XXX_Marshal 

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

func (*SpaceReceiptWithSignature) XXX_Merge 

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

func (*SpaceReceiptWithSignature) XXX_Size 

func (m *SpaceReceiptWithSignature) XXX_Size() int

func (*SpaceReceiptWithSignature) XXX_Unmarshal 

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

type SpaceSignRequest 

type SpaceSignRequest struct {
	// SpaceId is the id of the signed space
	SpaceId string `protobuf:"bytes,1,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
	// Header is the header of the signed space
	Header []byte `protobuf:"bytes,2,opt,name=header,proto3" json:"header,omitempty"`
	// OldIdentity is the old identity of the space owner
	OldIdentity []byte `protobuf:"bytes,3,opt,name=oldIdentity,proto3" json:"oldIdentity,omitempty"`
	// NewIdentitySignature is the new identity signed by the old one
	NewIdentitySignature []byte `protobuf:"bytes,4,opt,name=newIdentitySignature,proto3" json:"newIdentitySignature,omitempty"`
}

func (*SpaceSignRequest) Descriptor 

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

func (*SpaceSignRequest) GetHeader 

func (m *SpaceSignRequest) GetHeader() []byte

func (*SpaceSignRequest) GetNewIdentitySignature 

func (m *SpaceSignRequest) GetNewIdentitySignature() []byte

func (*SpaceSignRequest) GetOldIdentity 

func (m *SpaceSignRequest) GetOldIdentity() []byte

func (*SpaceSignRequest) GetSpaceId 

func (m *SpaceSignRequest) GetSpaceId() string

func (*SpaceSignRequest) Marshal 

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

func (*SpaceSignRequest) MarshalTo 

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

func (*SpaceSignRequest) MarshalToSizedBuffer 

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

func (*SpaceSignRequest) ProtoMessage 

func (*SpaceSignRequest) ProtoMessage()

func (*SpaceSignRequest) Reset 

func (m *SpaceSignRequest) Reset()

func (*SpaceSignRequest) Size 

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

func (*SpaceSignRequest) String 

func (m *SpaceSignRequest) String() string

func (*SpaceSignRequest) Unmarshal 

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

func (*SpaceSignRequest) XXX_DiscardUnknown 

func (m *SpaceSignRequest) XXX_DiscardUnknown()

func (*SpaceSignRequest) XXX_Marshal 

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

func (*SpaceSignRequest) XXX_Merge 

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

func (*SpaceSignRequest) XXX_Size 

func (m *SpaceSignRequest) XXX_Size() int

func (*SpaceSignRequest) XXX_Unmarshal 

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

type SpaceSignResponse 

type SpaceSignResponse struct {
	Receipt *SpaceReceiptWithSignature `protobuf:"bytes,1,opt,name=receipt,proto3" json:"receipt,omitempty"`
}

func (*SpaceSignResponse) Descriptor 

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

func (*SpaceSignResponse) GetReceipt 

func (m *SpaceSignResponse) GetReceipt() *SpaceReceiptWithSignature

func (*SpaceSignResponse) Marshal 

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

func (*SpaceSignResponse) MarshalTo 

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

func (*SpaceSignResponse) MarshalToSizedBuffer 

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

func (*SpaceSignResponse) ProtoMessage 

func (*SpaceSignResponse) ProtoMessage()

func (*SpaceSignResponse) Reset 

func (m *SpaceSignResponse) Reset()

func (*SpaceSignResponse) Size 

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

func (*SpaceSignResponse) String 

func (m *SpaceSignResponse) String() string

func (*SpaceSignResponse) Unmarshal 

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

func (*SpaceSignResponse) XXX_DiscardUnknown 

func (m *SpaceSignResponse) XXX_DiscardUnknown()

func (*SpaceSignResponse) XXX_Marshal 

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

func (*SpaceSignResponse) XXX_Merge 

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

func (*SpaceSignResponse) XXX_Size 

func (m *SpaceSignResponse) XXX_Size() int

func (*SpaceSignResponse) XXX_Unmarshal 

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

type SpaceStatus 

type SpaceStatus int32
const (
	SpaceStatus_SpaceStatusCreated         SpaceStatus = 0
	SpaceStatus_SpaceStatusPendingDeletion SpaceStatus = 1
	SpaceStatus_SpaceStatusDeletionStarted SpaceStatus = 2
	SpaceStatus_SpaceStatusDeleted         SpaceStatus = 3
)

func (SpaceStatus) EnumDescriptor 

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

func (SpaceStatus) String 

func (x SpaceStatus) String() string

type SpaceStatusChangeRequest 

type SpaceStatusChangeRequest struct {
	SpaceId               string `protobuf:"bytes,1,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
	DeletionChangeId      string `protobuf:"bytes,2,opt,name=deletionChangeId,proto3" json:"deletionChangeId,omitempty"`
	DeletionChangePayload []byte `protobuf:"bytes,3,opt,name=deletionChangePayload,proto3" json:"deletionChangePayload,omitempty"`
}

SpaceStatusChangeRequest contains the deletionChange if we want to delete space, or it is empty otherwise

func (*SpaceStatusChangeRequest) Descriptor 

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

func (*SpaceStatusChangeRequest) GetDeletionChangeId 

func (m *SpaceStatusChangeRequest) GetDeletionChangeId() string

func (*SpaceStatusChangeRequest) GetDeletionChangePayload 

func (m *SpaceStatusChangeRequest) GetDeletionChangePayload() []byte

func (*SpaceStatusChangeRequest) GetSpaceId 

func (m *SpaceStatusChangeRequest) GetSpaceId() string

func (*SpaceStatusChangeRequest) Marshal 

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

func (*SpaceStatusChangeRequest) MarshalTo 

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

func (*SpaceStatusChangeRequest) MarshalToSizedBuffer 

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

func (*SpaceStatusChangeRequest) ProtoMessage 

func (*SpaceStatusChangeRequest) ProtoMessage()

func (*SpaceStatusChangeRequest) Reset 

func (m *SpaceStatusChangeRequest) Reset()

func (*SpaceStatusChangeRequest) Size 

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

func (*SpaceStatusChangeRequest) String 

func (m *SpaceStatusChangeRequest) String() string

func (*SpaceStatusChangeRequest) Unmarshal 

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

func (*SpaceStatusChangeRequest) XXX_DiscardUnknown 

func (m *SpaceStatusChangeRequest) XXX_DiscardUnknown()

func (*SpaceStatusChangeRequest) XXX_Marshal 

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

func (*SpaceStatusChangeRequest) XXX_Merge 

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

func (*SpaceStatusChangeRequest) XXX_Size 

func (m *SpaceStatusChangeRequest) XXX_Size() int

func (*SpaceStatusChangeRequest) XXX_Unmarshal 

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

type SpaceStatusChangeResponse 

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

SpaceStatusChangeResponse contains changed status of space

func (*SpaceStatusChangeResponse) Descriptor 

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

func (*SpaceStatusChangeResponse) GetPayload 

func (m *SpaceStatusChangeResponse) GetPayload() *SpaceStatusPayload

func (*SpaceStatusChangeResponse) Marshal 

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

func (*SpaceStatusChangeResponse) MarshalTo 

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

func (*SpaceStatusChangeResponse) MarshalToSizedBuffer 

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

func (*SpaceStatusChangeResponse) ProtoMessage 

func (*SpaceStatusChangeResponse) ProtoMessage()

func (*SpaceStatusChangeResponse) Reset 

func (m *SpaceStatusChangeResponse) Reset()

func (*SpaceStatusChangeResponse) Size 

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

func (*SpaceStatusChangeResponse) String 

func (m *SpaceStatusChangeResponse) String() string

func (*SpaceStatusChangeResponse) Unmarshal 

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

func (*SpaceStatusChangeResponse) XXX_DiscardUnknown 

func (m *SpaceStatusChangeResponse) XXX_DiscardUnknown()

func (*SpaceStatusChangeResponse) XXX_Marshal 

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

func (*SpaceStatusChangeResponse) XXX_Merge 

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

func (*SpaceStatusChangeResponse) XXX_Size 

func (m *SpaceStatusChangeResponse) XXX_Size() int

func (*SpaceStatusChangeResponse) XXX_Unmarshal 

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

type SpaceStatusCheckRequest 

type SpaceStatusCheckRequest struct {
	SpaceId string `protobuf:"bytes,1,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
}

SpaceStatusCheckRequest contains the spaceId of requested space

func (*SpaceStatusCheckRequest) Descriptor 

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

func (*SpaceStatusCheckRequest) GetSpaceId 

func (m *SpaceStatusCheckRequest) GetSpaceId() string

func (*SpaceStatusCheckRequest) Marshal 

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

func (*SpaceStatusCheckRequest) MarshalTo 

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

func (*SpaceStatusCheckRequest) MarshalToSizedBuffer 

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

func (*SpaceStatusCheckRequest) ProtoMessage 

func (*SpaceStatusCheckRequest) ProtoMessage()

func (*SpaceStatusCheckRequest) Reset 

func (m *SpaceStatusCheckRequest) Reset()

func (*SpaceStatusCheckRequest) Size 

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

func (*SpaceStatusCheckRequest) String 

func (m *SpaceStatusCheckRequest) String() string

func (*SpaceStatusCheckRequest) Unmarshal 

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

func (*SpaceStatusCheckRequest) XXX_DiscardUnknown 

func (m *SpaceStatusCheckRequest) XXX_DiscardUnknown()

func (*SpaceStatusCheckRequest) XXX_Marshal 

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

func (*SpaceStatusCheckRequest) XXX_Merge 

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

func (*SpaceStatusCheckRequest) XXX_Size 

func (m *SpaceStatusCheckRequest) XXX_Size() int

func (*SpaceStatusCheckRequest) XXX_Unmarshal 

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

type SpaceStatusCheckResponse 

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

SpaceStatusCheckResponse contains the current status of space

func (*SpaceStatusCheckResponse) Descriptor 

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

func (*SpaceStatusCheckResponse) GetPayload 

func (m *SpaceStatusCheckResponse) GetPayload() *SpaceStatusPayload

func (*SpaceStatusCheckResponse) Marshal 

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

func (*SpaceStatusCheckResponse) MarshalTo 

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

func (*SpaceStatusCheckResponse) MarshalToSizedBuffer 

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

func (*SpaceStatusCheckResponse) ProtoMessage 

func (*SpaceStatusCheckResponse) ProtoMessage()

func (*SpaceStatusCheckResponse) Reset 

func (m *SpaceStatusCheckResponse) Reset()

func (*SpaceStatusCheckResponse) Size 

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

func (*SpaceStatusCheckResponse) String 

func (m *SpaceStatusCheckResponse) String() string

func (*SpaceStatusCheckResponse) Unmarshal 

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

func (*SpaceStatusCheckResponse) XXX_DiscardUnknown 

func (m *SpaceStatusCheckResponse) XXX_DiscardUnknown()

func (*SpaceStatusCheckResponse) XXX_Marshal 

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

func (*SpaceStatusCheckResponse) XXX_Merge 

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

func (*SpaceStatusCheckResponse) XXX_Size 

func (m *SpaceStatusCheckResponse) XXX_Size() int

func (*SpaceStatusCheckResponse) XXX_Unmarshal 

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

type SpaceStatusPayload 

type SpaceStatusPayload struct {
	Status            SpaceStatus `protobuf:"varint,1,opt,name=status,proto3,enum=coordinator.SpaceStatus" json:"status,omitempty"`
	DeletionTimestamp int64       `protobuf:"varint,2,opt,name=deletionTimestamp,proto3" json:"deletionTimestamp,omitempty"`
}

func (*SpaceStatusPayload) Descriptor 

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

func (*SpaceStatusPayload) GetDeletionTimestamp 

func (m *SpaceStatusPayload) GetDeletionTimestamp() int64

func (*SpaceStatusPayload) GetStatus 

func (m *SpaceStatusPayload) GetStatus() SpaceStatus

func (*SpaceStatusPayload) Marshal 

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

func (*SpaceStatusPayload) MarshalTo 

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

func (*SpaceStatusPayload) MarshalToSizedBuffer 

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

func (*SpaceStatusPayload) ProtoMessage 

func (*SpaceStatusPayload) ProtoMessage()

func (*SpaceStatusPayload) Reset 

func (m *SpaceStatusPayload) Reset()

func (*SpaceStatusPayload) Size 

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

func (*SpaceStatusPayload) String 

func (m *SpaceStatusPayload) String() string

func (*SpaceStatusPayload) Unmarshal 

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

func (*SpaceStatusPayload) XXX_DiscardUnknown 

func (m *SpaceStatusPayload) XXX_DiscardUnknown()

func (*SpaceStatusPayload) XXX_Marshal 

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

func (*SpaceStatusPayload) XXX_Merge 

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

func (*SpaceStatusPayload) XXX_Size 

func (m *SpaceStatusPayload) XXX_Size() int

func (*SpaceStatusPayload) XXX_Unmarshal 

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

Source Files

View all Source files

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.