coordinatorproto

package
v0.3.14 Latest Latest
Warning

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

 Go to latest Published: Dec 5, 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))
	ErrSpaceLimitReached    = errGroup.Register(errors.New("space limit reached"), uint64(ErrorCodes_SpaceLimitReached))
	ErrAccountIsDeleted     = errGroup.Register(errors.New("account is deleted"), uint64(ErrorCodes_AccountDeleted))
)
View Source 
var DeletionLogRecordStatus_name = map[int32]string{
	0: "Ok",
	1: "RemovePrepare",
	2: "Remove",
}
View Source 
var DeletionLogRecordStatus_value = map[string]int32{
	"Ok":            0,
	"RemovePrepare": 1,
	"Remove":        2,
}
View Source 
var DeletionPayloadType_name = map[int32]string{
	0: "Tree",
	1: "Confirm",
	2: "Account",
}
View Source 
var DeletionPayloadType_value = map[string]int32{
	"Tree":    0,
	"Confirm": 1,
	"Account": 2,
}
View Source 
var ErrorCodes_name = map[int32]string{
	0:   "Unexpected",
	1:   "SpaceDeleted",
	2:   "SpaceDeletionPending",
	3:   "SpaceCreated",
	4:   "SpaceNotExists",
	5:   "SpaceLimitReached",
	6:   "AccountDeleted",
	300: "ErrorOffset",
}
View Source 
var ErrorCodes_value = map[string]int32{
	"Unexpected":           0,
	"SpaceDeleted":         1,
	"SpaceDeletionPending": 2,
	"SpaceCreated":         3,
	"SpaceNotExists":       4,
	"SpaceLimitReached":    5,
	"AccountDeleted":       6,
	"ErrorOffset":          300,
}
View Source 
var NodeType_name = map[int32]string{
	0: "TreeAPI",
	1: "FileAPI",
	2: "CoordinatorAPI",
	3: "ConsensusAPI",
	4: "NamingNodeAPI",
	5: "PaymentProcessingAPI",
}
View Source 
var NodeType_value = map[string]int32{
	"TreeAPI":              0,
	"FileAPI":              1,
	"CoordinatorAPI":       2,
	"ConsensusAPI":         3,
	"NamingNodeAPI":        4,
	"PaymentProcessingAPI": 5,
}
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

func ValidateAccountDeleteConfirmation added in v0.3.4 

func ValidateAccountDeleteConfirmation(pubKey crypto.PubKey, spaceId, networkId string, deleteConfirm *DeletionConfirmPayloadWithSignature) (err error)

func ValidateDeleteConfirmation added in v0.3.0 

func ValidateDeleteConfirmation(pubKey crypto.PubKey, spaceId, networkId string, deleteConfirm *DeletionConfirmPayloadWithSignature) (err error)

Types

type AccountDeleteRequest added in v0.3.4 

type AccountDeleteRequest struct {
	DeletionPayloadId string `protobuf:"bytes,1,opt,name=deletionPayloadId,proto3" json:"deletionPayloadId,omitempty"`
	DeletionPayload   []byte `protobuf:"bytes,2,opt,name=deletionPayload,proto3" json:"deletionPayload,omitempty"`
}

AccountDeleteRequest contains payload for account deletion

func (*AccountDeleteRequest) Descriptor added in v0.3.4 

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

func (*AccountDeleteRequest) GetDeletionPayload added in v0.3.4 

func (m *AccountDeleteRequest) GetDeletionPayload() []byte

func (*AccountDeleteRequest) GetDeletionPayloadId added in v0.3.4 

func (m *AccountDeleteRequest) GetDeletionPayloadId() string

func (*AccountDeleteRequest) Marshal added in v0.3.4 

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

func (*AccountDeleteRequest) MarshalTo added in v0.3.4 

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

func (*AccountDeleteRequest) MarshalToSizedBuffer added in v0.3.4 

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

func (*AccountDeleteRequest) ProtoMessage added in v0.3.4 

func (*AccountDeleteRequest) ProtoMessage()

func (*AccountDeleteRequest) Reset added in v0.3.4 

func (m *AccountDeleteRequest) Reset()

func (*AccountDeleteRequest) Size added in v0.3.4 

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

func (*AccountDeleteRequest) String added in v0.3.4 

func (m *AccountDeleteRequest) String() string

func (*AccountDeleteRequest) Unmarshal added in v0.3.4 

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

func (*AccountDeleteRequest) XXX_DiscardUnknown added in v0.3.4 

func (m *AccountDeleteRequest) XXX_DiscardUnknown()

func (*AccountDeleteRequest) XXX_Marshal added in v0.3.4 

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

func (*AccountDeleteRequest) XXX_Merge added in v0.3.4 

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

func (*AccountDeleteRequest) XXX_Size added in v0.3.4 

func (m *AccountDeleteRequest) XXX_Size() int

func (*AccountDeleteRequest) XXX_Unmarshal added in v0.3.4 

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

type AccountDeleteResponse added in v0.3.4 

type AccountDeleteResponse struct {
	ToBeDeletedTimestamp int64 `protobuf:"varint,1,opt,name=toBeDeletedTimestamp,proto3" json:"toBeDeletedTimestamp,omitempty"`
}

AccountDeleteResponse contains timestamp when the account is finally deleted

func (*AccountDeleteResponse) Descriptor added in v0.3.4 

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

func (*AccountDeleteResponse) GetToBeDeletedTimestamp added in v0.3.4 

func (m *AccountDeleteResponse) GetToBeDeletedTimestamp() int64

func (*AccountDeleteResponse) Marshal added in v0.3.4 

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

func (*AccountDeleteResponse) MarshalTo added in v0.3.4 

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

func (*AccountDeleteResponse) MarshalToSizedBuffer added in v0.3.4 

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

func (*AccountDeleteResponse) ProtoMessage added in v0.3.4 

func (*AccountDeleteResponse) ProtoMessage()

func (*AccountDeleteResponse) Reset added in v0.3.4 

func (m *AccountDeleteResponse) Reset()

func (*AccountDeleteResponse) Size added in v0.3.4 

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

func (*AccountDeleteResponse) String added in v0.3.4 

func (m *AccountDeleteResponse) String() string

func (*AccountDeleteResponse) Unmarshal added in v0.3.4 

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

func (*AccountDeleteResponse) XXX_DiscardUnknown added in v0.3.4 

func (m *AccountDeleteResponse) XXX_DiscardUnknown()

func (*AccountDeleteResponse) XXX_Marshal added in v0.3.4 

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

func (*AccountDeleteResponse) XXX_Merge added in v0.3.4 

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

func (*AccountDeleteResponse) XXX_Size added in v0.3.4 

func (m *AccountDeleteResponse) XXX_Size() int

func (*AccountDeleteResponse) XXX_Unmarshal added in v0.3.4 

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

type AccountDeletionConfirmPayload added in v0.3.4 

type AccountDeletionConfirmPayload struct {
	// PeerId of receipt requester
	PeerId string `protobuf:"bytes,1,opt,name=peerId,proto3" json:"peerId,omitempty"`
	// AccountIdentity is an identity of a space owner
	AccountIdentity []byte `protobuf:"bytes,2,opt,name=accountIdentity,proto3" json:"accountIdentity,omitempty"`
	// NetworkId is the id of a network where the deletion was requested
	NetworkId string `protobuf:"bytes,3,opt,name=networkId,proto3" json:"networkId,omitempty"`
	// Timestamp is a timestamp when the deletion was requested
	Timestamp int64 `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

AccountDeletionConfirmPayload contains payload for deletion confirmation

func (*AccountDeletionConfirmPayload) Descriptor added in v0.3.4 

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

func (*AccountDeletionConfirmPayload) GetAccountIdentity added in v0.3.4 

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

func (*AccountDeletionConfirmPayload) GetNetworkId added in v0.3.4 

func (m *AccountDeletionConfirmPayload) GetNetworkId() string

func (*AccountDeletionConfirmPayload) GetPeerId added in v0.3.4 

func (m *AccountDeletionConfirmPayload) GetPeerId() string

func (*AccountDeletionConfirmPayload) GetTimestamp added in v0.3.4 

func (m *AccountDeletionConfirmPayload) GetTimestamp() int64

func (*AccountDeletionConfirmPayload) Marshal added in v0.3.4 

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

func (*AccountDeletionConfirmPayload) MarshalTo added in v0.3.4 

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

func (*AccountDeletionConfirmPayload) MarshalToSizedBuffer added in v0.3.4 

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

func (*AccountDeletionConfirmPayload) ProtoMessage added in v0.3.4 

func (*AccountDeletionConfirmPayload) ProtoMessage()

func (*AccountDeletionConfirmPayload) Reset added in v0.3.4 

func (m *AccountDeletionConfirmPayload) Reset()

func (*AccountDeletionConfirmPayload) Size added in v0.3.4 

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

func (*AccountDeletionConfirmPayload) String added in v0.3.4 

func (m *AccountDeletionConfirmPayload) String() string

func (*AccountDeletionConfirmPayload) Unmarshal added in v0.3.4 

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

func (*AccountDeletionConfirmPayload) XXX_DiscardUnknown added in v0.3.4 

func (m *AccountDeletionConfirmPayload) XXX_DiscardUnknown()

func (*AccountDeletionConfirmPayload) XXX_Marshal added in v0.3.4 

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

func (*AccountDeletionConfirmPayload) XXX_Merge added in v0.3.4 

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

func (*AccountDeletionConfirmPayload) XXX_Size added in v0.3.4 

func (m *AccountDeletionConfirmPayload) XXX_Size() int

func (*AccountDeletionConfirmPayload) XXX_Unmarshal added in v0.3.4 

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

type AccountRevertDeletionRequest added in v0.3.4 

type AccountRevertDeletionRequest struct {
}

AccountRevertDeletionRequest is a request to revert an account deletion

func (*AccountRevertDeletionRequest) Descriptor added in v0.3.4 

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

func (*AccountRevertDeletionRequest) Marshal added in v0.3.4 

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

func (*AccountRevertDeletionRequest) MarshalTo added in v0.3.4 

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

func (*AccountRevertDeletionRequest) MarshalToSizedBuffer added in v0.3.4 

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

func (*AccountRevertDeletionRequest) ProtoMessage added in v0.3.4 

func (*AccountRevertDeletionRequest) ProtoMessage()

func (*AccountRevertDeletionRequest) Reset added in v0.3.4 

func (m *AccountRevertDeletionRequest) Reset()

func (*AccountRevertDeletionRequest) Size added in v0.3.4 

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

func (*AccountRevertDeletionRequest) String added in v0.3.4 

func (m *AccountRevertDeletionRequest) String() string

func (*AccountRevertDeletionRequest) Unmarshal added in v0.3.4 

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

func (*AccountRevertDeletionRequest) XXX_DiscardUnknown added in v0.3.4 

func (m *AccountRevertDeletionRequest) XXX_DiscardUnknown()

func (*AccountRevertDeletionRequest) XXX_Marshal added in v0.3.4 

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

func (*AccountRevertDeletionRequest) XXX_Merge added in v0.3.4 

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

func (*AccountRevertDeletionRequest) XXX_Size added in v0.3.4 

func (m *AccountRevertDeletionRequest) XXX_Size() int

func (*AccountRevertDeletionRequest) XXX_Unmarshal added in v0.3.4 

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

type AccountRevertDeletionResponse added in v0.3.4 

type AccountRevertDeletionResponse struct {
}

AccountRevertDeletionResponse is an empty response confirming that the deletion is reverted

func (*AccountRevertDeletionResponse) Descriptor added in v0.3.4 

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

func (*AccountRevertDeletionResponse) Marshal added in v0.3.4 

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

func (*AccountRevertDeletionResponse) MarshalTo added in v0.3.4 

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

func (*AccountRevertDeletionResponse) MarshalToSizedBuffer added in v0.3.4 

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

func (*AccountRevertDeletionResponse) ProtoMessage added in v0.3.4 

func (*AccountRevertDeletionResponse) ProtoMessage()

func (*AccountRevertDeletionResponse) Reset added in v0.3.4 

func (m *AccountRevertDeletionResponse) Reset()

func (*AccountRevertDeletionResponse) Size added in v0.3.4 

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

func (*AccountRevertDeletionResponse) String added in v0.3.4 

func (m *AccountRevertDeletionResponse) String() string

func (*AccountRevertDeletionResponse) Unmarshal added in v0.3.4 

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

func (*AccountRevertDeletionResponse) XXX_DiscardUnknown added in v0.3.4 

func (m *AccountRevertDeletionResponse) XXX_DiscardUnknown()

func (*AccountRevertDeletionResponse) XXX_Marshal added in v0.3.4 

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

func (*AccountRevertDeletionResponse) XXX_Merge added in v0.3.4 

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

func (*AccountRevertDeletionResponse) XXX_Size added in v0.3.4 

func (m *AccountRevertDeletionResponse) XXX_Size() int

func (*AccountRevertDeletionResponse) XXX_Unmarshal added in v0.3.4 

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

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)
	SpaceStatusCheckMany(ctx context.Context, in *SpaceStatusCheckManyRequest) (*SpaceStatusCheckManyResponse, error)
	SpaceStatusChange(ctx context.Context, in *SpaceStatusChangeRequest) (*SpaceStatusChangeResponse, error)
	NetworkConfiguration(ctx context.Context, in *NetworkConfigurationRequest) (*NetworkConfigurationResponse, error)
	DeletionLog(ctx context.Context, in *DeletionLogRequest) (*DeletionLogResponse, error)
	SpaceDelete(ctx context.Context, in *SpaceDeleteRequest) (*SpaceDeleteResponse, error)
	AccountDelete(ctx context.Context, in *AccountDeleteRequest) (*AccountDeleteResponse, error)
	AccountRevertDeletion(ctx context.Context, in *AccountRevertDeletionRequest) (*AccountRevertDeletionResponse, 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)
	SpaceStatusCheckMany(context.Context, *SpaceStatusCheckManyRequest) (*SpaceStatusCheckManyResponse, error)
	SpaceStatusChange(context.Context, *SpaceStatusChangeRequest) (*SpaceStatusChangeResponse, error)
	NetworkConfiguration(context.Context, *NetworkConfigurationRequest) (*NetworkConfigurationResponse, error)
	DeletionLog(context.Context, *DeletionLogRequest) (*DeletionLogResponse, error)
	SpaceDelete(context.Context, *SpaceDeleteRequest) (*SpaceDeleteResponse, error)
	AccountDelete(context.Context, *AccountDeleteRequest) (*AccountDeleteResponse, error)
	AccountRevertDeletion(context.Context, *AccountRevertDeletionRequest) (*AccountRevertDeletionResponse, error)
}

type DRPCCoordinatorUnimplementedServer 

type DRPCCoordinatorUnimplementedServer struct{}

func (*DRPCCoordinatorUnimplementedServer) AccountDelete added in v0.3.4 

func (s *DRPCCoordinatorUnimplementedServer) AccountDelete(context.Context, *AccountDeleteRequest) (*AccountDeleteResponse, error)

func (*DRPCCoordinatorUnimplementedServer) AccountRevertDeletion added in v0.3.4 

func (s *DRPCCoordinatorUnimplementedServer) AccountRevertDeletion(context.Context, *AccountRevertDeletionRequest) (*AccountRevertDeletionResponse, error)

func (*DRPCCoordinatorUnimplementedServer) DeletionLog added in v0.3.0 

func (s *DRPCCoordinatorUnimplementedServer) DeletionLog(context.Context, *DeletionLogRequest) (*DeletionLogResponse, error)

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) SpaceDelete added in v0.3.4 

func (s *DRPCCoordinatorUnimplementedServer) SpaceDelete(context.Context, *SpaceDeleteRequest) (*SpaceDeleteResponse, 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)

func (*DRPCCoordinatorUnimplementedServer) SpaceStatusCheckMany added in v0.3.0 

func (s *DRPCCoordinatorUnimplementedServer) SpaceStatusCheckMany(context.Context, *SpaceStatusCheckManyRequest) (*SpaceStatusCheckManyResponse, error)

type DRPCCoordinator_AccountDeleteStream added in v0.3.4 

type DRPCCoordinator_AccountDeleteStream interface {
	drpc.Stream
	SendAndClose(*AccountDeleteResponse) error
}

type DRPCCoordinator_AccountRevertDeletionStream added in v0.3.4 

type DRPCCoordinator_AccountRevertDeletionStream interface {
	drpc.Stream
	SendAndClose(*AccountRevertDeletionResponse) error
}

type DRPCCoordinator_DeletionLogStream added in v0.3.0 

type DRPCCoordinator_DeletionLogStream interface {
	drpc.Stream
	SendAndClose(*DeletionLogResponse) 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_SpaceDeleteStream added in v0.3.4 

type DRPCCoordinator_SpaceDeleteStream interface {
	drpc.Stream
	SendAndClose(*SpaceDeleteResponse) 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_SpaceStatusCheckManyStream added in v0.3.0 

type DRPCCoordinator_SpaceStatusCheckManyStream interface {
	drpc.Stream
	SendAndClose(*SpaceStatusCheckManyResponse) error
}

type DRPCCoordinator_SpaceStatusCheckStream 

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

type DeletionConfirmPayload added in v0.3.0 

type DeletionConfirmPayload 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 deletion was requested
	NetworkId string `protobuf:"bytes,4,opt,name=networkId,proto3" json:"networkId,omitempty"`
	// Timestamp is a timestamp when the deletion was requested
	Timestamp int64 `protobuf:"varint,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

DeletionConfirmPayload contains payload for deletion confirmation

func (*DeletionConfirmPayload) Descriptor added in v0.3.0 

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

func (*DeletionConfirmPayload) GetAccountIdentity added in v0.3.0 

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

func (*DeletionConfirmPayload) GetNetworkId added in v0.3.0 

func (m *DeletionConfirmPayload) GetNetworkId() string

func (*DeletionConfirmPayload) GetPeerId added in v0.3.0 

func (m *DeletionConfirmPayload) GetPeerId() string

func (*DeletionConfirmPayload) GetSpaceId added in v0.3.0 

func (m *DeletionConfirmPayload) GetSpaceId() string

func (*DeletionConfirmPayload) GetTimestamp added in v0.3.0 

func (m *DeletionConfirmPayload) GetTimestamp() int64

func (*DeletionConfirmPayload) Marshal added in v0.3.0 

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

func (*DeletionConfirmPayload) MarshalTo added in v0.3.0 

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

func (*DeletionConfirmPayload) MarshalToSizedBuffer added in v0.3.0 

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

func (*DeletionConfirmPayload) ProtoMessage added in v0.3.0 

func (*DeletionConfirmPayload) ProtoMessage()

func (*DeletionConfirmPayload) Reset added in v0.3.0 

func (m *DeletionConfirmPayload) Reset()

func (*DeletionConfirmPayload) Size added in v0.3.0 

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

func (*DeletionConfirmPayload) String added in v0.3.0 

func (m *DeletionConfirmPayload) String() string

func (*DeletionConfirmPayload) Unmarshal added in v0.3.0 

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

func (*DeletionConfirmPayload) XXX_DiscardUnknown added in v0.3.0 

func (m *DeletionConfirmPayload) XXX_DiscardUnknown()

func (*DeletionConfirmPayload) XXX_Marshal added in v0.3.0 

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

func (*DeletionConfirmPayload) XXX_Merge added in v0.3.0 

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

func (*DeletionConfirmPayload) XXX_Size added in v0.3.0 

func (m *DeletionConfirmPayload) XXX_Size() int

func (*DeletionConfirmPayload) XXX_Unmarshal added in v0.3.0 

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

type DeletionConfirmPayloadWithSignature added in v0.3.0 

type DeletionConfirmPayloadWithSignature struct {
	DeletionPayload []byte `protobuf:"bytes,1,opt,name=deletionPayload,proto3" json:"deletionPayload,omitempty"`
	Signature       []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
}

DeletionConfirmPayloadWithSignature contains protobuf encoded deletion payload and its signature

func PrepareAccountDeleteConfirmation added in v0.3.4 

func PrepareAccountDeleteConfirmation(privKey crypto.PrivKey, peerId, networkId string) (signed *DeletionConfirmPayloadWithSignature, err error)

func PrepareDeleteConfirmation added in v0.3.0 

func PrepareDeleteConfirmation(privKey crypto.PrivKey, spaceId, peerId, networkId string) (signed *DeletionConfirmPayloadWithSignature, err error)

func (*DeletionConfirmPayloadWithSignature) Descriptor added in v0.3.0 

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

func (*DeletionConfirmPayloadWithSignature) GetDeletionPayload added in v0.3.0 

func (m *DeletionConfirmPayloadWithSignature) GetDeletionPayload() []byte

func (*DeletionConfirmPayloadWithSignature) GetSignature added in v0.3.0 

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

func (*DeletionConfirmPayloadWithSignature) Marshal added in v0.3.0 

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

func (*DeletionConfirmPayloadWithSignature) MarshalTo added in v0.3.0 

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

func (*DeletionConfirmPayloadWithSignature) MarshalToSizedBuffer added in v0.3.0 

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

func (*DeletionConfirmPayloadWithSignature) ProtoMessage added in v0.3.0 

func (*DeletionConfirmPayloadWithSignature) ProtoMessage()

func (*DeletionConfirmPayloadWithSignature) Reset added in v0.3.0 

func (m *DeletionConfirmPayloadWithSignature) Reset()

func (*DeletionConfirmPayloadWithSignature) Size added in v0.3.0 

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

func (*DeletionConfirmPayloadWithSignature) String added in v0.3.0 

func (m *DeletionConfirmPayloadWithSignature) String() string

func (*DeletionConfirmPayloadWithSignature) Unmarshal added in v0.3.0 

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

func (*DeletionConfirmPayloadWithSignature) XXX_DiscardUnknown added in v0.3.0 

func (m *DeletionConfirmPayloadWithSignature) XXX_DiscardUnknown()

func (*DeletionConfirmPayloadWithSignature) XXX_Marshal added in v0.3.0 

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

func (*DeletionConfirmPayloadWithSignature) XXX_Merge added in v0.3.0 

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

func (*DeletionConfirmPayloadWithSignature) XXX_Size added in v0.3.0 

func (m *DeletionConfirmPayloadWithSignature) XXX_Size() int

func (*DeletionConfirmPayloadWithSignature) XXX_Unmarshal added in v0.3.0 

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

type DeletionLogRecord added in v0.3.0 

type DeletionLogRecord struct {
	// Id is a record id
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// SpaceId is a space identifier
	SpaceId string `protobuf:"bytes,2,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
	// DeletionLogRecordStatus is a space status
	Status DeletionLogRecordStatus `protobuf:"varint,3,opt,name=status,proto3,enum=coordinator.DeletionLogRecordStatus" json:"status,omitempty"`
	// Timestamp is a unixtimestamp of record creation
	Timestamp int64 `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// FileGroup is a key of group for file nodes
	FileGroup string `protobuf:"bytes,5,opt,name=fileGroup,proto3" json:"fileGroup,omitempty"`
}

func (*DeletionLogRecord) Descriptor added in v0.3.0 

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

func (*DeletionLogRecord) GetFileGroup added in v0.3.7 

func (m *DeletionLogRecord) GetFileGroup() string

func (*DeletionLogRecord) GetId added in v0.3.0 

func (m *DeletionLogRecord) GetId() string

func (*DeletionLogRecord) GetSpaceId added in v0.3.0 

func (m *DeletionLogRecord) GetSpaceId() string

func (*DeletionLogRecord) GetStatus added in v0.3.0 

func (m *DeletionLogRecord) GetStatus() DeletionLogRecordStatus

func (*DeletionLogRecord) GetTimestamp added in v0.3.0 

func (m *DeletionLogRecord) GetTimestamp() int64

func (*DeletionLogRecord) Marshal added in v0.3.0 

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

func (*DeletionLogRecord) MarshalTo added in v0.3.0 

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

func (*DeletionLogRecord) MarshalToSizedBuffer added in v0.3.0 

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

func (*DeletionLogRecord) ProtoMessage added in v0.3.0 

func (*DeletionLogRecord) ProtoMessage()

func (*DeletionLogRecord) Reset added in v0.3.0 

func (m *DeletionLogRecord) Reset()

func (*DeletionLogRecord) Size added in v0.3.0 

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

func (*DeletionLogRecord) String added in v0.3.0 

func (m *DeletionLogRecord) String() string

func (*DeletionLogRecord) Unmarshal added in v0.3.0 

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

func (*DeletionLogRecord) XXX_DiscardUnknown added in v0.3.0 

func (m *DeletionLogRecord) XXX_DiscardUnknown()

func (*DeletionLogRecord) XXX_Marshal added in v0.3.0 

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

func (*DeletionLogRecord) XXX_Merge added in v0.3.0 

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

func (*DeletionLogRecord) XXX_Size added in v0.3.0 

func (m *DeletionLogRecord) XXX_Size() int

func (*DeletionLogRecord) XXX_Unmarshal added in v0.3.0 

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

type DeletionLogRecordStatus added in v0.3.0 

type DeletionLogRecordStatus int32
const (
	// Ok means space should operate in a normal
	DeletionLogRecordStatus_Ok DeletionLogRecordStatus = 0
	// RemovePrepare means space prepared to remove, sync should be disabled
	DeletionLogRecordStatus_RemovePrepare DeletionLogRecordStatus = 1
	// Remove means space should be removed
	DeletionLogRecordStatus_Remove DeletionLogRecordStatus = 2
)

func (DeletionLogRecordStatus) EnumDescriptor added in v0.3.0 

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

func (DeletionLogRecordStatus) String added in v0.3.0 

func (x DeletionLogRecordStatus) String() string

type DeletionLogRequest added in v0.3.0 

type DeletionLogRequest struct {
	// AfterId is the last known logId to request records after this id. If it is empty will be returned a list from the beginning.
	AfterId string `protobuf:"bytes,1,opt,name=afterId,proto3" json:"afterId,omitempty"`
	// Limit is a desired record count in response
	Limit uint32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
}

func (*DeletionLogRequest) Descriptor added in v0.3.0 

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

func (*DeletionLogRequest) GetAfterId added in v0.3.0 

func (m *DeletionLogRequest) GetAfterId() string

func (*DeletionLogRequest) GetLimit added in v0.3.0 

func (m *DeletionLogRequest) GetLimit() uint32

func (*DeletionLogRequest) Marshal added in v0.3.0 

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

func (*DeletionLogRequest) MarshalTo added in v0.3.0 

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

func (*DeletionLogRequest) MarshalToSizedBuffer added in v0.3.0 

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

func (*DeletionLogRequest) ProtoMessage added in v0.3.0 

func (*DeletionLogRequest) ProtoMessage()

func (*DeletionLogRequest) Reset added in v0.3.0 

func (m *DeletionLogRequest) Reset()

func (*DeletionLogRequest) Size added in v0.3.0 

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

func (*DeletionLogRequest) String added in v0.3.0 

func (m *DeletionLogRequest) String() string

func (*DeletionLogRequest) Unmarshal added in v0.3.0 

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

func (*DeletionLogRequest) XXX_DiscardUnknown added in v0.3.0 

func (m *DeletionLogRequest) XXX_DiscardUnknown()

func (*DeletionLogRequest) XXX_Marshal added in v0.3.0 

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

func (*DeletionLogRequest) XXX_Merge added in v0.3.0 

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

func (*DeletionLogRequest) XXX_Size added in v0.3.0 

func (m *DeletionLogRequest) XXX_Size() int

func (*DeletionLogRequest) XXX_Unmarshal added in v0.3.0 

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

type DeletionLogResponse added in v0.3.0 

type DeletionLogResponse struct {
	// DeletionLogRecord list of records, if there are no new records will be empty
	Records []*DeletionLogRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// HasMore indicates if there are records left
	HasMore bool `protobuf:"varint,2,opt,name=hasMore,proto3" json:"hasMore,omitempty"`
}

func (*DeletionLogResponse) Descriptor added in v0.3.0 

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

func (*DeletionLogResponse) GetHasMore added in v0.3.0 

func (m *DeletionLogResponse) GetHasMore() bool

func (*DeletionLogResponse) GetRecords added in v0.3.0 

func (m *DeletionLogResponse) GetRecords() []*DeletionLogRecord

func (*DeletionLogResponse) Marshal added in v0.3.0 

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

func (*DeletionLogResponse) MarshalTo added in v0.3.0 

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

func (*DeletionLogResponse) MarshalToSizedBuffer added in v0.3.0 

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

func (*DeletionLogResponse) ProtoMessage added in v0.3.0 

func (*DeletionLogResponse) ProtoMessage()

func (*DeletionLogResponse) Reset added in v0.3.0 

func (m *DeletionLogResponse) Reset()

func (*DeletionLogResponse) Size added in v0.3.0 

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

func (*DeletionLogResponse) String added in v0.3.0 

func (m *DeletionLogResponse) String() string

func (*DeletionLogResponse) Unmarshal added in v0.3.0 

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

func (*DeletionLogResponse) XXX_DiscardUnknown added in v0.3.0 

func (m *DeletionLogResponse) XXX_DiscardUnknown()

func (*DeletionLogResponse) XXX_Marshal added in v0.3.0 

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

func (*DeletionLogResponse) XXX_Merge added in v0.3.0 

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

func (*DeletionLogResponse) XXX_Size added in v0.3.0 

func (m *DeletionLogResponse) XXX_Size() int

func (*DeletionLogResponse) XXX_Unmarshal added in v0.3.0 

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

type DeletionPayloadType added in v0.3.0 

type DeletionPayloadType int32

DeletionChangeType determines the type of deletion payload 

const (
	DeletionPayloadType_Tree    DeletionPayloadType = 0
	DeletionPayloadType_Confirm DeletionPayloadType = 1
	DeletionPayloadType_Account DeletionPayloadType = 2
)

func (DeletionPayloadType) EnumDescriptor added in v0.3.0 

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

func (DeletionPayloadType) String added in v0.3.0 

func (x DeletionPayloadType) String() string

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_SpaceLimitReached    ErrorCodes = 5
	ErrorCodes_AccountDeleted       ErrorCodes = 6
	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 in bytes
	Limit uint64 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	// StorageKey tells a key that filenode should use to save files
	StorageKey string `protobuf:"bytes,2,opt,name=storageKey,proto3" json:"storageKey,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) GetStorageKey added in v0.3.1 

func (m *FileLimitCheckResponse) GetStorageKey() string

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
	// ConsensusAPI supports consensus api
	NodeType_ConsensusAPI NodeType = 3
	// NamingNodeAPI supports naming node api
	// (see any-ns-node repository)
	NodeType_NamingNodeAPI NodeType = 4
	// PaymentProcessingAPI supports payment processing api
	// (see any-pp-node repository)
	NodeType_PaymentProcessingAPI NodeType = 5
)

func (NodeType) EnumDescriptor 

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

func (NodeType) String 

func (x NodeType) String() string

type SpaceDeleteRequest added in v0.3.4 

type SpaceDeleteRequest struct {
	SpaceId           string `protobuf:"bytes,1,opt,name=spaceId,proto3" json:"spaceId,omitempty"`
	DeletionPayloadId string `protobuf:"bytes,2,opt,name=deletionPayloadId,proto3" json:"deletionPayloadId,omitempty"`
	DeletionPayload   []byte `protobuf:"bytes,3,opt,name=deletionPayload,proto3" json:"deletionPayload,omitempty"`
	DeletionDuration  int64  `protobuf:"varint,4,opt,name=deletionDuration,proto3" json:"deletionDuration,omitempty"`
}

SpaceDeleteRequest contains the deletion confirmation for the space to be deleted

func (*SpaceDeleteRequest) Descriptor added in v0.3.4 

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

func (*SpaceDeleteRequest) GetDeletionDuration added in v0.3.4 

func (m *SpaceDeleteRequest) GetDeletionDuration() int64

func (*SpaceDeleteRequest) GetDeletionPayload added in v0.3.4 

func (m *SpaceDeleteRequest) GetDeletionPayload() []byte

func (*SpaceDeleteRequest) GetDeletionPayloadId added in v0.3.4 

func (m *SpaceDeleteRequest) GetDeletionPayloadId() string

func (*SpaceDeleteRequest) GetSpaceId added in v0.3.4 

func (m *SpaceDeleteRequest) GetSpaceId() string

func (*SpaceDeleteRequest) Marshal added in v0.3.4 

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

func (*SpaceDeleteRequest) MarshalTo added in v0.3.4 

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

func (*SpaceDeleteRequest) MarshalToSizedBuffer added in v0.3.4 

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

func (*SpaceDeleteRequest) ProtoMessage added in v0.3.4 

func (*SpaceDeleteRequest) ProtoMessage()

func (*SpaceDeleteRequest) Reset added in v0.3.4 

func (m *SpaceDeleteRequest) Reset()

func (*SpaceDeleteRequest) Size added in v0.3.4 

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

func (*SpaceDeleteRequest) String added in v0.3.4 

func (m *SpaceDeleteRequest) String() string

func (*SpaceDeleteRequest) Unmarshal added in v0.3.4 

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

func (*SpaceDeleteRequest) XXX_DiscardUnknown added in v0.3.4 

func (m *SpaceDeleteRequest) XXX_DiscardUnknown()

func (*SpaceDeleteRequest) XXX_Marshal added in v0.3.4 

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

func (*SpaceDeleteRequest) XXX_Merge added in v0.3.4 

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

func (*SpaceDeleteRequest) XXX_Size added in v0.3.4 

func (m *SpaceDeleteRequest) XXX_Size() int

func (*SpaceDeleteRequest) XXX_Unmarshal added in v0.3.4 

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

type SpaceDeleteResponse added in v0.3.4 

type SpaceDeleteResponse struct {
	ToBeDeletedTimestamp int64 `protobuf:"varint,1,opt,name=toBeDeletedTimestamp,proto3" json:"toBeDeletedTimestamp,omitempty"`
}

SpaceDeleteResponse contains timestamp when the space is finally deleted

func (*SpaceDeleteResponse) Descriptor added in v0.3.4 

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

func (*SpaceDeleteResponse) GetToBeDeletedTimestamp added in v0.3.4 

func (m *SpaceDeleteResponse) GetToBeDeletedTimestamp() int64

func (*SpaceDeleteResponse) Marshal added in v0.3.4 

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

func (*SpaceDeleteResponse) MarshalTo added in v0.3.4 

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

func (*SpaceDeleteResponse) MarshalToSizedBuffer added in v0.3.4 

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

func (*SpaceDeleteResponse) ProtoMessage added in v0.3.4 

func (*SpaceDeleteResponse) ProtoMessage()

func (*SpaceDeleteResponse) Reset added in v0.3.4 

func (m *SpaceDeleteResponse) Reset()

func (*SpaceDeleteResponse) Size added in v0.3.4 

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

func (*SpaceDeleteResponse) String added in v0.3.4 

func (m *SpaceDeleteResponse) String() string

func (*SpaceDeleteResponse) Unmarshal added in v0.3.4 

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

func (*SpaceDeleteResponse) XXX_DiscardUnknown added in v0.3.4 

func (m *SpaceDeleteResponse) XXX_DiscardUnknown()

func (*SpaceDeleteResponse) XXX_Marshal added in v0.3.4 

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

func (*SpaceDeleteResponse) XXX_Merge added in v0.3.4 

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

func (*SpaceDeleteResponse) XXX_Size added in v0.3.4 

func (m *SpaceDeleteResponse) XXX_Size() int

func (*SpaceDeleteResponse) XXX_Unmarshal added in v0.3.4 

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

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"`
	// ForceRequest if true, forces the creating space receipt even if the space is deleted before
	ForceRequest bool `protobuf:"varint,5,opt,name=forceRequest,proto3" json:"forceRequest,omitempty"`
}

func (*SpaceSignRequest) Descriptor 

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

func (*SpaceSignRequest) GetForceRequest added in v0.3.0 

func (m *SpaceSignRequest) GetForceRequest() bool

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"`
	DeletionPayloadId   string              `protobuf:"bytes,2,opt,name=deletionPayloadId,proto3" json:"deletionPayloadId,omitempty"`
	DeletionPayload     []byte              `protobuf:"bytes,3,opt,name=deletionPayload,proto3" json:"deletionPayload,omitempty"`
	DeletionPayloadType DeletionPayloadType `` /* 129-byte string literal not displayed */
}

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) GetDeletionPayload added in v0.3.0 

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

func (*SpaceStatusChangeRequest) GetDeletionPayloadId added in v0.3.0 

func (m *SpaceStatusChangeRequest) GetDeletionPayloadId() string

func (*SpaceStatusChangeRequest) GetDeletionPayloadType added in v0.3.0 

func (m *SpaceStatusChangeRequest) GetDeletionPayloadType() DeletionPayloadType

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

type SpaceStatusCheckManyRequest struct {
	SpaceIds []string `protobuf:"bytes,1,rep,name=spaceIds,proto3" json:"spaceIds,omitempty"`
}

SpaceStatusCheckManyRequest contains the spaceIds of requested spaces

func (*SpaceStatusCheckManyRequest) Descriptor added in v0.3.0 

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

func (*SpaceStatusCheckManyRequest) GetSpaceIds added in v0.3.0 

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

func (*SpaceStatusCheckManyRequest) Marshal added in v0.3.0 

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

func (*SpaceStatusCheckManyRequest) MarshalTo added in v0.3.0 

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

func (*SpaceStatusCheckManyRequest) MarshalToSizedBuffer added in v0.3.0 

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

func (*SpaceStatusCheckManyRequest) ProtoMessage added in v0.3.0 

func (*SpaceStatusCheckManyRequest) ProtoMessage()

func (*SpaceStatusCheckManyRequest) Reset added in v0.3.0 

func (m *SpaceStatusCheckManyRequest) Reset()

func (*SpaceStatusCheckManyRequest) Size added in v0.3.0 

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

func (*SpaceStatusCheckManyRequest) String added in v0.3.0 

func (m *SpaceStatusCheckManyRequest) String() string

func (*SpaceStatusCheckManyRequest) Unmarshal added in v0.3.0 

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

func (*SpaceStatusCheckManyRequest) XXX_DiscardUnknown added in v0.3.0 

func (m *SpaceStatusCheckManyRequest) XXX_DiscardUnknown()

func (*SpaceStatusCheckManyRequest) XXX_Marshal added in v0.3.0 

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

func (*SpaceStatusCheckManyRequest) XXX_Merge added in v0.3.0 

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

func (*SpaceStatusCheckManyRequest) XXX_Size added in v0.3.0 

func (m *SpaceStatusCheckManyRequest) XXX_Size() int

func (*SpaceStatusCheckManyRequest) XXX_Unmarshal added in v0.3.0 

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

type SpaceStatusCheckManyResponse added in v0.3.0 

type SpaceStatusCheckManyResponse struct {
	Payloads []*SpaceStatusPayload `protobuf:"bytes,1,rep,name=payloads,proto3" json:"payloads,omitempty"`
}

SpaceStatusCheckManyResponse contains the current statuses of spaces

func (*SpaceStatusCheckManyResponse) Descriptor added in v0.3.0 

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

func (*SpaceStatusCheckManyResponse) GetPayloads added in v0.3.0 

func (m *SpaceStatusCheckManyResponse) GetPayloads() []*SpaceStatusPayload

func (*SpaceStatusCheckManyResponse) Marshal added in v0.3.0 

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

func (*SpaceStatusCheckManyResponse) MarshalTo added in v0.3.0 

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

func (*SpaceStatusCheckManyResponse) MarshalToSizedBuffer added in v0.3.0 

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

func (*SpaceStatusCheckManyResponse) ProtoMessage added in v0.3.0 

func (*SpaceStatusCheckManyResponse) ProtoMessage()

func (*SpaceStatusCheckManyResponse) Reset added in v0.3.0 

func (m *SpaceStatusCheckManyResponse) Reset()

func (*SpaceStatusCheckManyResponse) Size added in v0.3.0 

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

func (*SpaceStatusCheckManyResponse) String added in v0.3.0 

func (m *SpaceStatusCheckManyResponse) String() string

func (*SpaceStatusCheckManyResponse) Unmarshal added in v0.3.0 

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

func (*SpaceStatusCheckManyResponse) XXX_DiscardUnknown added in v0.3.0 

func (m *SpaceStatusCheckManyResponse) XXX_DiscardUnknown()

func (*SpaceStatusCheckManyResponse) XXX_Marshal added in v0.3.0 

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

func (*SpaceStatusCheckManyResponse) XXX_Merge added in v0.3.0 

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

func (*SpaceStatusCheckManyResponse) XXX_Size added in v0.3.0 

func (m *SpaceStatusCheckManyResponse) XXX_Size() int

func (*SpaceStatusCheckManyResponse) XXX_Unmarshal added in v0.3.0 

func (m *SpaceStatusCheckManyResponse) 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.