Documentation ¶
Index ¶
- Variables
- func RegisterAuthServer(s grpc.ServiceRegistrar, srv AuthServer)
- func RegisterChannelServer(s grpc.ServiceRegistrar, srv ChannelServer)
- func RegisterEscrowChannelServer(s grpc.ServiceRegistrar, srv EscrowChannelServer)
- func RegisterOperatorServer(s grpc.ServiceRegistrar, srv OperatorServer)
- func RegisterPriceFeedServer(s grpc.ServiceRegistrar, srv PriceFeedServer)
- func RegisterSettlementServiceServer(s grpc.ServiceRegistrar, srv SettlementServiceServer)
- func RegisterTradeChannelServer(s grpc.ServiceRegistrar, srv TradeChannelServer)
- type Address
- type Allocation
- func (*Allocation) Descriptor() ([]byte, []int)deprecated
- func (x *Allocation) GetAllocationType() AllocationType
- func (x *Allocation) GetAmount() string
- func (x *Allocation) GetDestination() []byte
- func (x *Allocation) GetMetadata() []byte
- func (*Allocation) ProtoMessage()
- func (x *Allocation) ProtoReflect() protoreflect.Message
- func (x *Allocation) Reset()
- func (x *Allocation) String() string
- type AllocationType
- func (AllocationType) Descriptor() protoreflect.EnumDescriptor
- func (x AllocationType) Enum() *AllocationType
- func (AllocationType) EnumDescriptor() ([]byte, []int)deprecated
- func (x AllocationType) Number() protoreflect.EnumNumber
- func (x AllocationType) String() string
- func (AllocationType) Type() protoreflect.EnumType
- type Asset
- func (*Asset) Descriptor() ([]byte, []int)deprecated
- func (x *Asset) GetAddress() *Address
- func (x *Asset) GetChainId() uint64
- func (x *Asset) GetDecimals() uint32
- func (x *Asset) GetSymbol() string
- func (*Asset) ProtoMessage()
- func (x *Asset) ProtoReflect() protoreflect.Message
- func (x *Asset) Reset()
- func (x *Asset) String() string
- type AssetMetadata
- func (*AssetMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *AssetMetadata) GetAssetType() AssetType
- func (x *AssetMetadata) GetMetadata() []byte
- func (*AssetMetadata) ProtoMessage()
- func (x *AssetMetadata) ProtoReflect() protoreflect.Message
- func (x *AssetMetadata) Reset()
- func (x *AssetMetadata) String() string
- type AssetType
- type AuthClient
- type AuthServer
- type AuthToken
- type AuthenticateRequest
- func (*AuthenticateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AuthenticateRequest) GetAddress() *Address
- func (x *AuthenticateRequest) GetSignature() string
- func (*AuthenticateRequest) ProtoMessage()
- func (x *AuthenticateRequest) ProtoReflect() protoreflect.Message
- func (x *AuthenticateRequest) Reset()
- func (x *AuthenticateRequest) String() string
- type AuthenticateResponse
- func (*AuthenticateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AuthenticateResponse) GetJwt() string
- func (*AuthenticateResponse) ProtoMessage()
- func (x *AuthenticateResponse) ProtoReflect() protoreflect.Message
- func (x *AuthenticateResponse) Reset()
- func (x *AuthenticateResponse) String() string
- type BigInt
- type ChallengeRequest
- func (*ChallengeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ChallengeRequest) GetClient() *Peer
- func (x *ChallengeRequest) GetServerOperatorAddress() string
- func (*ChallengeRequest) ProtoMessage()
- func (x *ChallengeRequest) ProtoReflect() protoreflect.Message
- func (x *ChallengeRequest) Reset()
- func (x *ChallengeRequest) String() string
- type ChallengeResponse
- func (*ChallengeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ChallengeResponse) GetServer() *Peer
- func (x *ChallengeResponse) GetServerChallenge() string
- func (*ChallengeResponse) ProtoMessage()
- func (x *ChallengeResponse) ProtoReflect() protoreflect.Message
- func (x *ChallengeResponse) Reset()
- func (x *ChallengeResponse) String() string
- type ChannelClient
- type ChannelServer
- type ChannelState
- func (*ChannelState) Descriptor() ([]byte, []int)deprecated
- func (x *ChannelState) GetState() *State
- func (x *ChannelState) GetStateHash() string
- func (x *ChannelState) GetStateSig() *Signature
- func (*ChannelState) ProtoMessage()
- func (x *ChannelState) ProtoReflect() protoreflect.Message
- func (x *ChannelState) Reset()
- func (x *ChannelState) String() string
- type Channel_SubscribeTradesClient
- type Channel_SubscribeTradesServer
- type ClearStream
- func (*ClearStream) Descriptor() ([]byte, []int)deprecated
- func (x *ClearStream) GetChannelId() string
- func (x *ClearStream) GetPositions() []*Position
- func (*ClearStream) ProtoMessage()
- func (x *ClearStream) ProtoReflect() protoreflect.Message
- func (x *ClearStream) Reset()
- func (x *ClearStream) String() string
- type ClearingEvent
- func (ClearingEvent) Descriptor() protoreflect.EnumDescriptor
- func (x ClearingEvent) Enum() *ClearingEvent
- func (ClearingEvent) EnumDescriptor() ([]byte, []int)deprecated
- func (x ClearingEvent) Number() protoreflect.EnumNumber
- func (x ClearingEvent) String() string
- func (ClearingEvent) Type() protoreflect.EnumType
- type ClearingSMState
- func (ClearingSMState) Descriptor() protoreflect.EnumDescriptor
- func (x ClearingSMState) Enum() *ClearingSMState
- func (ClearingSMState) EnumDescriptor() ([]byte, []int)deprecated
- func (x ClearingSMState) Number() protoreflect.EnumNumber
- func (x ClearingSMState) String() string
- func (ClearingSMState) Type() protoreflect.EnumType
- type ClearingState
- func (ClearingState) Descriptor() protoreflect.EnumDescriptor
- func (x ClearingState) Enum() *ClearingState
- func (ClearingState) EnumDescriptor() ([]byte, []int)deprecated
- func (x ClearingState) Number() protoreflect.EnumNumber
- func (x ClearingState) String() string
- func (ClearingState) Type() protoreflect.EnumType
- type CloseChannelRequest
- func (*CloseChannelRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CloseChannelRequest) GetChannelId() string
- func (*CloseChannelRequest) ProtoMessage()
- func (x *CloseChannelRequest) ProtoReflect() protoreflect.Message
- func (x *CloseChannelRequest) Reset()
- func (x *CloseChannelRequest) String() string
- type CloseChannelResponse
- type Decimal
- type Direction
- type ErrorMetadata
- func (*ErrorMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *ErrorMetadata) GetChannelId() string
- func (x *ErrorMetadata) GetEvent() string
- func (x *ErrorMetadata) GetState() string
- func (*ErrorMetadata) ProtoMessage()
- func (x *ErrorMetadata) ProtoReflect() protoreflect.Message
- func (x *ErrorMetadata) Reset()
- func (x *ErrorMetadata) String() string
- type ErrorNotification
- func (*ErrorNotification) Descriptor() ([]byte, []int)deprecated
- func (x *ErrorNotification) GetAction() string
- func (x *ErrorNotification) GetMetadata() *ErrorMetadata
- func (x *ErrorNotification) GetMsg() string
- func (*ErrorNotification) ProtoMessage()
- func (x *ErrorNotification) ProtoReflect() protoreflect.Message
- func (x *ErrorNotification) Reset()
- func (x *ErrorNotification) String() string
- type EscrowChannelClient
- type EscrowChannelServer
- type EscrowState
- func (*EscrowState) Descriptor() ([]byte, []int)deprecated
- func (x *EscrowState) GetChannelId() []byte
- func (x *EscrowState) GetSettlementId() uint64
- func (x *EscrowState) GetState() *State
- func (x *EscrowState) GetStateHash() []byte
- func (x *EscrowState) GetStateHashSigs() []*Signature
- func (*EscrowState) ProtoMessage()
- func (x *EscrowState) ProtoReflect() protoreflect.Message
- func (x *EscrowState) Reset()
- func (x *EscrowState) String() string
- type Exit
- type FinalizeRequest
- type FinalizeResponse
- type GetActiveClearStreamsRequest
- func (*GetActiveClearStreamsRequest) Descriptor() ([]byte, []int)deprecated
- func (*GetActiveClearStreamsRequest) ProtoMessage()
- func (x *GetActiveClearStreamsRequest) ProtoReflect() protoreflect.Message
- func (x *GetActiveClearStreamsRequest) Reset()
- func (x *GetActiveClearStreamsRequest) String() string
- type GetActiveClearStreamsResponse
- func (*GetActiveClearStreamsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetActiveClearStreamsResponse) GetClearStreams() []*ClearStream
- func (*GetActiveClearStreamsResponse) ProtoMessage()
- func (x *GetActiveClearStreamsResponse) ProtoReflect() protoreflect.Message
- func (x *GetActiveClearStreamsResponse) Reset()
- func (x *GetActiveClearStreamsResponse) String() string
- type GetChallengeRequest
- func (*GetChallengeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetChallengeRequest) GetAddress() *Address
- func (x *GetChallengeRequest) GetName() string
- func (*GetChallengeRequest) ProtoMessage()
- func (x *GetChallengeRequest) ProtoReflect() protoreflect.Message
- func (x *GetChallengeRequest) Reset()
- func (x *GetChallengeRequest) String() string
- type GetChallengeResponse
- func (*GetChallengeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetChallengeResponse) GetChallenge() string
- func (*GetChallengeResponse) ProtoMessage()
- func (x *GetChallengeResponse) ProtoReflect() protoreflect.Message
- func (x *GetChallengeResponse) Reset()
- func (x *GetChallengeResponse) String() string
- type GetJwtRequest
- type GetJwtResponse
- type GetPositionsRequest
- func (*GetPositionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetPositionsRequest) GetChannelId() string
- func (*GetPositionsRequest) ProtoMessage()
- func (x *GetPositionsRequest) ProtoReflect() protoreflect.Message
- func (x *GetPositionsRequest) Reset()
- func (x *GetPositionsRequest) String() string
- type GetPositionsResponse
- func (*GetPositionsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetPositionsResponse) GetChannelId() string
- func (x *GetPositionsResponse) GetPositions() []*Position
- func (*GetPositionsResponse) ProtoMessage()
- func (x *GetPositionsResponse) ProtoReflect() protoreflect.Message
- func (x *GetPositionsResponse) Reset()
- func (x *GetPositionsResponse) String() string
- type IncompleteUserOp
- func (*IncompleteUserOp) Descriptor() ([]byte, []int)deprecated
- func (x *IncompleteUserOp) GetCallData() []byte
- func (x *IncompleteUserOp) GetCallGasLimit() *BigInt
- func (x *IncompleteUserOp) GetInitCode() []byte
- func (x *IncompleteUserOp) GetMaxFeePerGas() *BigInt
- func (x *IncompleteUserOp) GetMaxPriorityFeePerGas() *BigInt
- func (x *IncompleteUserOp) GetNonce() *BigInt
- func (x *IncompleteUserOp) GetPaymasterAndData() []byte
- func (x *IncompleteUserOp) GetPreVerificationGas() *BigInt
- func (x *IncompleteUserOp) GetSender() *Address
- func (x *IncompleteUserOp) GetSignature() []byte
- func (x *IncompleteUserOp) GetVerificationGasLimit() *BigInt
- func (*IncompleteUserOp) ProtoMessage()
- func (x *IncompleteUserOp) ProtoReflect() protoreflect.Message
- func (x *IncompleteUserOp) Reset()
- func (x *IncompleteUserOp) String() string
- type Liability
- type MarginCall
- func (*MarginCall) Descriptor() ([]byte, []int)deprecated
- func (x *MarginCall) GetAmounts() []*Decimal
- func (x *MarginCall) GetVersion() uint64
- func (*MarginCall) ProtoMessage()
- func (x *MarginCall) ProtoReflect() protoreflect.Message
- func (x *MarginCall) Reset()
- func (x *MarginCall) String() string
- type MarginLimitType
- func (MarginLimitType) Descriptor() protoreflect.EnumDescriptor
- func (x MarginLimitType) Enum() *MarginLimitType
- func (MarginLimitType) EnumDescriptor() ([]byte, []int)deprecated
- func (x MarginLimitType) Number() protoreflect.EnumNumber
- func (x MarginLimitType) String() string
- func (MarginLimitType) Type() protoreflect.EnumType
- type Market
- type Notification
- func (*Notification) Descriptor() ([]byte, []int)deprecated
- func (x *Notification) GetErrorNotification() *ErrorNotification
- func (m *Notification) GetNotification() isNotification_Notification
- func (x *Notification) GetPositionNotification() *PositionNotification
- func (x *Notification) GetRecordTradeNotification() *RecordTradeNotification
- func (x *Notification) GetSessionKeyTransactionNotification() *SessionKeyTransactionNotification
- func (x *Notification) GetSettlementNotification() *SettlementNotification
- func (x *Notification) GetStreamNotification() *StreamNotification
- func (x *Notification) GetTransactionNotification() *TransactionNotification
- func (*Notification) ProtoMessage()
- func (x *Notification) ProtoReflect() protoreflect.Message
- func (x *Notification) Reset()
- func (x *Notification) String() string
- type Notification_ErrorNotification
- type Notification_PositionNotification
- type Notification_RecordTradeNotification
- type Notification_SessionKeyTransactionNotification
- type Notification_SettlementNotification
- type Notification_StreamNotification
- type Notification_TransactionNotification
- type OpenChannelRequest
- func (*OpenChannelRequest) Descriptor() ([]byte, []int)deprecated
- func (x *OpenChannelRequest) GetMarginDeposit() string
- func (x *OpenChannelRequest) GetPeer() *Peer
- func (*OpenChannelRequest) ProtoMessage()
- func (x *OpenChannelRequest) ProtoReflect() protoreflect.Message
- func (x *OpenChannelRequest) Reset()
- func (x *OpenChannelRequest) String() string
- type OpenChannelResponse
- func (*OpenChannelResponse) Descriptor() ([]byte, []int)deprecated
- func (x *OpenChannelResponse) GetChannelId() string
- func (*OpenChannelResponse) ProtoMessage()
- func (x *OpenChannelResponse) ProtoReflect() protoreflect.Message
- func (x *OpenChannelResponse) Reset()
- func (x *OpenChannelResponse) String() string
- type OperatorClient
- type OperatorServer
- type Operator_SubscribeChannelsEventsClient
- type Operator_SubscribeChannelsEventsServer
- type ParamCondition
- func (ParamCondition) Descriptor() protoreflect.EnumDescriptor
- func (x ParamCondition) Enum() *ParamCondition
- func (ParamCondition) EnumDescriptor() ([]byte, []int)deprecated
- func (x ParamCondition) Number() protoreflect.EnumNumber
- func (x ParamCondition) String() string
- func (ParamCondition) Type() protoreflect.EnumType
- type ParamRule
- type PaymentMethod
- func (PaymentMethod) Descriptor() protoreflect.EnumDescriptor
- func (x PaymentMethod) Enum() *PaymentMethod
- func (PaymentMethod) EnumDescriptor() ([]byte, []int)deprecated
- func (x PaymentMethod) Number() protoreflect.EnumNumber
- func (x PaymentMethod) String() string
- func (PaymentMethod) Type() protoreflect.EnumType
- type Peer
- func (*Peer) Descriptor() ([]byte, []int)deprecated
- func (x *Peer) GetName() string
- func (x *Peer) GetOperatorAddress() string
- func (x *Peer) GetParticipantAddress() string
- func (x *Peer) GetUrl() string
- func (*Peer) ProtoMessage()
- func (x *Peer) ProtoReflect() protoreflect.Message
- func (x *Peer) Reset()
- func (x *Peer) String() string
- type Position
- func (*Position) Descriptor() ([]byte, []int)deprecated
- func (x *Position) GetAmount() string
- func (x *Position) GetChannelId() string
- func (x *Position) GetCost() string
- func (x *Position) GetDirection() Direction
- func (x *Position) GetId() string
- func (x *Position) GetMarket() *Market
- func (x *Position) GetMarketValue() string
- func (x *Position) GetPnl() string
- func (x *Position) GetStatus() PositionStatus
- func (*Position) ProtoMessage()
- func (x *Position) ProtoReflect() protoreflect.Message
- func (x *Position) Reset()
- func (x *Position) String() string
- type PositionNotification
- func (*PositionNotification) Descriptor() ([]byte, []int)deprecated
- func (x *PositionNotification) GetPosition() *Position
- func (*PositionNotification) ProtoMessage()
- func (x *PositionNotification) ProtoReflect() protoreflect.Message
- func (x *PositionNotification) Reset()
- func (x *PositionNotification) String() string
- type PositionStatus
- func (PositionStatus) Descriptor() protoreflect.EnumDescriptor
- func (x PositionStatus) Enum() *PositionStatus
- func (PositionStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x PositionStatus) Number() protoreflect.EnumNumber
- func (x PositionStatus) String() string
- func (PositionStatus) Type() protoreflect.EnumType
- type PrepareRequest
- type PrepareResponse
- func (*PrepareResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PrepareResponse) GetMarkets() []string
- func (x *PrepareResponse) GetState() SettlementState
- func (*PrepareResponse) ProtoMessage()
- func (x *PrepareResponse) ProtoReflect() protoreflect.Message
- func (x *PrepareResponse) Reset()
- func (x *PrepareResponse) String() string
- type PriceFeedClient
- type PriceFeedServer
- type PriceFeedSubscribeRequest
- func (*PriceFeedSubscribeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PriceFeedSubscribeRequest) GetMarket() *Market
- func (*PriceFeedSubscribeRequest) ProtoMessage()
- func (x *PriceFeedSubscribeRequest) ProtoReflect() protoreflect.Message
- func (x *PriceFeedSubscribeRequest) Reset()
- func (x *PriceFeedSubscribeRequest) String() string
- type PriceFeed_SubscribeClient
- type PriceFeed_SubscribeServer
- type ProtocolIndex
- func (ProtocolIndex) Descriptor() protoreflect.EnumDescriptor
- func (x ProtocolIndex) Enum() *ProtocolIndex
- func (ProtocolIndex) EnumDescriptor() ([]byte, []int)deprecated
- func (x ProtocolIndex) Number() protoreflect.EnumNumber
- func (x ProtocolIndex) String() string
- func (ProtocolIndex) Type() protoreflect.EnumType
- type Quote
- type RecordTradeNotification
- func (*RecordTradeNotification) Descriptor() ([]byte, []int)deprecated
- func (x *RecordTradeNotification) GetRevertReason() string
- func (x *RecordTradeNotification) GetTrade() *Trade
- func (*RecordTradeNotification) ProtoMessage()
- func (x *RecordTradeNotification) ProtoReflect() protoreflect.Message
- func (x *RecordTradeNotification) Reset()
- func (x *RecordTradeNotification) String() string
- type SessionKeyPermission
- func (*SessionKeyPermission) Descriptor() ([]byte, []int)deprecated
- func (x *SessionKeyPermission) GetFunctionAbi() []byte
- func (x *SessionKeyPermission) GetParamRules() []*ParamRule
- func (x *SessionKeyPermission) GetTarget() *Address
- func (x *SessionKeyPermission) GetValueLimit() *BigInt
- func (*SessionKeyPermission) ProtoMessage()
- func (x *SessionKeyPermission) ProtoReflect() protoreflect.Message
- func (x *SessionKeyPermission) Reset()
- func (x *SessionKeyPermission) String() string
- type SessionKeyTransactionNotification
- func (*SessionKeyTransactionNotification) Descriptor() ([]byte, []int)deprecated
- func (x *SessionKeyTransactionNotification) GetDigestHash() string
- func (x *SessionKeyTransactionNotification) GetEnableSigOffset() uint64
- func (x *SessionKeyTransactionNotification) GetIncompleteUserop() *IncompleteUserOp
- func (x *SessionKeyTransactionNotification) GetPermissions() []*SessionKeyPermission
- func (*SessionKeyTransactionNotification) ProtoMessage()
- func (x *SessionKeyTransactionNotification) ProtoReflect() protoreflect.Message
- func (x *SessionKeyTransactionNotification) Reset()
- func (x *SessionKeyTransactionNotification) String() string
- type Settlement
- func (*Settlement) Descriptor() ([]byte, []int)deprecated
- func (x *Settlement) GetChainId() uint64
- func (x *Settlement) GetCid() string
- func (x *Settlement) GetLedger() *SettlementLedger
- func (x *Settlement) GetMarkets() []string
- func (x *Settlement) GetPaymentMethod() PaymentMethod
- func (x *Settlement) GetPsmTurnNum() uint64
- func (x *Settlement) GetState() SettlementState
- func (x *Settlement) GetType() SettlementType
- func (*Settlement) ProtoMessage()
- func (x *Settlement) ProtoReflect() protoreflect.Message
- func (x *Settlement) Reset()
- func (x *Settlement) String() string
- type SettlementLedger
- func (*SettlementLedger) Descriptor() ([]byte, []int)deprecated
- func (x *SettlementLedger) GetInitiatorEntries() []*Liability
- func (x *SettlementLedger) GetNextMargin() *MarginCall
- func (x *SettlementLedger) GetResponderEntries() []*Liability
- func (*SettlementLedger) ProtoMessage()
- func (x *SettlementLedger) ProtoReflect() protoreflect.Message
- func (x *SettlementLedger) Reset()
- func (x *SettlementLedger) String() string
- type SettlementNotification
- func (*SettlementNotification) Descriptor() ([]byte, []int)deprecated
- func (x *SettlementNotification) GetChannelId() string
- func (x *SettlementNotification) GetLedger() *SettlementLedger
- func (x *SettlementNotification) GetMarkets() []*Market
- func (x *SettlementNotification) GetSettlementState() SettlementState
- func (*SettlementNotification) ProtoMessage()
- func (x *SettlementNotification) ProtoReflect() protoreflect.Message
- func (x *SettlementNotification) Reset()
- func (x *SettlementNotification) String() string
- type SettlementRequest
- func (*SettlementRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SettlementRequest) GetChainId() uint64
- func (x *SettlementRequest) GetChannelId() string
- func (x *SettlementRequest) GetMarkets() []*Market
- func (x *SettlementRequest) GetPaymentMethod() PaymentMethod
- func (*SettlementRequest) ProtoMessage()
- func (x *SettlementRequest) ProtoReflect() protoreflect.Message
- func (x *SettlementRequest) Reset()
- func (x *SettlementRequest) String() string
- type SettlementResponse
- type SettlementServiceClient
- type SettlementServiceServer
- type SettlementState
- func (SettlementState) Descriptor() protoreflect.EnumDescriptor
- func (x SettlementState) Enum() *SettlementState
- func (SettlementState) EnumDescriptor() ([]byte, []int)deprecated
- func (x SettlementState) Number() protoreflect.EnumNumber
- func (x SettlementState) String() string
- func (SettlementState) Type() protoreflect.EnumType
- type SettlementStateUpdate
- func (*SettlementStateUpdate) Descriptor() ([]byte, []int)deprecated
- func (x *SettlementStateUpdate) GetCid() string
- func (x *SettlementStateUpdate) GetToState() SettlementState
- func (*SettlementStateUpdate) ProtoMessage()
- func (x *SettlementStateUpdate) ProtoReflect() protoreflect.Message
- func (x *SettlementStateUpdate) Reset()
- func (x *SettlementStateUpdate) String() string
- type SettlementType
- func (SettlementType) Descriptor() protoreflect.EnumDescriptor
- func (x SettlementType) Enum() *SettlementType
- func (SettlementType) EnumDescriptor() ([]byte, []int)deprecated
- func (x SettlementType) Number() protoreflect.EnumNumber
- func (x SettlementType) String() string
- func (SettlementType) Type() protoreflect.EnumType
- type Signature
- func (*Signature) Descriptor() ([]byte, []int)deprecated
- func (x *Signature) GetR() []byte
- func (x *Signature) GetS() []byte
- func (x *Signature) GetV() uint32
- func (*Signature) ProtoMessage()
- func (x *Signature) ProtoReflect() protoreflect.Message
- func (x *Signature) Reset()
- func (x *Signature) String() string
- type SignedChallenge
- func (*SignedChallenge) Descriptor() ([]byte, []int)deprecated
- func (x *SignedChallenge) GetClient() *Peer
- func (x *SignedChallenge) GetServerOperatorAddress() string
- func (x *SignedChallenge) GetSignedServerChallenge() []byte
- func (*SignedChallenge) ProtoMessage()
- func (x *SignedChallenge) ProtoReflect() protoreflect.Message
- func (x *SignedChallenge) Reset()
- func (x *SignedChallenge) String() string
- type SignedMarginCall
- func (*SignedMarginCall) Descriptor() ([]byte, []int)deprecated
- func (x *SignedMarginCall) GetMarginCall() *MarginCall
- func (x *SignedMarginCall) GetSigs() []*Signature
- func (*SignedMarginCall) ProtoMessage()
- func (x *SignedMarginCall) ProtoReflect() protoreflect.Message
- func (x *SignedMarginCall) Reset()
- func (x *SignedMarginCall) String() string
- type SignoutResponse
- type SingleAssetExit
- func (*SingleAssetExit) Descriptor() ([]byte, []int)deprecated
- func (x *SingleAssetExit) GetAllocations() []*Allocation
- func (x *SingleAssetExit) GetAsset() *Address
- func (x *SingleAssetExit) GetAssetMetadata() *AssetMetadata
- func (*SingleAssetExit) ProtoMessage()
- func (x *SingleAssetExit) ProtoReflect() protoreflect.Message
- func (x *SingleAssetExit) Reset()
- func (x *SingleAssetExit) String() string
- type State
- func (*State) Descriptor() ([]byte, []int)deprecated
- func (x *State) GetAppData() []byte
- func (x *State) GetAppDefinition() *Address
- func (x *State) GetChallengeDuration() uint32
- func (x *State) GetChannelNonce() uint64
- func (x *State) GetIsFinal() bool
- func (x *State) GetOutcome() *Exit
- func (x *State) GetParticipants() []*Address
- func (x *State) GetTurnNum() uint64
- func (*State) ProtoMessage()
- func (x *State) ProtoReflect() protoreflect.Message
- func (x *State) Reset()
- func (x *State) String() string
- type StateConfirmation
- func (*StateConfirmation) Descriptor() ([]byte, []int)deprecated
- func (x *StateConfirmation) GetState() SettlementState
- func (*StateConfirmation) ProtoMessage()
- func (x *StateConfirmation) ProtoReflect() protoreflect.Message
- func (x *StateConfirmation) Reset()
- func (x *StateConfirmation) String() string
- type StreamNotification
- func (*StreamNotification) Descriptor() ([]byte, []int)deprecated
- func (x *StreamNotification) GetChannelId() string
- func (x *StreamNotification) GetClearingSmState() ClearingSMState
- func (x *StreamNotification) GetEvent() ClearingEvent
- func (x *StreamNotification) GetFollowerMarginBalance() string
- func (x *StreamNotification) GetInitiatorMarginBalance() string
- func (x *StreamNotification) GetMarginDeposit() string
- func (x *StreamNotification) GetMarginLimitType() MarginLimitType
- func (x *StreamNotification) GetMyRole() ProtocolIndex
- func (x *StreamNotification) GetPeer() *Peer
- func (x *StreamNotification) GetState() ClearingState
- func (x *StreamNotification) GetTurnNum() uint64
- func (*StreamNotification) ProtoMessage()
- func (x *StreamNotification) ProtoReflect() protoreflect.Message
- func (x *StreamNotification) Reset()
- func (x *StreamNotification) String() string
- type SubscribeRequest
- type SubscribeTradesRequest
- func (*SubscribeTradesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeTradesRequest) GetChannelId() string
- func (x *SubscribeTradesRequest) GetLastExternalId() string
- func (*SubscribeTradesRequest) ProtoMessage()
- func (x *SubscribeTradesRequest) ProtoReflect() protoreflect.Message
- func (x *SubscribeTradesRequest) Reset()
- func (x *SubscribeTradesRequest) String() string
- type Trade
- func (*Trade) Descriptor() ([]byte, []int)deprecated
- func (x *Trade) GetAmount() *Decimal
- func (x *Trade) GetChannelId() string
- func (x *Trade) GetDirection() Direction
- func (x *Trade) GetExecutedAt() int64
- func (x *Trade) GetExternalId() string
- func (x *Trade) GetMarket() *Market
- func (x *Trade) GetPrice() *Decimal
- func (*Trade) ProtoMessage()
- func (x *Trade) ProtoReflect() protoreflect.Message
- func (x *Trade) Reset()
- func (x *Trade) String() string
- type TradeChannelClient
- type TradeChannelServer
- type TradeRequest
- type TradeResponse
- type TradeState
- func (*TradeState) Descriptor() ([]byte, []int)deprecated
- func (x *TradeState) GetChannelId() []byte
- func (x *TradeState) GetMarginCall() *SignedMarginCall
- func (x *TradeState) GetSafety() *Decimal
- func (x *TradeState) GetState() *State
- func (x *TradeState) GetStateHash() []byte
- func (x *TradeState) GetStateHashSigs() []*Signature
- func (*TradeState) ProtoMessage()
- func (x *TradeState) ProtoReflect() protoreflect.Message
- func (x *TradeState) Reset()
- func (x *TradeState) String() string
- type TradesRequest
- type TradesResponse
- type TransactionNotification
- func (*TransactionNotification) Descriptor() ([]byte, []int)deprecated
- func (x *TransactionNotification) GetData() string
- func (x *TransactionNotification) GetTo() string
- func (*TransactionNotification) ProtoMessage()
- func (x *TransactionNotification) ProtoReflect() protoreflect.Message
- func (x *TransactionNotification) Reset()
- func (x *TransactionNotification) String() string
- type UnimplementedAuthServer
- func (UnimplementedAuthServer) Authenticate(context.Context, *SignedChallenge) (*AuthToken, error)
- func (UnimplementedAuthServer) GetChallenge(context.Context, *ChallengeRequest) (*ChallengeResponse, error)
- func (UnimplementedAuthServer) Signout(context.Context, *AuthToken) (*SignoutResponse, error)
- func (UnimplementedAuthServer) TokenRefresh(context.Context, *AuthToken) (*AuthToken, error)
- type UnimplementedChannelServer
- func (UnimplementedChannelServer) Close(context.Context, *ChannelState) (*Signature, error)
- func (UnimplementedChannelServer) Open(context.Context, *ChannelState) (*Signature, error)
- func (UnimplementedChannelServer) SubscribeTrades(*SubscribeTradesRequest, Channel_SubscribeTradesServer) error
- func (UnimplementedChannelServer) Update(context.Context, *ChannelState) (*Signature, error)
- type UnimplementedEscrowChannelServer
- func (UnimplementedEscrowChannelServer) Execute(context.Context, *EscrowState) (*EscrowState, error)
- func (UnimplementedEscrowChannelServer) Finalize(context.Context, *EscrowState) (*EscrowState, error)
- func (UnimplementedEscrowChannelServer) Postfund(context.Context, *EscrowState) (*EscrowState, error)
- func (UnimplementedEscrowChannelServer) Prefund(context.Context, *EscrowState) (*EscrowState, error)
- type UnimplementedOperatorServer
- func (UnimplementedOperatorServer) Authenticate(context.Context, *AuthenticateRequest) (*AuthenticateResponse, error)
- func (UnimplementedOperatorServer) CloseChannel(context.Context, *CloseChannelRequest) (*CloseChannelResponse, error)
- func (UnimplementedOperatorServer) GetActiveClearStreams(context.Context, *GetActiveClearStreamsRequest) (*GetActiveClearStreamsResponse, error)
- func (UnimplementedOperatorServer) GetChallenge(context.Context, *GetChallengeRequest) (*GetChallengeResponse, error)
- func (UnimplementedOperatorServer) GetChannelJwt(context.Context, *GetJwtRequest) (*GetJwtResponse, error)
- func (UnimplementedOperatorServer) GetPositions(context.Context, *GetPositionsRequest) (*GetPositionsResponse, error)
- func (UnimplementedOperatorServer) GetVersion(context.Context, *VersionRequest) (*VersionResponse, error)
- func (UnimplementedOperatorServer) OpenChannel(context.Context, *OpenChannelRequest) (*OpenChannelResponse, error)
- func (UnimplementedOperatorServer) RecordTrade(context.Context, *TradeRequest) (*TradeResponse, error)
- func (UnimplementedOperatorServer) RecordTrades(context.Context, *TradesRequest) (*TradesResponse, error)
- func (UnimplementedOperatorServer) RequestSettlement(context.Context, *SettlementRequest) (*SettlementResponse, error)
- func (UnimplementedOperatorServer) SubscribeChannelsEvents(*SubscribeRequest, Operator_SubscribeChannelsEventsServer) error
- type UnimplementedPriceFeedServer
- type UnimplementedSettlementServiceServer
- func (UnimplementedSettlementServiceServer) Finalize(context.Context, *FinalizeRequest) (*FinalizeResponse, error)
- func (UnimplementedSettlementServiceServer) Prepare(context.Context, *PrepareRequest) (*PrepareResponse, error)
- func (UnimplementedSettlementServiceServer) Update(context.Context, *SettlementStateUpdate) (*StateConfirmation, error)
- type UnimplementedTradeChannelServer
- func (UnimplementedTradeChannelServer) Finalize(context.Context, *TradeState) (*TradeState, error)
- func (UnimplementedTradeChannelServer) Postfund(context.Context, *TradeState) (*TradeState, error)
- func (UnimplementedTradeChannelServer) Prefund(context.Context, *TradeState) (*TradeState, error)
- func (UnimplementedTradeChannelServer) RequestSettlement(context.Context, *TradeState) (*TradeState, error)
- func (UnimplementedTradeChannelServer) UpdateMargin(context.Context, *SignedMarginCall) (*SignedMarginCall, error)
- type UnsafeAuthServer
- type UnsafeChannelServer
- type UnsafeEscrowChannelServer
- type UnsafeOperatorServer
- type UnsafePriceFeedServer
- type UnsafeSettlementServiceServer
- type UnsafeTradeChannelServer
- type VersionRequest
- type VersionResponse
Constants ¶
This section is empty.
Variables ¶
var ( ProtocolIndex_name = map[int32]string{ 0: "PROTOCOL_INDEX_UNSPECIFIED", 1: "PROTOCOL_INDEX_INITIATOR", 2: "PROTOCOL_INDEX_RESPONDER", } ProtocolIndex_value = map[string]int32{ "PROTOCOL_INDEX_UNSPECIFIED": 0, "PROTOCOL_INDEX_INITIATOR": 1, "PROTOCOL_INDEX_RESPONDER": 2, } )
Enum value maps for ProtocolIndex.
var ( Direction_name = map[int32]string{ 0: "DIRECTION_UNSPECIFIED", 1: "DIRECTION_BUY", 2: "DIRECTION_SELL", } Direction_value = map[string]int32{ "DIRECTION_UNSPECIFIED": 0, "DIRECTION_BUY": 1, "DIRECTION_SELL": 2, } )
Enum value maps for Direction.
var ( PositionStatus_name = map[int32]string{ 0: "POSITION_STATUS_UNSPECIFIED", 1: "POSITION_STATUS_OPEN", 2: "POSITION_STATUS_IN_SETTLEMENT", 3: "POSITION_STATUS_SETTLED", 4: "POSITION_STATUS_CLOSED", } PositionStatus_value = map[string]int32{ "POSITION_STATUS_UNSPECIFIED": 0, "POSITION_STATUS_OPEN": 1, "POSITION_STATUS_IN_SETTLEMENT": 2, "POSITION_STATUS_SETTLED": 3, "POSITION_STATUS_CLOSED": 4, } )
Enum value maps for PositionStatus.
var ( MarginLimitType_name = map[int32]string{ 0: "MARGIN_LIMIT_TYPE_UNSPECIFIED", 1: "MARGIN_LIMIT_TYPE_NONE", 2: "MARGIN_LIMIT_TYPE_SOFT", 3: "MARGIN_LIMIT_TYPE_HARD", } MarginLimitType_value = map[string]int32{ "MARGIN_LIMIT_TYPE_UNSPECIFIED": 0, "MARGIN_LIMIT_TYPE_NONE": 1, "MARGIN_LIMIT_TYPE_SOFT": 2, "MARGIN_LIMIT_TYPE_HARD": 3, } )
Enum value maps for MarginLimitType.
var ( AssetType_name = map[int32]string{ 0: "ASSET_TYPE_UNSPECIFIED", 1: "ASSET_TYPE_ERC721", 2: "ASSET_TYPE_ERC1155", 3: "ASSET_TYPE_QUALIFIED", } AssetType_value = map[string]int32{ "ASSET_TYPE_UNSPECIFIED": 0, "ASSET_TYPE_ERC721": 1, "ASSET_TYPE_ERC1155": 2, "ASSET_TYPE_QUALIFIED": 3, } )
Enum value maps for AssetType.
var ( AllocationType_name = map[int32]string{ 0: "ALLOCATION_TYPE_UNSPECIFIED", 1: "ALLOCATION_TYPE_WITHDRAW_HELPER", 2: "ALLOCATION_TYPE_GUARANTEE", } AllocationType_value = map[string]int32{ "ALLOCATION_TYPE_UNSPECIFIED": 0, "ALLOCATION_TYPE_WITHDRAW_HELPER": 1, "ALLOCATION_TYPE_GUARANTEE": 2, } )
Enum value maps for AllocationType.
var ( ClearingEvent_name = map[int32]string{ 0: "CLEARING_EVENT_UNSPECIFIED", 1: "CLEARING_EVENT_INSTANTIATED", 2: "CLEARING_EVENT_ACCEPTED", 3: "CLEARING_EVENT_FAILED", 4: "CLEARING_EVENT_INITIATOR_FUNDED", 5: "CLEARING_EVENT_RESPONDER_FUNDED", 6: "CLEARING_EVENT_POSTFUND_PROPOSED", 7: "CLEARING_EVENT_AGREED_ON_POSTFUND", 8: "CLEARING_EVENT_MOVE_TO_OPERATIONAL", 9: "CLEARING_EVENT_PROCESS_MARGIN_CALL", 10: "CLEARING_EVENT_STARTED_SETTLEMENT", 11: "CLEARING_EVENT_PROCESS_POST_SETTLEMENT_MARGIN", 12: "CLEARING_EVENT_FINALIZE_SETTLEMENT", 13: "CLEARING_EVENT_FAILED_SETTLEMENT", 14: "CLEARING_EVENT_CHALLENGE", 15: "CLEARING_EVENT_FINALIZE", 16: "CLEARING_EVENT_WITHDRAW", 17: "CLEARING_EVENT_CLEAR_CHALLENGE", 18: "CLEARING_EVENT_TIMEOUT_CHALLENGE", } ClearingEvent_value = map[string]int32{ "CLEARING_EVENT_UNSPECIFIED": 0, "CLEARING_EVENT_INSTANTIATED": 1, "CLEARING_EVENT_ACCEPTED": 2, "CLEARING_EVENT_FAILED": 3, "CLEARING_EVENT_INITIATOR_FUNDED": 4, "CLEARING_EVENT_RESPONDER_FUNDED": 5, "CLEARING_EVENT_POSTFUND_PROPOSED": 6, "CLEARING_EVENT_AGREED_ON_POSTFUND": 7, "CLEARING_EVENT_MOVE_TO_OPERATIONAL": 8, "CLEARING_EVENT_PROCESS_MARGIN_CALL": 9, "CLEARING_EVENT_STARTED_SETTLEMENT": 10, "CLEARING_EVENT_PROCESS_POST_SETTLEMENT_MARGIN": 11, "CLEARING_EVENT_FINALIZE_SETTLEMENT": 12, "CLEARING_EVENT_FAILED_SETTLEMENT": 13, "CLEARING_EVENT_CHALLENGE": 14, "CLEARING_EVENT_FINALIZE": 15, "CLEARING_EVENT_WITHDRAW": 16, "CLEARING_EVENT_CLEAR_CHALLENGE": 17, "CLEARING_EVENT_TIMEOUT_CHALLENGE": 18, } )
Enum value maps for ClearingEvent.
var ( ClearingState_name = map[int32]string{ 0: "CLEARING_STATE_UNSPECIFIED", 1: "CLEARING_STATE_INSTANTIATED", 2: "CLEARING_STATE_ACCEPTED", 3: "CLEARING_STATE_FAILED", 4: "CLEARING_STATE_INITIATOR_FUNDED", 5: "CLEARING_STATE_FUNDED", 6: "CLEARING_STATE_OPERATIONAL", 7: "CLEARING_STATE_ISSUING_MARGIN_CALL", 8: "CLEARING_STATE_PROCESSING_MARGIN_CALL", 9: "CLEARING_STATE_ACTIVE_SETTLEMENT", 10: "CLEARING_STATE_ISSUING_POST_SETTLEMENT_MARGIN", 11: "CLEARING_STATE_PROCESSING_POST_SETTLEMENT_MARGIN", 12: "CLEARING_STATE_CHALLENGING", 13: "CLEARING_STATE_FINALIZING", 14: "CLEARING_STATE_WITHDRAWING", 15: "CLEARING_STATE_CONCLUDING", 16: "CLEARING_STATE_DEFAULT", } ClearingState_value = map[string]int32{ "CLEARING_STATE_UNSPECIFIED": 0, "CLEARING_STATE_INSTANTIATED": 1, "CLEARING_STATE_ACCEPTED": 2, "CLEARING_STATE_FAILED": 3, "CLEARING_STATE_INITIATOR_FUNDED": 4, "CLEARING_STATE_FUNDED": 5, "CLEARING_STATE_OPERATIONAL": 6, "CLEARING_STATE_ISSUING_MARGIN_CALL": 7, "CLEARING_STATE_PROCESSING_MARGIN_CALL": 8, "CLEARING_STATE_ACTIVE_SETTLEMENT": 9, "CLEARING_STATE_ISSUING_POST_SETTLEMENT_MARGIN": 10, "CLEARING_STATE_PROCESSING_POST_SETTLEMENT_MARGIN": 11, "CLEARING_STATE_CHALLENGING": 12, "CLEARING_STATE_FINALIZING": 13, "CLEARING_STATE_WITHDRAWING": 14, "CLEARING_STATE_CONCLUDING": 15, "CLEARING_STATE_DEFAULT": 16, } )
Enum value maps for ClearingState.
var ( ParamCondition_name = map[int32]string{ 0: "PARAM_CONDITION_UNSPECIFIED", 1: "PARAM_CONDITION_EQUAL", 2: "PARAM_CONDITION_GREATER_THAN", 3: "PARAM_CONDITION_LESS_THAN", 4: "PARAM_CONDITION_GREATER_THAN_OR_EQUAL", 5: "PARAM_CONDITION_LESS_THAN_OR_EQUAL", 6: "PARAM_CONDITION_NOT_EQUAL", } ParamCondition_value = map[string]int32{ "PARAM_CONDITION_UNSPECIFIED": 0, "PARAM_CONDITION_EQUAL": 1, "PARAM_CONDITION_GREATER_THAN": 2, "PARAM_CONDITION_LESS_THAN": 3, "PARAM_CONDITION_GREATER_THAN_OR_EQUAL": 4, "PARAM_CONDITION_LESS_THAN_OR_EQUAL": 5, "PARAM_CONDITION_NOT_EQUAL": 6, } )
Enum value maps for ParamCondition.
var ( SettlementType_name = map[int32]string{ 0: "SETTLEMENT_TYPE_UNSPECIFIED", 1: "SETTLEMENT_TYPE_AVAILABLE", 2: "SETTLEMENT_TYPE_FORCE", } SettlementType_value = map[string]int32{ "SETTLEMENT_TYPE_UNSPECIFIED": 0, "SETTLEMENT_TYPE_AVAILABLE": 1, "SETTLEMENT_TYPE_FORCE": 2, } )
Enum value maps for SettlementType.
var ( SettlementState_name = map[int32]string{ 0: "SETTLEMENT_STATE_UNSPECIFIED", 1: "SETTLEMENT_STATE_PROPOSED", 2: "SETTLEMENT_STATE_ACCEPTED", 3: "SETTLEMENT_STATE_INITIATED", 4: "SETTLEMENT_STATE_PREPARED", 5: "SETTLEMENT_STATE_EXECUTED", 6: "SETTLEMENT_STATE_COMPLETED", 7: "SETTLEMENT_STATE_WITHDRAWN", 8: "SETTLEMENT_STATE_FAILED", 9: "SETTLEMENT_STATE_REJECTED", } SettlementState_value = map[string]int32{ "SETTLEMENT_STATE_UNSPECIFIED": 0, "SETTLEMENT_STATE_PROPOSED": 1, "SETTLEMENT_STATE_ACCEPTED": 2, "SETTLEMENT_STATE_INITIATED": 3, "SETTLEMENT_STATE_PREPARED": 4, "SETTLEMENT_STATE_EXECUTED": 5, "SETTLEMENT_STATE_COMPLETED": 6, "SETTLEMENT_STATE_WITHDRAWN": 7, "SETTLEMENT_STATE_FAILED": 8, "SETTLEMENT_STATE_REJECTED": 9, } )
Enum value maps for SettlementState.
var ( PaymentMethod_name = map[int32]string{ 0: "PAYMENT_METHOD_UNSPECIFIED", 1: "PAYMENT_METHOD_ESCROW", 2: "PAYMENT_METHOD_MOCK", } PaymentMethod_value = map[string]int32{ "PAYMENT_METHOD_UNSPECIFIED": 0, "PAYMENT_METHOD_ESCROW": 1, "PAYMENT_METHOD_MOCK": 2, } )
Enum value maps for PaymentMethod.
var ( ClearingSMState_name = map[int32]string{ 0: "CLEARING_SMSTATE_UNSPECIFIED", 1: "CLEARING_SMSTATE_DEFAULT", 2: "CLEARING_SMSTATE_INSTANTIATING", 3: "CLEARING_SMSTATE_ACCEPTED", 4: "CLEARING_SMSTATE_FAILED", 5: "CLEARING_SMSTATE_INITIATOR_FUNDED", 6: "CLEARING_SMSTATE_FUNDED", 7: "CLEARING_SMSTATE_PRE_OP_CHALLENGING", 8: "CLEARING_SMSTATE_PENDING_PRE_OP_CHALLENGE_REGISTERED", 9: "CLEARING_SMSTATE_PRE_OP_CHALLENGE_REGISTERED", 10: "CLEARING_SMSTATE_OPERATIONAL", 11: "CLEARING_SMSTATE_PROCESSING_MARGIN_CALL", 12: "CLEARING_SMSTATE_ACTIVE_SETTLEMENT", 13: "CLEARING_SMSTATE_PROCESSING_POST_SETTLEMENT_MARGIN", 14: "CLEARING_SMSTATE_CHALLENGING", 15: "CLEARING_SMSTATE_PENDING_CHALLENGE_REGISTERED", 16: "CLEARING_SMSTATE_CHALLENGE_REGISTERED", 17: "CLEARING_SMSTATE_FINALIZING", 18: "CLEARING_SMSTATE_WITHDRAWING", 19: "CLEARING_SMSTATE_CONCLUDING", 20: "CLEARING_SMSTATE_FINAL", } ClearingSMState_value = map[string]int32{ "CLEARING_SMSTATE_UNSPECIFIED": 0, "CLEARING_SMSTATE_DEFAULT": 1, "CLEARING_SMSTATE_INSTANTIATING": 2, "CLEARING_SMSTATE_ACCEPTED": 3, "CLEARING_SMSTATE_FAILED": 4, "CLEARING_SMSTATE_INITIATOR_FUNDED": 5, "CLEARING_SMSTATE_FUNDED": 6, "CLEARING_SMSTATE_PRE_OP_CHALLENGING": 7, "CLEARING_SMSTATE_PENDING_PRE_OP_CHALLENGE_REGISTERED": 8, "CLEARING_SMSTATE_PRE_OP_CHALLENGE_REGISTERED": 9, "CLEARING_SMSTATE_OPERATIONAL": 10, "CLEARING_SMSTATE_PROCESSING_MARGIN_CALL": 11, "CLEARING_SMSTATE_ACTIVE_SETTLEMENT": 12, "CLEARING_SMSTATE_PROCESSING_POST_SETTLEMENT_MARGIN": 13, "CLEARING_SMSTATE_CHALLENGING": 14, "CLEARING_SMSTATE_PENDING_CHALLENGE_REGISTERED": 15, "CLEARING_SMSTATE_CHALLENGE_REGISTERED": 16, "CLEARING_SMSTATE_FINALIZING": 17, "CLEARING_SMSTATE_WITHDRAWING": 18, "CLEARING_SMSTATE_CONCLUDING": 19, "CLEARING_SMSTATE_FINAL": 20, } )
Enum value maps for ClearingSMState.
var Auth_ServiceDesc = grpc.ServiceDesc{ ServiceName: "auth.Auth", HandlerType: (*AuthServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetChallenge", Handler: _Auth_GetChallenge_Handler, }, { MethodName: "Authenticate", Handler: _Auth_Authenticate_Handler, }, { MethodName: "TokenRefresh", Handler: _Auth_TokenRefresh_Handler, }, { MethodName: "Signout", Handler: _Auth_Signout_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "auth.proto", }
Auth_ServiceDesc is the grpc.ServiceDesc for Auth service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Channel_ServiceDesc = grpc.ServiceDesc{ ServiceName: "Channel", HandlerType: (*ChannelServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Open", Handler: _Channel_Open_Handler, }, { MethodName: "Update", Handler: _Channel_Update_Handler, }, { MethodName: "Close", Handler: _Channel_Close_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "SubscribeTrades", Handler: _Channel_SubscribeTrades_Handler, ServerStreams: true, }, }, Metadata: "channel.proto", }
Channel_ServiceDesc is the grpc.ServiceDesc for Channel service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var EscrowChannel_ServiceDesc = grpc.ServiceDesc{ ServiceName: "EscrowChannel", HandlerType: (*EscrowChannelServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Prefund", Handler: _EscrowChannel_Prefund_Handler, }, { MethodName: "Postfund", Handler: _EscrowChannel_Postfund_Handler, }, { MethodName: "Execute", Handler: _EscrowChannel_Execute_Handler, }, { MethodName: "Finalize", Handler: _EscrowChannel_Finalize_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "escrow.proto", }
EscrowChannel_ServiceDesc is the grpc.ServiceDesc for EscrowChannel service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_auth_proto protoreflect.FileDescriptor
var File_channel_proto protoreflect.FileDescriptor
var File_clear_stream_proto protoreflect.FileDescriptor
var File_core_proto protoreflect.FileDescriptor
var File_escrow_proto protoreflect.FileDescriptor
var File_exit_proto protoreflect.FileDescriptor
var File_operator_proto protoreflect.FileDescriptor
var File_price_feed_proto protoreflect.FileDescriptor
var File_session_key_proto protoreflect.FileDescriptor
var File_settlement_proto protoreflect.FileDescriptor
var File_state_machine_proto protoreflect.FileDescriptor
var File_state_proto protoreflect.FileDescriptor
var File_trade_proto protoreflect.FileDescriptor
var Operator_ServiceDesc = grpc.ServiceDesc{ ServiceName: "Operator", HandlerType: (*OperatorServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetVersion", Handler: _Operator_GetVersion_Handler, }, { MethodName: "GetChallenge", Handler: _Operator_GetChallenge_Handler, }, { MethodName: "Authenticate", Handler: _Operator_Authenticate_Handler, }, { MethodName: "OpenChannel", Handler: _Operator_OpenChannel_Handler, }, { MethodName: "GetChannelJwt", Handler: _Operator_GetChannelJwt_Handler, }, { MethodName: "GetPositions", Handler: _Operator_GetPositions_Handler, }, { MethodName: "GetActiveClearStreams", Handler: _Operator_GetActiveClearStreams_Handler, }, { MethodName: "RecordTrade", Handler: _Operator_RecordTrade_Handler, }, { MethodName: "RecordTrades", Handler: _Operator_RecordTrades_Handler, }, { MethodName: "RequestSettlement", Handler: _Operator_RequestSettlement_Handler, }, { MethodName: "CloseChannel", Handler: _Operator_CloseChannel_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "SubscribeChannelsEvents", Handler: _Operator_SubscribeChannelsEvents_Handler, ServerStreams: true, }, }, Metadata: "operator.proto", }
Operator_ServiceDesc is the grpc.ServiceDesc for Operator service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var PriceFeed_ServiceDesc = grpc.ServiceDesc{ ServiceName: "PriceFeed", HandlerType: (*PriceFeedServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Subscribe", Handler: _PriceFeed_Subscribe_Handler, ServerStreams: true, }, }, Metadata: "price_feed.proto", }
PriceFeed_ServiceDesc is the grpc.ServiceDesc for PriceFeed service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var SettlementService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "settlement.SettlementService", HandlerType: (*SettlementServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Prepare", Handler: _SettlementService_Prepare_Handler, }, { MethodName: "Update", Handler: _SettlementService_Update_Handler, }, { MethodName: "Finalize", Handler: _SettlementService_Finalize_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "settlement.proto", }
SettlementService_ServiceDesc is the grpc.ServiceDesc for SettlementService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var TradeChannel_ServiceDesc = grpc.ServiceDesc{ ServiceName: "TradeChannel", HandlerType: (*TradeChannelServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Prefund", Handler: _TradeChannel_Prefund_Handler, }, { MethodName: "Postfund", Handler: _TradeChannel_Postfund_Handler, }, { MethodName: "UpdateMargin", Handler: _TradeChannel_UpdateMargin_Handler, }, { MethodName: "RequestSettlement", Handler: _TradeChannel_RequestSettlement_Handler, }, { MethodName: "Finalize", Handler: _TradeChannel_Finalize_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "trade.proto", }
TradeChannel_ServiceDesc is the grpc.ServiceDesc for TradeChannel service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterAuthServer ¶
func RegisterAuthServer(s grpc.ServiceRegistrar, srv AuthServer)
func RegisterChannelServer ¶
func RegisterChannelServer(s grpc.ServiceRegistrar, srv ChannelServer)
func RegisterEscrowChannelServer ¶
func RegisterEscrowChannelServer(s grpc.ServiceRegistrar, srv EscrowChannelServer)
func RegisterOperatorServer ¶
func RegisterOperatorServer(s grpc.ServiceRegistrar, srv OperatorServer)
func RegisterPriceFeedServer ¶ added in v0.0.23
func RegisterPriceFeedServer(s grpc.ServiceRegistrar, srv PriceFeedServer)
func RegisterSettlementServiceServer ¶
func RegisterSettlementServiceServer(s grpc.ServiceRegistrar, srv SettlementServiceServer)
func RegisterTradeChannelServer ¶
func RegisterTradeChannelServer(s grpc.ServiceRegistrar, srv TradeChannelServer)
Types ¶
type Address ¶
type Address struct { Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
* A 42-character hexadecimal address derived from the last 20 bytes of the public key
func (*Address) Descriptor
deprecated
func (*Address) ProtoMessage ¶
func (*Address) ProtoMessage()
func (*Address) ProtoReflect ¶
func (x *Address) ProtoReflect() protoreflect.Message
type Allocation ¶
type Allocation struct { Destination []byte `protobuf:"bytes,1,opt,name=destination,proto3" json:"destination,omitempty"` // bytes32 in solidity Amount string `protobuf:"bytes,2,opt,name=amount,proto3" json:"amount,omitempty"` // big.Int cast to string AllocationType AllocationType `` /* 132-byte string literal not displayed */ Metadata []byte `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"` // contains filtered or unexported fields }
func (*Allocation) Descriptor
deprecated
func (*Allocation) Descriptor() ([]byte, []int)
Deprecated: Use Allocation.ProtoReflect.Descriptor instead.
func (*Allocation) GetAllocationType ¶
func (x *Allocation) GetAllocationType() AllocationType
func (*Allocation) GetAmount ¶
func (x *Allocation) GetAmount() string
func (*Allocation) GetDestination ¶
func (x *Allocation) GetDestination() []byte
func (*Allocation) GetMetadata ¶
func (x *Allocation) GetMetadata() []byte
func (*Allocation) ProtoMessage ¶
func (*Allocation) ProtoMessage()
func (*Allocation) ProtoReflect ¶
func (x *Allocation) ProtoReflect() protoreflect.Message
func (*Allocation) Reset ¶
func (x *Allocation) Reset()
func (*Allocation) String ¶
func (x *Allocation) String() string
type AllocationType ¶
type AllocationType int32
const ( AllocationType_ALLOCATION_TYPE_UNSPECIFIED AllocationType = 0 AllocationType_ALLOCATION_TYPE_WITHDRAW_HELPER AllocationType = 1 AllocationType_ALLOCATION_TYPE_GUARANTEE AllocationType = 2 )
func (AllocationType) Descriptor ¶
func (AllocationType) Descriptor() protoreflect.EnumDescriptor
func (AllocationType) Enum ¶
func (x AllocationType) Enum() *AllocationType
func (AllocationType) EnumDescriptor
deprecated
func (AllocationType) EnumDescriptor() ([]byte, []int)
Deprecated: Use AllocationType.Descriptor instead.
func (AllocationType) Number ¶
func (x AllocationType) Number() protoreflect.EnumNumber
func (AllocationType) String ¶
func (x AllocationType) String() string
func (AllocationType) Type ¶
func (AllocationType) Type() protoreflect.EnumType
type Asset ¶
type Asset struct { Symbol string `protobuf:"bytes,1,opt,name=symbol,proto3" json:"symbol,omitempty"` ChainId uint64 `protobuf:"varint,2,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` Address *Address `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"` Decimals uint32 `protobuf:"varint,4,opt,name=decimals,proto3" json:"decimals,omitempty"` // contains filtered or unexported fields }
func (*Asset) Descriptor
deprecated
func (*Asset) GetAddress ¶
func (*Asset) GetChainId ¶
func (*Asset) GetDecimals ¶
func (*Asset) ProtoMessage ¶
func (*Asset) ProtoMessage()
func (*Asset) ProtoReflect ¶
func (x *Asset) ProtoReflect() protoreflect.Message
type AssetMetadata ¶
type AssetMetadata struct { AssetType AssetType `protobuf:"varint,1,opt,name=asset_type,json=assetType,proto3,enum=outcome.AssetType" json:"asset_type,omitempty"` Metadata []byte `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"` // contains filtered or unexported fields }
func (*AssetMetadata) Descriptor
deprecated
func (*AssetMetadata) Descriptor() ([]byte, []int)
Deprecated: Use AssetMetadata.ProtoReflect.Descriptor instead.
func (*AssetMetadata) GetAssetType ¶
func (x *AssetMetadata) GetAssetType() AssetType
func (*AssetMetadata) GetMetadata ¶
func (x *AssetMetadata) GetMetadata() []byte
func (*AssetMetadata) ProtoMessage ¶
func (*AssetMetadata) ProtoMessage()
func (*AssetMetadata) ProtoReflect ¶
func (x *AssetMetadata) ProtoReflect() protoreflect.Message
func (*AssetMetadata) Reset ¶
func (x *AssetMetadata) Reset()
func (*AssetMetadata) String ¶
func (x *AssetMetadata) String() string
type AssetType ¶
type AssetType int32
func (AssetType) Descriptor ¶
func (AssetType) Descriptor() protoreflect.EnumDescriptor
func (AssetType) EnumDescriptor
deprecated
func (AssetType) Number ¶
func (x AssetType) Number() protoreflect.EnumNumber
func (AssetType) Type ¶
func (AssetType) Type() protoreflect.EnumType
type AuthClient ¶
type AuthClient interface { GetChallenge(ctx context.Context, in *ChallengeRequest, opts ...grpc.CallOption) (*ChallengeResponse, error) Authenticate(ctx context.Context, in *SignedChallenge, opts ...grpc.CallOption) (*AuthToken, error) TokenRefresh(ctx context.Context, in *AuthToken, opts ...grpc.CallOption) (*AuthToken, error) Signout(ctx context.Context, in *AuthToken, opts ...grpc.CallOption) (*SignoutResponse, error) }
AuthClient is the client API for Auth service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewAuthClient ¶
func NewAuthClient(cc grpc.ClientConnInterface) AuthClient
type AuthServer ¶
type AuthServer interface { GetChallenge(context.Context, *ChallengeRequest) (*ChallengeResponse, error) Authenticate(context.Context, *SignedChallenge) (*AuthToken, error) TokenRefresh(context.Context, *AuthToken) (*AuthToken, error) Signout(context.Context, *AuthToken) (*SignoutResponse, error) // contains filtered or unexported methods }
AuthServer is the server API for Auth service. All implementations must embed UnimplementedAuthServer for forward compatibility
type AuthToken ¶
type AuthToken struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` // contains filtered or unexported fields }
AuthToken can be attached in headers
func (*AuthToken) Descriptor
deprecated
func (*AuthToken) ProtoMessage ¶
func (*AuthToken) ProtoMessage()
func (*AuthToken) ProtoReflect ¶
func (x *AuthToken) ProtoReflect() protoreflect.Message
type AuthenticateRequest ¶
type AuthenticateRequest struct { Signature string `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` Address *Address `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"` // contains filtered or unexported fields }
func (*AuthenticateRequest) Descriptor
deprecated
func (*AuthenticateRequest) Descriptor() ([]byte, []int)
Deprecated: Use AuthenticateRequest.ProtoReflect.Descriptor instead.
func (*AuthenticateRequest) GetAddress ¶ added in v0.0.27
func (x *AuthenticateRequest) GetAddress() *Address
func (*AuthenticateRequest) GetSignature ¶
func (x *AuthenticateRequest) GetSignature() string
func (*AuthenticateRequest) ProtoMessage ¶
func (*AuthenticateRequest) ProtoMessage()
func (*AuthenticateRequest) ProtoReflect ¶
func (x *AuthenticateRequest) ProtoReflect() protoreflect.Message
func (*AuthenticateRequest) Reset ¶
func (x *AuthenticateRequest) Reset()
func (*AuthenticateRequest) String ¶
func (x *AuthenticateRequest) String() string
type AuthenticateResponse ¶
type AuthenticateResponse struct { Jwt string `protobuf:"bytes,1,opt,name=jwt,proto3" json:"jwt,omitempty"` // contains filtered or unexported fields }
func (*AuthenticateResponse) Descriptor
deprecated
func (*AuthenticateResponse) Descriptor() ([]byte, []int)
Deprecated: Use AuthenticateResponse.ProtoReflect.Descriptor instead.
func (*AuthenticateResponse) GetJwt ¶
func (x *AuthenticateResponse) GetJwt() string
func (*AuthenticateResponse) ProtoMessage ¶
func (*AuthenticateResponse) ProtoMessage()
func (*AuthenticateResponse) ProtoReflect ¶
func (x *AuthenticateResponse) ProtoReflect() protoreflect.Message
func (*AuthenticateResponse) Reset ¶
func (x *AuthenticateResponse) Reset()
func (*AuthenticateResponse) String ¶
func (x *AuthenticateResponse) String() string
type BigInt ¶ added in v0.0.103
type BigInt struct { Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*BigInt) Descriptor
deprecated
added in
v0.0.103
func (*BigInt) ProtoMessage ¶ added in v0.0.103
func (*BigInt) ProtoMessage()
func (*BigInt) ProtoReflect ¶ added in v0.0.103
func (x *BigInt) ProtoReflect() protoreflect.Message
type ChallengeRequest ¶
type ChallengeRequest struct { Client *Peer `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"` ServerOperatorAddress string `` /* 126-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ChallengeRequest) Descriptor
deprecated
func (*ChallengeRequest) Descriptor() ([]byte, []int)
Deprecated: Use ChallengeRequest.ProtoReflect.Descriptor instead.
func (*ChallengeRequest) GetClient ¶
func (x *ChallengeRequest) GetClient() *Peer
func (*ChallengeRequest) GetServerOperatorAddress ¶ added in v0.0.27
func (x *ChallengeRequest) GetServerOperatorAddress() string
func (*ChallengeRequest) ProtoMessage ¶
func (*ChallengeRequest) ProtoMessage()
func (*ChallengeRequest) ProtoReflect ¶
func (x *ChallengeRequest) ProtoReflect() protoreflect.Message
func (*ChallengeRequest) Reset ¶
func (x *ChallengeRequest) Reset()
func (*ChallengeRequest) String ¶
func (x *ChallengeRequest) String() string
type ChallengeResponse ¶
type ChallengeResponse struct { Server *Peer `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"` ServerChallenge string `protobuf:"bytes,2,opt,name=server_challenge,json=serverChallenge,proto3" json:"server_challenge,omitempty"` // contains filtered or unexported fields }
Server signs the client's challenge
func (*ChallengeResponse) Descriptor
deprecated
func (*ChallengeResponse) Descriptor() ([]byte, []int)
Deprecated: Use ChallengeResponse.ProtoReflect.Descriptor instead.
func (*ChallengeResponse) GetServer ¶
func (x *ChallengeResponse) GetServer() *Peer
func (*ChallengeResponse) GetServerChallenge ¶
func (x *ChallengeResponse) GetServerChallenge() string
func (*ChallengeResponse) ProtoMessage ¶
func (*ChallengeResponse) ProtoMessage()
func (*ChallengeResponse) ProtoReflect ¶
func (x *ChallengeResponse) ProtoReflect() protoreflect.Message
func (*ChallengeResponse) Reset ¶
func (x *ChallengeResponse) Reset()
func (*ChallengeResponse) String ¶
func (x *ChallengeResponse) String() string
type ChannelClient ¶
type ChannelClient interface { Open(ctx context.Context, in *ChannelState, opts ...grpc.CallOption) (*Signature, error) Update(ctx context.Context, in *ChannelState, opts ...grpc.CallOption) (*Signature, error) Close(ctx context.Context, in *ChannelState, opts ...grpc.CallOption) (*Signature, error) SubscribeTrades(ctx context.Context, in *SubscribeTradesRequest, opts ...grpc.CallOption) (Channel_SubscribeTradesClient, error) }
ChannelClient is the client API for Channel service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewChannelClient ¶
func NewChannelClient(cc grpc.ClientConnInterface) ChannelClient
type ChannelServer ¶
type ChannelServer interface { Open(context.Context, *ChannelState) (*Signature, error) Update(context.Context, *ChannelState) (*Signature, error) Close(context.Context, *ChannelState) (*Signature, error) SubscribeTrades(*SubscribeTradesRequest, Channel_SubscribeTradesServer) error // contains filtered or unexported methods }
ChannelServer is the server API for Channel service. All implementations must embed UnimplementedChannelServer for forward compatibility
type ChannelState ¶
type ChannelState struct { State *State `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"` StateHash string `protobuf:"bytes,2,opt,name=state_hash,json=stateHash,proto3" json:"state_hash,omitempty"` StateSig *Signature `protobuf:"bytes,3,opt,name=state_sig,json=stateSig,proto3" json:"state_sig,omitempty"` // contains filtered or unexported fields }
func (*ChannelState) Descriptor
deprecated
func (*ChannelState) Descriptor() ([]byte, []int)
Deprecated: Use ChannelState.ProtoReflect.Descriptor instead.
func (*ChannelState) GetState ¶
func (x *ChannelState) GetState() *State
func (*ChannelState) GetStateHash ¶
func (x *ChannelState) GetStateHash() string
func (*ChannelState) GetStateSig ¶
func (x *ChannelState) GetStateSig() *Signature
func (*ChannelState) ProtoMessage ¶
func (*ChannelState) ProtoMessage()
func (*ChannelState) ProtoReflect ¶
func (x *ChannelState) ProtoReflect() protoreflect.Message
func (*ChannelState) Reset ¶
func (x *ChannelState) Reset()
func (*ChannelState) String ¶
func (x *ChannelState) String() string
type Channel_SubscribeTradesClient ¶ added in v0.0.74
type Channel_SubscribeTradesClient interface { Recv() (*Trade, error) grpc.ClientStream }
type Channel_SubscribeTradesServer ¶ added in v0.0.74
type Channel_SubscribeTradesServer interface { Send(*Trade) error grpc.ServerStream }
type ClearStream ¶ added in v0.0.106
type ClearStream struct { ChannelId string `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` Positions []*Position `protobuf:"bytes,2,rep,name=positions,proto3" json:"positions,omitempty"` // contains filtered or unexported fields }
ClearStream is aggregated message about status of the clearing protocol instance, including the nitro channel portfolio and settlement statuses
func (*ClearStream) Descriptor
deprecated
added in
v0.0.106
func (*ClearStream) Descriptor() ([]byte, []int)
Deprecated: Use ClearStream.ProtoReflect.Descriptor instead.
func (*ClearStream) GetChannelId ¶ added in v0.0.106
func (x *ClearStream) GetChannelId() string
func (*ClearStream) GetPositions ¶ added in v0.0.106
func (x *ClearStream) GetPositions() []*Position
func (*ClearStream) ProtoMessage ¶ added in v0.0.106
func (*ClearStream) ProtoMessage()
func (*ClearStream) ProtoReflect ¶ added in v0.0.106
func (x *ClearStream) ProtoReflect() protoreflect.Message
func (*ClearStream) Reset ¶ added in v0.0.106
func (x *ClearStream) Reset()
func (*ClearStream) String ¶ added in v0.0.106
func (x *ClearStream) String() string
type ClearingEvent ¶ added in v0.0.122
type ClearingEvent int32
const ( ClearingEvent_CLEARING_EVENT_UNSPECIFIED ClearingEvent = 0 ClearingEvent_CLEARING_EVENT_INSTANTIATED ClearingEvent = 1 ClearingEvent_CLEARING_EVENT_ACCEPTED ClearingEvent = 2 ClearingEvent_CLEARING_EVENT_FAILED ClearingEvent = 3 ClearingEvent_CLEARING_EVENT_INITIATOR_FUNDED ClearingEvent = 4 ClearingEvent_CLEARING_EVENT_RESPONDER_FUNDED ClearingEvent = 5 ClearingEvent_CLEARING_EVENT_POSTFUND_PROPOSED ClearingEvent = 6 ClearingEvent_CLEARING_EVENT_AGREED_ON_POSTFUND ClearingEvent = 7 ClearingEvent_CLEARING_EVENT_MOVE_TO_OPERATIONAL ClearingEvent = 8 ClearingEvent_CLEARING_EVENT_PROCESS_MARGIN_CALL ClearingEvent = 9 ClearingEvent_CLEARING_EVENT_STARTED_SETTLEMENT ClearingEvent = 10 ClearingEvent_CLEARING_EVENT_PROCESS_POST_SETTLEMENT_MARGIN ClearingEvent = 11 ClearingEvent_CLEARING_EVENT_FINALIZE_SETTLEMENT ClearingEvent = 12 ClearingEvent_CLEARING_EVENT_FAILED_SETTLEMENT ClearingEvent = 13 ClearingEvent_CLEARING_EVENT_CHALLENGE ClearingEvent = 14 ClearingEvent_CLEARING_EVENT_FINALIZE ClearingEvent = 15 ClearingEvent_CLEARING_EVENT_WITHDRAW ClearingEvent = 16 ClearingEvent_CLEARING_EVENT_CLEAR_CHALLENGE ClearingEvent = 17 ClearingEvent_CLEARING_EVENT_TIMEOUT_CHALLENGE ClearingEvent = 18 )
func (ClearingEvent) Descriptor ¶ added in v0.0.122
func (ClearingEvent) Descriptor() protoreflect.EnumDescriptor
func (ClearingEvent) Enum ¶ added in v0.0.122
func (x ClearingEvent) Enum() *ClearingEvent
func (ClearingEvent) EnumDescriptor
deprecated
added in
v0.0.122
func (ClearingEvent) EnumDescriptor() ([]byte, []int)
Deprecated: Use ClearingEvent.Descriptor instead.
func (ClearingEvent) Number ¶ added in v0.0.122
func (x ClearingEvent) Number() protoreflect.EnumNumber
func (ClearingEvent) String ¶ added in v0.0.122
func (x ClearingEvent) String() string
func (ClearingEvent) Type ¶ added in v0.0.122
func (ClearingEvent) Type() protoreflect.EnumType
type ClearingSMState ¶ added in v0.0.67
type ClearingSMState int32
const ( ClearingSMState_CLEARING_SMSTATE_UNSPECIFIED ClearingSMState = 0 ClearingSMState_CLEARING_SMSTATE_DEFAULT ClearingSMState = 1 ClearingSMState_CLEARING_SMSTATE_INSTANTIATING ClearingSMState = 2 ClearingSMState_CLEARING_SMSTATE_ACCEPTED ClearingSMState = 3 ClearingSMState_CLEARING_SMSTATE_FAILED ClearingSMState = 4 ClearingSMState_CLEARING_SMSTATE_INITIATOR_FUNDED ClearingSMState = 5 ClearingSMState_CLEARING_SMSTATE_FUNDED ClearingSMState = 6 ClearingSMState_CLEARING_SMSTATE_PRE_OP_CHALLENGING ClearingSMState = 7 ClearingSMState_CLEARING_SMSTATE_PENDING_PRE_OP_CHALLENGE_REGISTERED ClearingSMState = 8 ClearingSMState_CLEARING_SMSTATE_PRE_OP_CHALLENGE_REGISTERED ClearingSMState = 9 ClearingSMState_CLEARING_SMSTATE_OPERATIONAL ClearingSMState = 10 ClearingSMState_CLEARING_SMSTATE_PROCESSING_MARGIN_CALL ClearingSMState = 11 ClearingSMState_CLEARING_SMSTATE_ACTIVE_SETTLEMENT ClearingSMState = 12 ClearingSMState_CLEARING_SMSTATE_PROCESSING_POST_SETTLEMENT_MARGIN ClearingSMState = 13 ClearingSMState_CLEARING_SMSTATE_CHALLENGING ClearingSMState = 14 ClearingSMState_CLEARING_SMSTATE_PENDING_CHALLENGE_REGISTERED ClearingSMState = 15 ClearingSMState_CLEARING_SMSTATE_CHALLENGE_REGISTERED ClearingSMState = 16 ClearingSMState_CLEARING_SMSTATE_FINALIZING ClearingSMState = 17 ClearingSMState_CLEARING_SMSTATE_WITHDRAWING ClearingSMState = 18 ClearingSMState_CLEARING_SMSTATE_CONCLUDING ClearingSMState = 19 ClearingSMState_CLEARING_SMSTATE_FINAL ClearingSMState = 20 )
func (ClearingSMState) Descriptor ¶ added in v0.0.67
func (ClearingSMState) Descriptor() protoreflect.EnumDescriptor
func (ClearingSMState) Enum ¶ added in v0.0.67
func (x ClearingSMState) Enum() *ClearingSMState
func (ClearingSMState) EnumDescriptor
deprecated
added in
v0.0.67
func (ClearingSMState) EnumDescriptor() ([]byte, []int)
Deprecated: Use ClearingSMState.Descriptor instead.
func (ClearingSMState) Number ¶ added in v0.0.67
func (x ClearingSMState) Number() protoreflect.EnumNumber
func (ClearingSMState) String ¶ added in v0.0.67
func (x ClearingSMState) String() string
func (ClearingSMState) Type ¶ added in v0.0.67
func (ClearingSMState) Type() protoreflect.EnumType
type ClearingState ¶ added in v0.0.122
type ClearingState int32
const ( ClearingState_CLEARING_STATE_UNSPECIFIED ClearingState = 0 ClearingState_CLEARING_STATE_INSTANTIATED ClearingState = 1 ClearingState_CLEARING_STATE_ACCEPTED ClearingState = 2 ClearingState_CLEARING_STATE_FAILED ClearingState = 3 ClearingState_CLEARING_STATE_INITIATOR_FUNDED ClearingState = 4 ClearingState_CLEARING_STATE_FUNDED ClearingState = 5 ClearingState_CLEARING_STATE_OPERATIONAL ClearingState = 6 ClearingState_CLEARING_STATE_ISSUING_MARGIN_CALL ClearingState = 7 ClearingState_CLEARING_STATE_PROCESSING_MARGIN_CALL ClearingState = 8 ClearingState_CLEARING_STATE_ACTIVE_SETTLEMENT ClearingState = 9 ClearingState_CLEARING_STATE_ISSUING_POST_SETTLEMENT_MARGIN ClearingState = 10 ClearingState_CLEARING_STATE_PROCESSING_POST_SETTLEMENT_MARGIN ClearingState = 11 ClearingState_CLEARING_STATE_CHALLENGING ClearingState = 12 ClearingState_CLEARING_STATE_FINALIZING ClearingState = 13 ClearingState_CLEARING_STATE_WITHDRAWING ClearingState = 14 ClearingState_CLEARING_STATE_CONCLUDING ClearingState = 15 ClearingState_CLEARING_STATE_DEFAULT ClearingState = 16 )
func (ClearingState) Descriptor ¶ added in v0.0.122
func (ClearingState) Descriptor() protoreflect.EnumDescriptor
func (ClearingState) Enum ¶ added in v0.0.122
func (x ClearingState) Enum() *ClearingState
func (ClearingState) EnumDescriptor
deprecated
added in
v0.0.122
func (ClearingState) EnumDescriptor() ([]byte, []int)
Deprecated: Use ClearingState.Descriptor instead.
func (ClearingState) Number ¶ added in v0.0.122
func (x ClearingState) Number() protoreflect.EnumNumber
func (ClearingState) String ¶ added in v0.0.122
func (x ClearingState) String() string
func (ClearingState) Type ¶ added in v0.0.122
func (ClearingState) Type() protoreflect.EnumType
type CloseChannelRequest ¶
type CloseChannelRequest struct { ChannelId string `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` // contains filtered or unexported fields }
func (*CloseChannelRequest) Descriptor
deprecated
func (*CloseChannelRequest) Descriptor() ([]byte, []int)
Deprecated: Use CloseChannelRequest.ProtoReflect.Descriptor instead.
func (*CloseChannelRequest) GetChannelId ¶
func (x *CloseChannelRequest) GetChannelId() string
func (*CloseChannelRequest) ProtoMessage ¶
func (*CloseChannelRequest) ProtoMessage()
func (*CloseChannelRequest) ProtoReflect ¶
func (x *CloseChannelRequest) ProtoReflect() protoreflect.Message
func (*CloseChannelRequest) Reset ¶
func (x *CloseChannelRequest) Reset()
func (*CloseChannelRequest) String ¶
func (x *CloseChannelRequest) String() string
type CloseChannelResponse ¶
type CloseChannelResponse struct {
// contains filtered or unexported fields
}
func (*CloseChannelResponse) Descriptor
deprecated
func (*CloseChannelResponse) Descriptor() ([]byte, []int)
Deprecated: Use CloseChannelResponse.ProtoReflect.Descriptor instead.
func (*CloseChannelResponse) ProtoMessage ¶
func (*CloseChannelResponse) ProtoMessage()
func (*CloseChannelResponse) ProtoReflect ¶
func (x *CloseChannelResponse) ProtoReflect() protoreflect.Message
func (*CloseChannelResponse) Reset ¶
func (x *CloseChannelResponse) Reset()
func (*CloseChannelResponse) String ¶
func (x *CloseChannelResponse) String() string
type Decimal ¶
type Decimal struct { Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
Represent Decimal as a string Can be changed to 2 numbers Due to compatibility issues we may need To create a new Decimal type compatible with ExitFormat
func (*Decimal) Descriptor
deprecated
func (*Decimal) ProtoMessage ¶
func (*Decimal) ProtoMessage()
func (*Decimal) ProtoReflect ¶
func (x *Decimal) ProtoReflect() protoreflect.Message
type Direction ¶
type Direction int32
func (Direction) Descriptor ¶
func (Direction) Descriptor() protoreflect.EnumDescriptor
func (Direction) EnumDescriptor
deprecated
func (Direction) Number ¶
func (x Direction) Number() protoreflect.EnumNumber
func (Direction) Type ¶
func (Direction) Type() protoreflect.EnumType
type ErrorMetadata ¶ added in v0.0.8
type ErrorMetadata struct { ChannelId string `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` State string `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"` Event string `protobuf:"bytes,4,opt,name=event,proto3" json:"event,omitempty"` // contains filtered or unexported fields }
func (*ErrorMetadata) Descriptor
deprecated
added in
v0.0.8
func (*ErrorMetadata) Descriptor() ([]byte, []int)
Deprecated: Use ErrorMetadata.ProtoReflect.Descriptor instead.
func (*ErrorMetadata) GetChannelId ¶ added in v0.0.8
func (x *ErrorMetadata) GetChannelId() string
func (*ErrorMetadata) GetEvent ¶ added in v0.0.15
func (x *ErrorMetadata) GetEvent() string
func (*ErrorMetadata) GetState ¶ added in v0.0.15
func (x *ErrorMetadata) GetState() string
func (*ErrorMetadata) ProtoMessage ¶ added in v0.0.8
func (*ErrorMetadata) ProtoMessage()
func (*ErrorMetadata) ProtoReflect ¶ added in v0.0.8
func (x *ErrorMetadata) ProtoReflect() protoreflect.Message
func (*ErrorMetadata) Reset ¶ added in v0.0.8
func (x *ErrorMetadata) Reset()
func (*ErrorMetadata) String ¶ added in v0.0.8
func (x *ErrorMetadata) String() string
type ErrorNotification ¶ added in v0.0.8
type ErrorNotification struct { Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Metadata *ErrorMetadata `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"` Action string `protobuf:"bytes,5,opt,name=action,proto3" json:"action,omitempty"` // contains filtered or unexported fields }
func (*ErrorNotification) Descriptor
deprecated
added in
v0.0.8
func (*ErrorNotification) Descriptor() ([]byte, []int)
Deprecated: Use ErrorNotification.ProtoReflect.Descriptor instead.
func (*ErrorNotification) GetAction ¶ added in v0.0.15
func (x *ErrorNotification) GetAction() string
func (*ErrorNotification) GetMetadata ¶ added in v0.0.8
func (x *ErrorNotification) GetMetadata() *ErrorMetadata
func (*ErrorNotification) GetMsg ¶ added in v0.0.8
func (x *ErrorNotification) GetMsg() string
func (*ErrorNotification) ProtoMessage ¶ added in v0.0.8
func (*ErrorNotification) ProtoMessage()
func (*ErrorNotification) ProtoReflect ¶ added in v0.0.8
func (x *ErrorNotification) ProtoReflect() protoreflect.Message
func (*ErrorNotification) Reset ¶ added in v0.0.8
func (x *ErrorNotification) Reset()
func (*ErrorNotification) String ¶ added in v0.0.8
func (x *ErrorNotification) String() string
type EscrowChannelClient ¶
type EscrowChannelClient interface { Prefund(ctx context.Context, in *EscrowState, opts ...grpc.CallOption) (*EscrowState, error) Postfund(ctx context.Context, in *EscrowState, opts ...grpc.CallOption) (*EscrowState, error) Execute(ctx context.Context, in *EscrowState, opts ...grpc.CallOption) (*EscrowState, error) Finalize(ctx context.Context, in *EscrowState, opts ...grpc.CallOption) (*EscrowState, error) }
EscrowChannelClient is the client API for EscrowChannel service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewEscrowChannelClient ¶
func NewEscrowChannelClient(cc grpc.ClientConnInterface) EscrowChannelClient
type EscrowChannelServer ¶
type EscrowChannelServer interface { Prefund(context.Context, *EscrowState) (*EscrowState, error) Postfund(context.Context, *EscrowState) (*EscrowState, error) Execute(context.Context, *EscrowState) (*EscrowState, error) Finalize(context.Context, *EscrowState) (*EscrowState, error) // contains filtered or unexported methods }
EscrowChannelServer is the server API for EscrowChannel service. All implementations must embed UnimplementedEscrowChannelServer for forward compatibility
type EscrowState ¶
type EscrowState struct { ChannelId []byte `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` State *State `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"` StateHash []byte `protobuf:"bytes,3,opt,name=state_hash,json=stateHash,proto3" json:"state_hash,omitempty"` StateHashSigs []*Signature `protobuf:"bytes,4,rep,name=state_hash_sigs,json=stateHashSigs,proto3" json:"state_hash_sigs,omitempty"` // TODO: Find how to correction bind TradeChannel, // Settlements and EscrowChannels // Keep in mind that and EscrowChannels // is a type of settlement options. SettlementId uint64 `protobuf:"varint,5,opt,name=settlement_id,json=settlementId,proto3" json:"settlement_id,omitempty"` // contains filtered or unexported fields }
Message Trading Channel state definition
func (*EscrowState) Descriptor
deprecated
func (*EscrowState) Descriptor() ([]byte, []int)
Deprecated: Use EscrowState.ProtoReflect.Descriptor instead.
func (*EscrowState) GetChannelId ¶
func (x *EscrowState) GetChannelId() []byte
func (*EscrowState) GetSettlementId ¶
func (x *EscrowState) GetSettlementId() uint64
func (*EscrowState) GetState ¶
func (x *EscrowState) GetState() *State
func (*EscrowState) GetStateHash ¶
func (x *EscrowState) GetStateHash() []byte
func (*EscrowState) GetStateHashSigs ¶
func (x *EscrowState) GetStateHashSigs() []*Signature
func (*EscrowState) ProtoMessage ¶
func (*EscrowState) ProtoMessage()
func (*EscrowState) ProtoReflect ¶
func (x *EscrowState) ProtoReflect() protoreflect.Message
func (*EscrowState) Reset ¶
func (x *EscrowState) Reset()
func (*EscrowState) String ¶
func (x *EscrowState) String() string
type Exit ¶
type Exit struct { SingleAssetExits []*SingleAssetExit `protobuf:"bytes,1,rep,name=single_asset_exits,json=singleAssetExits,proto3" json:"single_asset_exits,omitempty"` // contains filtered or unexported fields }
func (*Exit) Descriptor
deprecated
func (*Exit) GetSingleAssetExits ¶
func (x *Exit) GetSingleAssetExits() []*SingleAssetExit
func (*Exit) ProtoMessage ¶
func (*Exit) ProtoMessage()
func (*Exit) ProtoReflect ¶
func (x *Exit) ProtoReflect() protoreflect.Message
type FinalizeRequest ¶
type FinalizeRequest struct { Cid string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"` // contains filtered or unexported fields }
func (*FinalizeRequest) Descriptor
deprecated
func (*FinalizeRequest) Descriptor() ([]byte, []int)
Deprecated: Use FinalizeRequest.ProtoReflect.Descriptor instead.
func (*FinalizeRequest) GetCid ¶
func (x *FinalizeRequest) GetCid() string
func (*FinalizeRequest) ProtoMessage ¶
func (*FinalizeRequest) ProtoMessage()
func (*FinalizeRequest) ProtoReflect ¶
func (x *FinalizeRequest) ProtoReflect() protoreflect.Message
func (*FinalizeRequest) Reset ¶
func (x *FinalizeRequest) Reset()
func (*FinalizeRequest) String ¶
func (x *FinalizeRequest) String() string
type FinalizeResponse ¶
type FinalizeResponse struct { State SettlementState `protobuf:"varint,1,opt,name=state,proto3,enum=settlement.SettlementState" json:"state,omitempty"` // contains filtered or unexported fields }
func (*FinalizeResponse) Descriptor
deprecated
func (*FinalizeResponse) Descriptor() ([]byte, []int)
Deprecated: Use FinalizeResponse.ProtoReflect.Descriptor instead.
func (*FinalizeResponse) GetState ¶
func (x *FinalizeResponse) GetState() SettlementState
func (*FinalizeResponse) ProtoMessage ¶
func (*FinalizeResponse) ProtoMessage()
func (*FinalizeResponse) ProtoReflect ¶
func (x *FinalizeResponse) ProtoReflect() protoreflect.Message
func (*FinalizeResponse) Reset ¶
func (x *FinalizeResponse) Reset()
func (*FinalizeResponse) String ¶
func (x *FinalizeResponse) String() string
type GetActiveClearStreamsRequest ¶ added in v0.0.106
type GetActiveClearStreamsRequest struct {
// contains filtered or unexported fields
}
func (*GetActiveClearStreamsRequest) Descriptor
deprecated
added in
v0.0.106
func (*GetActiveClearStreamsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetActiveClearStreamsRequest.ProtoReflect.Descriptor instead.
func (*GetActiveClearStreamsRequest) ProtoMessage ¶ added in v0.0.106
func (*GetActiveClearStreamsRequest) ProtoMessage()
func (*GetActiveClearStreamsRequest) ProtoReflect ¶ added in v0.0.106
func (x *GetActiveClearStreamsRequest) ProtoReflect() protoreflect.Message
func (*GetActiveClearStreamsRequest) Reset ¶ added in v0.0.106
func (x *GetActiveClearStreamsRequest) Reset()
func (*GetActiveClearStreamsRequest) String ¶ added in v0.0.106
func (x *GetActiveClearStreamsRequest) String() string
type GetActiveClearStreamsResponse ¶ added in v0.0.106
type GetActiveClearStreamsResponse struct { ClearStreams []*ClearStream `protobuf:"bytes,1,rep,name=clear_streams,json=clearStreams,proto3" json:"clear_streams,omitempty"` // contains filtered or unexported fields }
func (*GetActiveClearStreamsResponse) Descriptor
deprecated
added in
v0.0.106
func (*GetActiveClearStreamsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetActiveClearStreamsResponse.ProtoReflect.Descriptor instead.
func (*GetActiveClearStreamsResponse) GetClearStreams ¶ added in v0.0.106
func (x *GetActiveClearStreamsResponse) GetClearStreams() []*ClearStream
func (*GetActiveClearStreamsResponse) ProtoMessage ¶ added in v0.0.106
func (*GetActiveClearStreamsResponse) ProtoMessage()
func (*GetActiveClearStreamsResponse) ProtoReflect ¶ added in v0.0.106
func (x *GetActiveClearStreamsResponse) ProtoReflect() protoreflect.Message
func (*GetActiveClearStreamsResponse) Reset ¶ added in v0.0.106
func (x *GetActiveClearStreamsResponse) Reset()
func (*GetActiveClearStreamsResponse) String ¶ added in v0.0.106
func (x *GetActiveClearStreamsResponse) String() string
type GetChallengeRequest ¶
type GetChallengeRequest struct { Address *Address `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*GetChallengeRequest) Descriptor
deprecated
func (*GetChallengeRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetChallengeRequest.ProtoReflect.Descriptor instead.
func (*GetChallengeRequest) GetAddress ¶ added in v0.0.27
func (x *GetChallengeRequest) GetAddress() *Address
func (*GetChallengeRequest) GetName ¶ added in v0.0.27
func (x *GetChallengeRequest) GetName() string
func (*GetChallengeRequest) ProtoMessage ¶
func (*GetChallengeRequest) ProtoMessage()
func (*GetChallengeRequest) ProtoReflect ¶
func (x *GetChallengeRequest) ProtoReflect() protoreflect.Message
func (*GetChallengeRequest) Reset ¶
func (x *GetChallengeRequest) Reset()
func (*GetChallengeRequest) String ¶
func (x *GetChallengeRequest) String() string
type GetChallengeResponse ¶
type GetChallengeResponse struct { Challenge string `protobuf:"bytes,1,opt,name=challenge,proto3" json:"challenge,omitempty"` // contains filtered or unexported fields }
func (*GetChallengeResponse) Descriptor
deprecated
func (*GetChallengeResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetChallengeResponse.ProtoReflect.Descriptor instead.
func (*GetChallengeResponse) GetChallenge ¶
func (x *GetChallengeResponse) GetChallenge() string
func (*GetChallengeResponse) ProtoMessage ¶
func (*GetChallengeResponse) ProtoMessage()
func (*GetChallengeResponse) ProtoReflect ¶
func (x *GetChallengeResponse) ProtoReflect() protoreflect.Message
func (*GetChallengeResponse) Reset ¶
func (x *GetChallengeResponse) Reset()
func (*GetChallengeResponse) String ¶
func (x *GetChallengeResponse) String() string
type GetJwtRequest ¶
type GetJwtRequest struct { ChannelId string `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` // contains filtered or unexported fields }
func (*GetJwtRequest) Descriptor
deprecated
func (*GetJwtRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetJwtRequest.ProtoReflect.Descriptor instead.
func (*GetJwtRequest) GetChannelId ¶
func (x *GetJwtRequest) GetChannelId() string
func (*GetJwtRequest) ProtoMessage ¶
func (*GetJwtRequest) ProtoMessage()
func (*GetJwtRequest) ProtoReflect ¶
func (x *GetJwtRequest) ProtoReflect() protoreflect.Message
func (*GetJwtRequest) Reset ¶
func (x *GetJwtRequest) Reset()
func (*GetJwtRequest) String ¶
func (x *GetJwtRequest) String() string
type GetJwtResponse ¶
type GetJwtResponse struct { Jwt string `protobuf:"bytes,1,opt,name=jwt,proto3" json:"jwt,omitempty"` // contains filtered or unexported fields }
func (*GetJwtResponse) Descriptor
deprecated
func (*GetJwtResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetJwtResponse.ProtoReflect.Descriptor instead.
func (*GetJwtResponse) GetJwt ¶
func (x *GetJwtResponse) GetJwt() string
func (*GetJwtResponse) ProtoMessage ¶
func (*GetJwtResponse) ProtoMessage()
func (*GetJwtResponse) ProtoReflect ¶
func (x *GetJwtResponse) ProtoReflect() protoreflect.Message
func (*GetJwtResponse) Reset ¶
func (x *GetJwtResponse) Reset()
func (*GetJwtResponse) String ¶
func (x *GetJwtResponse) String() string
type GetPositionsRequest ¶
type GetPositionsRequest struct { ChannelId string `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` // contains filtered or unexported fields }
func (*GetPositionsRequest) Descriptor
deprecated
func (*GetPositionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetPositionsRequest.ProtoReflect.Descriptor instead.
func (*GetPositionsRequest) GetChannelId ¶
func (x *GetPositionsRequest) GetChannelId() string
func (*GetPositionsRequest) ProtoMessage ¶
func (*GetPositionsRequest) ProtoMessage()
func (*GetPositionsRequest) ProtoReflect ¶
func (x *GetPositionsRequest) ProtoReflect() protoreflect.Message
func (*GetPositionsRequest) Reset ¶
func (x *GetPositionsRequest) Reset()
func (*GetPositionsRequest) String ¶
func (x *GetPositionsRequest) String() string
type GetPositionsResponse ¶
type GetPositionsResponse struct { ChannelId string `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` Positions []*Position `protobuf:"bytes,2,rep,name=positions,proto3" json:"positions,omitempty"` // contains filtered or unexported fields }
func (*GetPositionsResponse) Descriptor
deprecated
func (*GetPositionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetPositionsResponse.ProtoReflect.Descriptor instead.
func (*GetPositionsResponse) GetChannelId ¶
func (x *GetPositionsResponse) GetChannelId() string
func (*GetPositionsResponse) GetPositions ¶
func (x *GetPositionsResponse) GetPositions() []*Position
func (*GetPositionsResponse) ProtoMessage ¶
func (*GetPositionsResponse) ProtoMessage()
func (*GetPositionsResponse) ProtoReflect ¶
func (x *GetPositionsResponse) ProtoReflect() protoreflect.Message
func (*GetPositionsResponse) Reset ¶
func (x *GetPositionsResponse) Reset()
func (*GetPositionsResponse) String ¶
func (x *GetPositionsResponse) String() string
type IncompleteUserOp ¶ added in v0.0.102
type IncompleteUserOp struct { Sender *Address `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"` Nonce *BigInt `protobuf:"bytes,2,opt,name=nonce,proto3" json:"nonce,omitempty"` InitCode []byte `protobuf:"bytes,3,opt,name=init_code,json=initCode,proto3" json:"init_code,omitempty"` CallData []byte `protobuf:"bytes,4,opt,name=call_data,json=callData,proto3" json:"call_data,omitempty"` CallGasLimit *BigInt `protobuf:"bytes,5,opt,name=call_gas_limit,json=callGasLimit,proto3" json:"call_gas_limit,omitempty"` VerificationGasLimit *BigInt `protobuf:"bytes,6,opt,name=verification_gas_limit,json=verificationGasLimit,proto3" json:"verification_gas_limit,omitempty"` PreVerificationGas *BigInt `protobuf:"bytes,7,opt,name=pre_verification_gas,json=preVerificationGas,proto3" json:"pre_verification_gas,omitempty"` MaxFeePerGas *BigInt `protobuf:"bytes,8,opt,name=max_fee_per_gas,json=maxFeePerGas,proto3" json:"max_fee_per_gas,omitempty"` MaxPriorityFeePerGas *BigInt `` /* 127-byte string literal not displayed */ PaymasterAndData []byte `protobuf:"bytes,10,opt,name=paymaster_and_data,json=paymasterAndData,proto3" json:"paymaster_and_data,omitempty"` Signature []byte `protobuf:"bytes,11,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
func (*IncompleteUserOp) Descriptor
deprecated
added in
v0.0.102
func (*IncompleteUserOp) Descriptor() ([]byte, []int)
Deprecated: Use IncompleteUserOp.ProtoReflect.Descriptor instead.
func (*IncompleteUserOp) GetCallData ¶ added in v0.0.102
func (x *IncompleteUserOp) GetCallData() []byte
func (*IncompleteUserOp) GetCallGasLimit ¶ added in v0.0.102
func (x *IncompleteUserOp) GetCallGasLimit() *BigInt
func (*IncompleteUserOp) GetInitCode ¶ added in v0.0.102
func (x *IncompleteUserOp) GetInitCode() []byte
func (*IncompleteUserOp) GetMaxFeePerGas ¶ added in v0.0.102
func (x *IncompleteUserOp) GetMaxFeePerGas() *BigInt
func (*IncompleteUserOp) GetMaxPriorityFeePerGas ¶ added in v0.0.102
func (x *IncompleteUserOp) GetMaxPriorityFeePerGas() *BigInt
func (*IncompleteUserOp) GetNonce ¶ added in v0.0.102
func (x *IncompleteUserOp) GetNonce() *BigInt
func (*IncompleteUserOp) GetPaymasterAndData ¶ added in v0.0.102
func (x *IncompleteUserOp) GetPaymasterAndData() []byte
func (*IncompleteUserOp) GetPreVerificationGas ¶ added in v0.0.102
func (x *IncompleteUserOp) GetPreVerificationGas() *BigInt
func (*IncompleteUserOp) GetSender ¶ added in v0.0.102
func (x *IncompleteUserOp) GetSender() *Address
func (*IncompleteUserOp) GetSignature ¶ added in v0.0.102
func (x *IncompleteUserOp) GetSignature() []byte
func (*IncompleteUserOp) GetVerificationGasLimit ¶ added in v0.0.102
func (x *IncompleteUserOp) GetVerificationGasLimit() *BigInt
func (*IncompleteUserOp) ProtoMessage ¶ added in v0.0.102
func (*IncompleteUserOp) ProtoMessage()
func (*IncompleteUserOp) ProtoReflect ¶ added in v0.0.102
func (x *IncompleteUserOp) ProtoReflect() protoreflect.Message
func (*IncompleteUserOp) Reset ¶ added in v0.0.102
func (x *IncompleteUserOp) Reset()
func (*IncompleteUserOp) String ¶ added in v0.0.102
func (x *IncompleteUserOp) String() string
type Liability ¶
type Liability struct { Asset *Asset `protobuf:"bytes,1,opt,name=asset,proto3" json:"asset,omitempty"` Amount string `protobuf:"bytes,2,opt,name=amount,proto3" json:"amount,omitempty"` // contains filtered or unexported fields }
func (*Liability) Descriptor
deprecated
func (*Liability) ProtoMessage ¶
func (*Liability) ProtoMessage()
func (*Liability) ProtoReflect ¶
func (x *Liability) ProtoReflect() protoreflect.Message
type MarginCall ¶
type MarginCall struct { Version uint64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"` Amounts []*Decimal `protobuf:"bytes,2,rep,name=amounts,proto3" json:"amounts,omitempty"` // contains filtered or unexported fields }
func (*MarginCall) Descriptor
deprecated
func (*MarginCall) Descriptor() ([]byte, []int)
Deprecated: Use MarginCall.ProtoReflect.Descriptor instead.
func (*MarginCall) GetAmounts ¶
func (x *MarginCall) GetAmounts() []*Decimal
func (*MarginCall) GetVersion ¶
func (x *MarginCall) GetVersion() uint64
func (*MarginCall) ProtoMessage ¶
func (*MarginCall) ProtoMessage()
func (*MarginCall) ProtoReflect ¶
func (x *MarginCall) ProtoReflect() protoreflect.Message
func (*MarginCall) Reset ¶
func (x *MarginCall) Reset()
func (*MarginCall) String ¶
func (x *MarginCall) String() string
type MarginLimitType ¶ added in v0.0.5
type MarginLimitType int32
const ( MarginLimitType_MARGIN_LIMIT_TYPE_UNSPECIFIED MarginLimitType = 0 MarginLimitType_MARGIN_LIMIT_TYPE_NONE MarginLimitType = 1 MarginLimitType_MARGIN_LIMIT_TYPE_SOFT MarginLimitType = 2 MarginLimitType_MARGIN_LIMIT_TYPE_HARD MarginLimitType = 3 )
func (MarginLimitType) Descriptor ¶ added in v0.0.5
func (MarginLimitType) Descriptor() protoreflect.EnumDescriptor
func (MarginLimitType) Enum ¶ added in v0.0.5
func (x MarginLimitType) Enum() *MarginLimitType
func (MarginLimitType) EnumDescriptor
deprecated
added in
v0.0.5
func (MarginLimitType) EnumDescriptor() ([]byte, []int)
Deprecated: Use MarginLimitType.Descriptor instead.
func (MarginLimitType) Number ¶ added in v0.0.5
func (x MarginLimitType) Number() protoreflect.EnumNumber
func (MarginLimitType) String ¶ added in v0.0.5
func (x MarginLimitType) String() string
func (MarginLimitType) Type ¶ added in v0.0.5
func (MarginLimitType) Type() protoreflect.EnumType
type Market ¶
type Market struct { Base string `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"` Quote string `protobuf:"bytes,2,opt,name=quote,proto3" json:"quote,omitempty"` // contains filtered or unexported fields }
func (*Market) Descriptor
deprecated
func (*Market) ProtoMessage ¶
func (*Market) ProtoMessage()
func (*Market) ProtoReflect ¶
func (x *Market) ProtoReflect() protoreflect.Message
type Notification ¶
type Notification struct { // Types that are assignable to Notification: // // *Notification_StreamNotification // *Notification_SettlementNotification // *Notification_PositionNotification // *Notification_ErrorNotification // *Notification_TransactionNotification // *Notification_SessionKeyTransactionNotification // *Notification_RecordTradeNotification Notification isNotification_Notification `protobuf_oneof:"notification"` // contains filtered or unexported fields }
func (*Notification) Descriptor
deprecated
func (*Notification) Descriptor() ([]byte, []int)
Deprecated: Use Notification.ProtoReflect.Descriptor instead.
func (*Notification) GetErrorNotification ¶ added in v0.0.8
func (x *Notification) GetErrorNotification() *ErrorNotification
func (*Notification) GetNotification ¶
func (m *Notification) GetNotification() isNotification_Notification
func (*Notification) GetPositionNotification ¶
func (x *Notification) GetPositionNotification() *PositionNotification
func (*Notification) GetRecordTradeNotification ¶ added in v0.0.107
func (x *Notification) GetRecordTradeNotification() *RecordTradeNotification
func (*Notification) GetSessionKeyTransactionNotification ¶ added in v0.0.102
func (x *Notification) GetSessionKeyTransactionNotification() *SessionKeyTransactionNotification
func (*Notification) GetSettlementNotification ¶
func (x *Notification) GetSettlementNotification() *SettlementNotification
func (*Notification) GetStreamNotification ¶
func (x *Notification) GetStreamNotification() *StreamNotification
func (*Notification) GetTransactionNotification ¶ added in v0.0.9
func (x *Notification) GetTransactionNotification() *TransactionNotification
func (*Notification) ProtoMessage ¶
func (*Notification) ProtoMessage()
func (*Notification) ProtoReflect ¶
func (x *Notification) ProtoReflect() protoreflect.Message
func (*Notification) Reset ¶
func (x *Notification) Reset()
func (*Notification) String ¶
func (x *Notification) String() string
type Notification_ErrorNotification ¶ added in v0.0.8
type Notification_ErrorNotification struct {
ErrorNotification *ErrorNotification `protobuf:"bytes,4,opt,name=error_notification,json=errorNotification,proto3,oneof"`
}
type Notification_PositionNotification ¶
type Notification_PositionNotification struct {
PositionNotification *PositionNotification `protobuf:"bytes,3,opt,name=position_notification,json=positionNotification,proto3,oneof"`
}
type Notification_RecordTradeNotification ¶ added in v0.0.107
type Notification_RecordTradeNotification struct {
RecordTradeNotification *RecordTradeNotification `protobuf:"bytes,7,opt,name=record_trade_notification,json=recordTradeNotification,proto3,oneof"`
}
type Notification_SessionKeyTransactionNotification ¶ added in v0.0.102
type Notification_SessionKeyTransactionNotification struct {
SessionKeyTransactionNotification *SessionKeyTransactionNotification `protobuf:"bytes,6,opt,name=session_key_transaction_notification,json=sessionKeyTransactionNotification,proto3,oneof"`
}
type Notification_SettlementNotification ¶
type Notification_SettlementNotification struct {
SettlementNotification *SettlementNotification `protobuf:"bytes,2,opt,name=settlement_notification,json=settlementNotification,proto3,oneof"`
}
type Notification_StreamNotification ¶
type Notification_StreamNotification struct {
StreamNotification *StreamNotification `protobuf:"bytes,1,opt,name=stream_notification,json=streamNotification,proto3,oneof"`
}
type Notification_TransactionNotification ¶ added in v0.0.9
type Notification_TransactionNotification struct {
TransactionNotification *TransactionNotification `protobuf:"bytes,5,opt,name=transaction_notification,json=transactionNotification,proto3,oneof"`
}
type OpenChannelRequest ¶
type OpenChannelRequest struct { Peer *Peer `protobuf:"bytes,1,opt,name=peer,proto3" json:"peer,omitempty"` MarginDeposit string `protobuf:"bytes,2,opt,name=margin_deposit,json=marginDeposit,proto3" json:"margin_deposit,omitempty"` // contains filtered or unexported fields }
func (*OpenChannelRequest) Descriptor
deprecated
func (*OpenChannelRequest) Descriptor() ([]byte, []int)
Deprecated: Use OpenChannelRequest.ProtoReflect.Descriptor instead.
func (*OpenChannelRequest) GetMarginDeposit ¶
func (x *OpenChannelRequest) GetMarginDeposit() string
func (*OpenChannelRequest) GetPeer ¶
func (x *OpenChannelRequest) GetPeer() *Peer
func (*OpenChannelRequest) ProtoMessage ¶
func (*OpenChannelRequest) ProtoMessage()
func (*OpenChannelRequest) ProtoReflect ¶
func (x *OpenChannelRequest) ProtoReflect() protoreflect.Message
func (*OpenChannelRequest) Reset ¶
func (x *OpenChannelRequest) Reset()
func (*OpenChannelRequest) String ¶
func (x *OpenChannelRequest) String() string
type OpenChannelResponse ¶
type OpenChannelResponse struct { ChannelId string `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` // contains filtered or unexported fields }
func (*OpenChannelResponse) Descriptor
deprecated
func (*OpenChannelResponse) Descriptor() ([]byte, []int)
Deprecated: Use OpenChannelResponse.ProtoReflect.Descriptor instead.
func (*OpenChannelResponse) GetChannelId ¶
func (x *OpenChannelResponse) GetChannelId() string
func (*OpenChannelResponse) ProtoMessage ¶
func (*OpenChannelResponse) ProtoMessage()
func (*OpenChannelResponse) ProtoReflect ¶
func (x *OpenChannelResponse) ProtoReflect() protoreflect.Message
func (*OpenChannelResponse) Reset ¶
func (x *OpenChannelResponse) Reset()
func (*OpenChannelResponse) String ¶
func (x *OpenChannelResponse) String() string
type OperatorClient ¶
type OperatorClient interface { GetVersion(ctx context.Context, in *VersionRequest, opts ...grpc.CallOption) (*VersionResponse, error) GetChallenge(ctx context.Context, in *GetChallengeRequest, opts ...grpc.CallOption) (*GetChallengeResponse, error) Authenticate(ctx context.Context, in *AuthenticateRequest, opts ...grpc.CallOption) (*AuthenticateResponse, error) OpenChannel(ctx context.Context, in *OpenChannelRequest, opts ...grpc.CallOption) (*OpenChannelResponse, error) GetChannelJwt(ctx context.Context, in *GetJwtRequest, opts ...grpc.CallOption) (*GetJwtResponse, error) GetPositions(ctx context.Context, in *GetPositionsRequest, opts ...grpc.CallOption) (*GetPositionsResponse, error) GetActiveClearStreams(ctx context.Context, in *GetActiveClearStreamsRequest, opts ...grpc.CallOption) (*GetActiveClearStreamsResponse, error) RecordTrade(ctx context.Context, in *TradeRequest, opts ...grpc.CallOption) (*TradeResponse, error) RecordTrades(ctx context.Context, in *TradesRequest, opts ...grpc.CallOption) (*TradesResponse, error) RequestSettlement(ctx context.Context, in *SettlementRequest, opts ...grpc.CallOption) (*SettlementResponse, error) CloseChannel(ctx context.Context, in *CloseChannelRequest, opts ...grpc.CallOption) (*CloseChannelResponse, error) SubscribeChannelsEvents(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Operator_SubscribeChannelsEventsClient, error) }
OperatorClient is the client API for Operator service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewOperatorClient ¶
func NewOperatorClient(cc grpc.ClientConnInterface) OperatorClient
type OperatorServer ¶
type OperatorServer interface { GetVersion(context.Context, *VersionRequest) (*VersionResponse, error) GetChallenge(context.Context, *GetChallengeRequest) (*GetChallengeResponse, error) Authenticate(context.Context, *AuthenticateRequest) (*AuthenticateResponse, error) OpenChannel(context.Context, *OpenChannelRequest) (*OpenChannelResponse, error) GetChannelJwt(context.Context, *GetJwtRequest) (*GetJwtResponse, error) GetPositions(context.Context, *GetPositionsRequest) (*GetPositionsResponse, error) GetActiveClearStreams(context.Context, *GetActiveClearStreamsRequest) (*GetActiveClearStreamsResponse, error) RecordTrade(context.Context, *TradeRequest) (*TradeResponse, error) RecordTrades(context.Context, *TradesRequest) (*TradesResponse, error) RequestSettlement(context.Context, *SettlementRequest) (*SettlementResponse, error) CloseChannel(context.Context, *CloseChannelRequest) (*CloseChannelResponse, error) SubscribeChannelsEvents(*SubscribeRequest, Operator_SubscribeChannelsEventsServer) error // contains filtered or unexported methods }
OperatorServer is the server API for Operator service. All implementations must embed UnimplementedOperatorServer for forward compatibility
type Operator_SubscribeChannelsEventsClient ¶
type Operator_SubscribeChannelsEventsClient interface { Recv() (*Notification, error) grpc.ClientStream }
type Operator_SubscribeChannelsEventsServer ¶
type Operator_SubscribeChannelsEventsServer interface { Send(*Notification) error grpc.ServerStream }
type ParamCondition ¶ added in v0.0.102
type ParamCondition int32
const ( ParamCondition_PARAM_CONDITION_UNSPECIFIED ParamCondition = 0 ParamCondition_PARAM_CONDITION_EQUAL ParamCondition = 1 ParamCondition_PARAM_CONDITION_GREATER_THAN ParamCondition = 2 ParamCondition_PARAM_CONDITION_LESS_THAN ParamCondition = 3 ParamCondition_PARAM_CONDITION_GREATER_THAN_OR_EQUAL ParamCondition = 4 ParamCondition_PARAM_CONDITION_LESS_THAN_OR_EQUAL ParamCondition = 5 ParamCondition_PARAM_CONDITION_NOT_EQUAL ParamCondition = 6 )
func (ParamCondition) Descriptor ¶ added in v0.0.102
func (ParamCondition) Descriptor() protoreflect.EnumDescriptor
func (ParamCondition) Enum ¶ added in v0.0.102
func (x ParamCondition) Enum() *ParamCondition
func (ParamCondition) EnumDescriptor
deprecated
added in
v0.0.102
func (ParamCondition) EnumDescriptor() ([]byte, []int)
Deprecated: Use ParamCondition.Descriptor instead.
func (ParamCondition) Number ¶ added in v0.0.102
func (x ParamCondition) Number() protoreflect.EnumNumber
func (ParamCondition) String ¶ added in v0.0.102
func (x ParamCondition) String() string
func (ParamCondition) Type ¶ added in v0.0.102
func (ParamCondition) Type() protoreflect.EnumType
type ParamRule ¶ added in v0.0.102
type ParamRule struct { Condition ParamCondition `protobuf:"varint,1,opt,name=condition,proto3,enum=ParamCondition" json:"condition,omitempty"` Param string `protobuf:"bytes,2,opt,name=param,proto3" json:"param,omitempty"` // contains filtered or unexported fields }
func (*ParamRule) Descriptor
deprecated
added in
v0.0.102
func (*ParamRule) GetCondition ¶ added in v0.0.102
func (x *ParamRule) GetCondition() ParamCondition
func (*ParamRule) ProtoMessage ¶ added in v0.0.102
func (*ParamRule) ProtoMessage()
func (*ParamRule) ProtoReflect ¶ added in v0.0.102
func (x *ParamRule) ProtoReflect() protoreflect.Message
type PaymentMethod ¶
type PaymentMethod int32
const ( PaymentMethod_PAYMENT_METHOD_UNSPECIFIED PaymentMethod = 0 PaymentMethod_PAYMENT_METHOD_ESCROW PaymentMethod = 1 PaymentMethod_PAYMENT_METHOD_MOCK PaymentMethod = 2 )
func (PaymentMethod) Descriptor ¶
func (PaymentMethod) Descriptor() protoreflect.EnumDescriptor
func (PaymentMethod) Enum ¶
func (x PaymentMethod) Enum() *PaymentMethod
func (PaymentMethod) EnumDescriptor
deprecated
func (PaymentMethod) EnumDescriptor() ([]byte, []int)
Deprecated: Use PaymentMethod.Descriptor instead.
func (PaymentMethod) Number ¶
func (x PaymentMethod) Number() protoreflect.EnumNumber
func (PaymentMethod) String ¶
func (x PaymentMethod) String() string
func (PaymentMethod) Type ¶
func (PaymentMethod) Type() protoreflect.EnumType
type Peer ¶
type Peer struct { Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` ParticipantAddress string `protobuf:"bytes,4,opt,name=participant_address,json=participantAddress,proto3" json:"participant_address,omitempty"` OperatorAddress string `protobuf:"bytes,6,opt,name=operator_address,json=operatorAddress,proto3" json:"operator_address,omitempty"` // contains filtered or unexported fields }
func (*Peer) Descriptor
deprecated
func (*Peer) GetOperatorAddress ¶ added in v0.0.27
func (*Peer) GetParticipantAddress ¶ added in v0.0.12
func (*Peer) ProtoMessage ¶
func (*Peer) ProtoMessage()
func (*Peer) ProtoReflect ¶
func (x *Peer) ProtoReflect() protoreflect.Message
type Position ¶
type Position struct { Id string `protobuf:"bytes,9,opt,name=id,proto3" json:"id,omitempty"` ChannelId string `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` Market *Market `protobuf:"bytes,2,opt,name=market,proto3" json:"market,omitempty"` Direction Direction `protobuf:"varint,3,opt,name=direction,proto3,enum=core.Direction" json:"direction,omitempty"` Amount string `protobuf:"bytes,4,opt,name=amount,proto3" json:"amount,omitempty"` Cost string `protobuf:"bytes,5,opt,name=cost,proto3" json:"cost,omitempty"` MarketValue string `protobuf:"bytes,6,opt,name=market_value,json=marketValue,proto3" json:"market_value,omitempty"` Pnl string `protobuf:"bytes,7,opt,name=pnl,proto3" json:"pnl,omitempty"` Status PositionStatus `protobuf:"varint,8,opt,name=status,proto3,enum=core.PositionStatus" json:"status,omitempty"` // contains filtered or unexported fields }
func (*Position) Descriptor
deprecated
func (*Position) GetChannelId ¶
func (*Position) GetDirection ¶
func (*Position) GetMarketValue ¶
func (*Position) GetStatus ¶
func (x *Position) GetStatus() PositionStatus
func (*Position) ProtoMessage ¶
func (*Position) ProtoMessage()
func (*Position) ProtoReflect ¶
func (x *Position) ProtoReflect() protoreflect.Message
type PositionNotification ¶
type PositionNotification struct { Position *Position `protobuf:"bytes,1,opt,name=position,proto3" json:"position,omitempty"` // contains filtered or unexported fields }
func (*PositionNotification) Descriptor
deprecated
func (*PositionNotification) Descriptor() ([]byte, []int)
Deprecated: Use PositionNotification.ProtoReflect.Descriptor instead.
func (*PositionNotification) GetPosition ¶
func (x *PositionNotification) GetPosition() *Position
func (*PositionNotification) ProtoMessage ¶
func (*PositionNotification) ProtoMessage()
func (*PositionNotification) ProtoReflect ¶
func (x *PositionNotification) ProtoReflect() protoreflect.Message
func (*PositionNotification) Reset ¶
func (x *PositionNotification) Reset()
func (*PositionNotification) String ¶
func (x *PositionNotification) String() string
type PositionStatus ¶
type PositionStatus int32
const ( PositionStatus_POSITION_STATUS_UNSPECIFIED PositionStatus = 0 PositionStatus_POSITION_STATUS_OPEN PositionStatus = 1 PositionStatus_POSITION_STATUS_IN_SETTLEMENT PositionStatus = 2 PositionStatus_POSITION_STATUS_SETTLED PositionStatus = 3 PositionStatus_POSITION_STATUS_CLOSED PositionStatus = 4 )
func (PositionStatus) Descriptor ¶
func (PositionStatus) Descriptor() protoreflect.EnumDescriptor
func (PositionStatus) Enum ¶
func (x PositionStatus) Enum() *PositionStatus
func (PositionStatus) EnumDescriptor
deprecated
func (PositionStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use PositionStatus.Descriptor instead.
func (PositionStatus) Number ¶
func (x PositionStatus) Number() protoreflect.EnumNumber
func (PositionStatus) String ¶
func (x PositionStatus) String() string
func (PositionStatus) Type ¶
func (PositionStatus) Type() protoreflect.EnumType
type PrepareRequest ¶
type PrepareRequest struct { Settlement *Settlement `protobuf:"bytes,2,opt,name=settlement,proto3" json:"settlement,omitempty"` // contains filtered or unexported fields }
func (*PrepareRequest) Descriptor
deprecated
func (*PrepareRequest) Descriptor() ([]byte, []int)
Deprecated: Use PrepareRequest.ProtoReflect.Descriptor instead.
func (*PrepareRequest) GetSettlement ¶
func (x *PrepareRequest) GetSettlement() *Settlement
func (*PrepareRequest) ProtoMessage ¶
func (*PrepareRequest) ProtoMessage()
func (*PrepareRequest) ProtoReflect ¶
func (x *PrepareRequest) ProtoReflect() protoreflect.Message
func (*PrepareRequest) Reset ¶
func (x *PrepareRequest) Reset()
func (*PrepareRequest) String ¶
func (x *PrepareRequest) String() string
type PrepareResponse ¶
type PrepareResponse struct { State SettlementState `protobuf:"varint,1,opt,name=state,proto3,enum=settlement.SettlementState" json:"state,omitempty"` Markets []string `protobuf:"bytes,2,rep,name=markets,proto3" json:"markets,omitempty"` // contains filtered or unexported fields }
func (*PrepareResponse) Descriptor
deprecated
func (*PrepareResponse) Descriptor() ([]byte, []int)
Deprecated: Use PrepareResponse.ProtoReflect.Descriptor instead.
func (*PrepareResponse) GetMarkets ¶
func (x *PrepareResponse) GetMarkets() []string
func (*PrepareResponse) GetState ¶
func (x *PrepareResponse) GetState() SettlementState
func (*PrepareResponse) ProtoMessage ¶
func (*PrepareResponse) ProtoMessage()
func (*PrepareResponse) ProtoReflect ¶
func (x *PrepareResponse) ProtoReflect() protoreflect.Message
func (*PrepareResponse) Reset ¶
func (x *PrepareResponse) Reset()
func (*PrepareResponse) String ¶
func (x *PrepareResponse) String() string
type PriceFeedClient ¶ added in v0.0.23
type PriceFeedClient interface {
Subscribe(ctx context.Context, in *PriceFeedSubscribeRequest, opts ...grpc.CallOption) (PriceFeed_SubscribeClient, error)
}
PriceFeedClient is the client API for PriceFeed service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewPriceFeedClient ¶ added in v0.0.23
func NewPriceFeedClient(cc grpc.ClientConnInterface) PriceFeedClient
type PriceFeedServer ¶ added in v0.0.23
type PriceFeedServer interface { Subscribe(*PriceFeedSubscribeRequest, PriceFeed_SubscribeServer) error // contains filtered or unexported methods }
PriceFeedServer is the server API for PriceFeed service. All implementations must embed UnimplementedPriceFeedServer for forward compatibility
type PriceFeedSubscribeRequest ¶ added in v0.0.23
type PriceFeedSubscribeRequest struct { Market *Market `protobuf:"bytes,1,opt,name=market,proto3" json:"market,omitempty"` // contains filtered or unexported fields }
func (*PriceFeedSubscribeRequest) Descriptor
deprecated
added in
v0.0.23
func (*PriceFeedSubscribeRequest) Descriptor() ([]byte, []int)
Deprecated: Use PriceFeedSubscribeRequest.ProtoReflect.Descriptor instead.
func (*PriceFeedSubscribeRequest) GetMarket ¶ added in v0.0.23
func (x *PriceFeedSubscribeRequest) GetMarket() *Market
func (*PriceFeedSubscribeRequest) ProtoMessage ¶ added in v0.0.23
func (*PriceFeedSubscribeRequest) ProtoMessage()
func (*PriceFeedSubscribeRequest) ProtoReflect ¶ added in v0.0.23
func (x *PriceFeedSubscribeRequest) ProtoReflect() protoreflect.Message
func (*PriceFeedSubscribeRequest) Reset ¶ added in v0.0.23
func (x *PriceFeedSubscribeRequest) Reset()
func (*PriceFeedSubscribeRequest) String ¶ added in v0.0.23
func (x *PriceFeedSubscribeRequest) String() string
type PriceFeed_SubscribeClient ¶ added in v0.0.23
type PriceFeed_SubscribeClient interface { Recv() (*Quote, error) grpc.ClientStream }
type PriceFeed_SubscribeServer ¶ added in v0.0.23
type PriceFeed_SubscribeServer interface { Send(*Quote) error grpc.ServerStream }
type ProtocolIndex ¶
type ProtocolIndex int32
const ( ProtocolIndex_PROTOCOL_INDEX_UNSPECIFIED ProtocolIndex = 0 ProtocolIndex_PROTOCOL_INDEX_INITIATOR ProtocolIndex = 1 ProtocolIndex_PROTOCOL_INDEX_RESPONDER ProtocolIndex = 2 )
func (ProtocolIndex) Descriptor ¶
func (ProtocolIndex) Descriptor() protoreflect.EnumDescriptor
func (ProtocolIndex) Enum ¶
func (x ProtocolIndex) Enum() *ProtocolIndex
func (ProtocolIndex) EnumDescriptor
deprecated
func (ProtocolIndex) EnumDescriptor() ([]byte, []int)
Deprecated: Use ProtocolIndex.Descriptor instead.
func (ProtocolIndex) Number ¶
func (x ProtocolIndex) Number() protoreflect.EnumNumber
func (ProtocolIndex) String ¶
func (x ProtocolIndex) String() string
func (ProtocolIndex) Type ¶
func (ProtocolIndex) Type() protoreflect.EnumType
type Quote ¶ added in v0.0.23
type Quote struct { Market *Market `protobuf:"bytes,1,opt,name=market,proto3" json:"market,omitempty"` Price *Decimal `protobuf:"bytes,2,opt,name=price,proto3" json:"price,omitempty"` Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // contains filtered or unexported fields }
func (*Quote) Descriptor
deprecated
added in
v0.0.23
func (*Quote) GetTimestamp ¶ added in v0.0.23
func (*Quote) ProtoMessage ¶ added in v0.0.23
func (*Quote) ProtoMessage()
func (*Quote) ProtoReflect ¶ added in v0.0.23
func (x *Quote) ProtoReflect() protoreflect.Message
type RecordTradeNotification ¶ added in v0.0.107
type RecordTradeNotification struct { Trade *Trade `protobuf:"bytes,1,opt,name=trade,proto3" json:"trade,omitempty"` RevertReason string `protobuf:"bytes,2,opt,name=revert_reason,json=revertReason,proto3" json:"revert_reason,omitempty"` // contains filtered or unexported fields }
func (*RecordTradeNotification) Descriptor
deprecated
added in
v0.0.107
func (*RecordTradeNotification) Descriptor() ([]byte, []int)
Deprecated: Use RecordTradeNotification.ProtoReflect.Descriptor instead.
func (*RecordTradeNotification) GetRevertReason ¶ added in v0.0.107
func (x *RecordTradeNotification) GetRevertReason() string
func (*RecordTradeNotification) GetTrade ¶ added in v0.0.107
func (x *RecordTradeNotification) GetTrade() *Trade
func (*RecordTradeNotification) ProtoMessage ¶ added in v0.0.107
func (*RecordTradeNotification) ProtoMessage()
func (*RecordTradeNotification) ProtoReflect ¶ added in v0.0.107
func (x *RecordTradeNotification) ProtoReflect() protoreflect.Message
func (*RecordTradeNotification) Reset ¶ added in v0.0.107
func (x *RecordTradeNotification) Reset()
func (*RecordTradeNotification) String ¶ added in v0.0.107
func (x *RecordTradeNotification) String() string
type SessionKeyPermission ¶ added in v0.0.102
type SessionKeyPermission struct { Target *Address `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"` FunctionAbi []byte `protobuf:"bytes,2,opt,name=function_abi,json=functionAbi,proto3" json:"function_abi,omitempty"` ValueLimit *BigInt `protobuf:"bytes,3,opt,name=value_limit,json=valueLimit,proto3" json:"value_limit,omitempty"` ParamRules []*ParamRule `protobuf:"bytes,4,rep,name=param_rules,json=paramRules,proto3" json:"param_rules,omitempty"` // contains filtered or unexported fields }
func (*SessionKeyPermission) Descriptor
deprecated
added in
v0.0.102
func (*SessionKeyPermission) Descriptor() ([]byte, []int)
Deprecated: Use SessionKeyPermission.ProtoReflect.Descriptor instead.
func (*SessionKeyPermission) GetFunctionAbi ¶ added in v0.0.102
func (x *SessionKeyPermission) GetFunctionAbi() []byte
func (*SessionKeyPermission) GetParamRules ¶ added in v0.0.102
func (x *SessionKeyPermission) GetParamRules() []*ParamRule
func (*SessionKeyPermission) GetTarget ¶ added in v0.0.102
func (x *SessionKeyPermission) GetTarget() *Address
func (*SessionKeyPermission) GetValueLimit ¶ added in v0.0.102
func (x *SessionKeyPermission) GetValueLimit() *BigInt
func (*SessionKeyPermission) ProtoMessage ¶ added in v0.0.102
func (*SessionKeyPermission) ProtoMessage()
func (*SessionKeyPermission) ProtoReflect ¶ added in v0.0.102
func (x *SessionKeyPermission) ProtoReflect() protoreflect.Message
func (*SessionKeyPermission) Reset ¶ added in v0.0.102
func (x *SessionKeyPermission) Reset()
func (*SessionKeyPermission) String ¶ added in v0.0.102
func (x *SessionKeyPermission) String() string
type SessionKeyTransactionNotification ¶ added in v0.0.102
type SessionKeyTransactionNotification struct { IncompleteUserop *IncompleteUserOp `protobuf:"bytes,1,opt,name=incomplete_userop,json=incompleteUserop,proto3" json:"incomplete_userop,omitempty"` EnableSigOffset uint64 `protobuf:"varint,2,opt,name=enable_sig_offset,json=enableSigOffset,proto3" json:"enable_sig_offset,omitempty"` DigestHash string `protobuf:"bytes,3,opt,name=digest_hash,json=digestHash,proto3" json:"digest_hash,omitempty"` Permissions []*SessionKeyPermission `protobuf:"bytes,4,rep,name=permissions,proto3" json:"permissions,omitempty"` // contains filtered or unexported fields }
func (*SessionKeyTransactionNotification) Descriptor
deprecated
added in
v0.0.102
func (*SessionKeyTransactionNotification) Descriptor() ([]byte, []int)
Deprecated: Use SessionKeyTransactionNotification.ProtoReflect.Descriptor instead.
func (*SessionKeyTransactionNotification) GetDigestHash ¶ added in v0.0.102
func (x *SessionKeyTransactionNotification) GetDigestHash() string
func (*SessionKeyTransactionNotification) GetEnableSigOffset ¶ added in v0.0.102
func (x *SessionKeyTransactionNotification) GetEnableSigOffset() uint64
func (*SessionKeyTransactionNotification) GetIncompleteUserop ¶ added in v0.0.102
func (x *SessionKeyTransactionNotification) GetIncompleteUserop() *IncompleteUserOp
func (*SessionKeyTransactionNotification) GetPermissions ¶ added in v0.0.102
func (x *SessionKeyTransactionNotification) GetPermissions() []*SessionKeyPermission
func (*SessionKeyTransactionNotification) ProtoMessage ¶ added in v0.0.102
func (*SessionKeyTransactionNotification) ProtoMessage()
func (*SessionKeyTransactionNotification) ProtoReflect ¶ added in v0.0.102
func (x *SessionKeyTransactionNotification) ProtoReflect() protoreflect.Message
func (*SessionKeyTransactionNotification) Reset ¶ added in v0.0.102
func (x *SessionKeyTransactionNotification) Reset()
func (*SessionKeyTransactionNotification) String ¶ added in v0.0.102
func (x *SessionKeyTransactionNotification) String() string
type Settlement ¶
type Settlement struct { Cid string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"` Type SettlementType `protobuf:"varint,2,opt,name=type,proto3,enum=settlement.SettlementType" json:"type,omitempty"` State SettlementState `protobuf:"varint,3,opt,name=state,proto3,enum=settlement.SettlementState" json:"state,omitempty"` Ledger *SettlementLedger `protobuf:"bytes,4,opt,name=ledger,proto3" json:"ledger,omitempty"` PsmTurnNum uint64 `protobuf:"varint,5,opt,name=psm_turn_num,json=psmTurnNum,proto3" json:"psm_turn_num,omitempty"` PaymentMethod PaymentMethod `` /* 131-byte string literal not displayed */ Markets []string `protobuf:"bytes,7,rep,name=markets,proto3" json:"markets,omitempty"` ChainId uint64 `protobuf:"varint,8,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` // contains filtered or unexported fields }
func (*Settlement) Descriptor
deprecated
func (*Settlement) Descriptor() ([]byte, []int)
Deprecated: Use Settlement.ProtoReflect.Descriptor instead.
func (*Settlement) GetChainId ¶
func (x *Settlement) GetChainId() uint64
func (*Settlement) GetCid ¶
func (x *Settlement) GetCid() string
func (*Settlement) GetLedger ¶
func (x *Settlement) GetLedger() *SettlementLedger
func (*Settlement) GetMarkets ¶
func (x *Settlement) GetMarkets() []string
func (*Settlement) GetPaymentMethod ¶
func (x *Settlement) GetPaymentMethod() PaymentMethod
func (*Settlement) GetPsmTurnNum ¶
func (x *Settlement) GetPsmTurnNum() uint64
func (*Settlement) GetState ¶
func (x *Settlement) GetState() SettlementState
func (*Settlement) GetType ¶
func (x *Settlement) GetType() SettlementType
func (*Settlement) ProtoMessage ¶
func (*Settlement) ProtoMessage()
func (*Settlement) ProtoReflect ¶
func (x *Settlement) ProtoReflect() protoreflect.Message
func (*Settlement) Reset ¶
func (x *Settlement) Reset()
func (*Settlement) String ¶
func (x *Settlement) String() string
type SettlementLedger ¶
type SettlementLedger struct { InitiatorEntries []*Liability `protobuf:"bytes,1,rep,name=initiator_entries,json=initiatorEntries,proto3" json:"initiator_entries,omitempty"` ResponderEntries []*Liability `protobuf:"bytes,2,rep,name=responder_entries,json=responderEntries,proto3" json:"responder_entries,omitempty"` NextMargin *MarginCall `protobuf:"bytes,3,opt,name=next_margin,json=nextMargin,proto3" json:"next_margin,omitempty"` // contains filtered or unexported fields }
func (*SettlementLedger) Descriptor
deprecated
func (*SettlementLedger) Descriptor() ([]byte, []int)
Deprecated: Use SettlementLedger.ProtoReflect.Descriptor instead.
func (*SettlementLedger) GetInitiatorEntries ¶
func (x *SettlementLedger) GetInitiatorEntries() []*Liability
func (*SettlementLedger) GetNextMargin ¶
func (x *SettlementLedger) GetNextMargin() *MarginCall
func (*SettlementLedger) GetResponderEntries ¶
func (x *SettlementLedger) GetResponderEntries() []*Liability
func (*SettlementLedger) ProtoMessage ¶
func (*SettlementLedger) ProtoMessage()
func (*SettlementLedger) ProtoReflect ¶
func (x *SettlementLedger) ProtoReflect() protoreflect.Message
func (*SettlementLedger) Reset ¶
func (x *SettlementLedger) Reset()
func (*SettlementLedger) String ¶
func (x *SettlementLedger) String() string
type SettlementNotification ¶
type SettlementNotification struct { ChannelId string `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` SettlementState SettlementState `` /* 139-byte string literal not displayed */ Markets []*Market `protobuf:"bytes,3,rep,name=markets,proto3" json:"markets,omitempty"` Ledger *SettlementLedger `protobuf:"bytes,4,opt,name=ledger,proto3" json:"ledger,omitempty"` // contains filtered or unexported fields }
func (*SettlementNotification) Descriptor
deprecated
func (*SettlementNotification) Descriptor() ([]byte, []int)
Deprecated: Use SettlementNotification.ProtoReflect.Descriptor instead.
func (*SettlementNotification) GetChannelId ¶
func (x *SettlementNotification) GetChannelId() string
func (*SettlementNotification) GetLedger ¶ added in v0.0.106
func (x *SettlementNotification) GetLedger() *SettlementLedger
func (*SettlementNotification) GetMarkets ¶ added in v0.0.104
func (x *SettlementNotification) GetMarkets() []*Market
func (*SettlementNotification) GetSettlementState ¶
func (x *SettlementNotification) GetSettlementState() SettlementState
func (*SettlementNotification) ProtoMessage ¶
func (*SettlementNotification) ProtoMessage()
func (*SettlementNotification) ProtoReflect ¶
func (x *SettlementNotification) ProtoReflect() protoreflect.Message
func (*SettlementNotification) Reset ¶
func (x *SettlementNotification) Reset()
func (*SettlementNotification) String ¶
func (x *SettlementNotification) String() string
type SettlementRequest ¶
type SettlementRequest struct { ChannelId string `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` PaymentMethod PaymentMethod `` /* 131-byte string literal not displayed */ ChainId uint64 `protobuf:"varint,3,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"` Markets []*Market `protobuf:"bytes,4,rep,name=markets,proto3" json:"markets,omitempty"` // contains filtered or unexported fields }
func (*SettlementRequest) Descriptor
deprecated
func (*SettlementRequest) Descriptor() ([]byte, []int)
Deprecated: Use SettlementRequest.ProtoReflect.Descriptor instead.
func (*SettlementRequest) GetChainId ¶
func (x *SettlementRequest) GetChainId() uint64
func (*SettlementRequest) GetChannelId ¶
func (x *SettlementRequest) GetChannelId() string
func (*SettlementRequest) GetMarkets ¶
func (x *SettlementRequest) GetMarkets() []*Market
func (*SettlementRequest) GetPaymentMethod ¶
func (x *SettlementRequest) GetPaymentMethod() PaymentMethod
func (*SettlementRequest) ProtoMessage ¶
func (*SettlementRequest) ProtoMessage()
func (*SettlementRequest) ProtoReflect ¶
func (x *SettlementRequest) ProtoReflect() protoreflect.Message
func (*SettlementRequest) Reset ¶
func (x *SettlementRequest) Reset()
func (*SettlementRequest) String ¶
func (x *SettlementRequest) String() string
type SettlementResponse ¶
type SettlementResponse struct {
// contains filtered or unexported fields
}
func (*SettlementResponse) Descriptor
deprecated
func (*SettlementResponse) Descriptor() ([]byte, []int)
Deprecated: Use SettlementResponse.ProtoReflect.Descriptor instead.
func (*SettlementResponse) ProtoMessage ¶
func (*SettlementResponse) ProtoMessage()
func (*SettlementResponse) ProtoReflect ¶
func (x *SettlementResponse) ProtoReflect() protoreflect.Message
func (*SettlementResponse) Reset ¶
func (x *SettlementResponse) Reset()
func (*SettlementResponse) String ¶
func (x *SettlementResponse) String() string
type SettlementServiceClient ¶
type SettlementServiceClient interface { Prepare(ctx context.Context, in *PrepareRequest, opts ...grpc.CallOption) (*PrepareResponse, error) Update(ctx context.Context, in *SettlementStateUpdate, opts ...grpc.CallOption) (*StateConfirmation, error) Finalize(ctx context.Context, in *FinalizeRequest, opts ...grpc.CallOption) (*FinalizeResponse, error) }
SettlementServiceClient is the client API for SettlementService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewSettlementServiceClient ¶
func NewSettlementServiceClient(cc grpc.ClientConnInterface) SettlementServiceClient
type SettlementServiceServer ¶
type SettlementServiceServer interface { Prepare(context.Context, *PrepareRequest) (*PrepareResponse, error) Update(context.Context, *SettlementStateUpdate) (*StateConfirmation, error) Finalize(context.Context, *FinalizeRequest) (*FinalizeResponse, error) // contains filtered or unexported methods }
SettlementServiceServer is the server API for SettlementService service. All implementations must embed UnimplementedSettlementServiceServer for forward compatibility
type SettlementState ¶
type SettlementState int32
const ( SettlementState_SETTLEMENT_STATE_UNSPECIFIED SettlementState = 0 SettlementState_SETTLEMENT_STATE_PROPOSED SettlementState = 1 SettlementState_SETTLEMENT_STATE_ACCEPTED SettlementState = 2 SettlementState_SETTLEMENT_STATE_INITIATED SettlementState = 3 SettlementState_SETTLEMENT_STATE_PREPARED SettlementState = 4 SettlementState_SETTLEMENT_STATE_EXECUTED SettlementState = 5 SettlementState_SETTLEMENT_STATE_COMPLETED SettlementState = 6 SettlementState_SETTLEMENT_STATE_WITHDRAWN SettlementState = 7 SettlementState_SETTLEMENT_STATE_FAILED SettlementState = 8 SettlementState_SETTLEMENT_STATE_REJECTED SettlementState = 9 )
func (SettlementState) Descriptor ¶
func (SettlementState) Descriptor() protoreflect.EnumDescriptor
func (SettlementState) Enum ¶
func (x SettlementState) Enum() *SettlementState
func (SettlementState) EnumDescriptor
deprecated
func (SettlementState) EnumDescriptor() ([]byte, []int)
Deprecated: Use SettlementState.Descriptor instead.
func (SettlementState) Number ¶
func (x SettlementState) Number() protoreflect.EnumNumber
func (SettlementState) String ¶
func (x SettlementState) String() string
func (SettlementState) Type ¶
func (SettlementState) Type() protoreflect.EnumType
type SettlementStateUpdate ¶
type SettlementStateUpdate struct { Cid string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"` ToState SettlementState `protobuf:"varint,2,opt,name=to_state,json=toState,proto3,enum=settlement.SettlementState" json:"to_state,omitempty"` // contains filtered or unexported fields }
func (*SettlementStateUpdate) Descriptor
deprecated
func (*SettlementStateUpdate) Descriptor() ([]byte, []int)
Deprecated: Use SettlementStateUpdate.ProtoReflect.Descriptor instead.
func (*SettlementStateUpdate) GetCid ¶
func (x *SettlementStateUpdate) GetCid() string
func (*SettlementStateUpdate) GetToState ¶
func (x *SettlementStateUpdate) GetToState() SettlementState
func (*SettlementStateUpdate) ProtoMessage ¶
func (*SettlementStateUpdate) ProtoMessage()
func (*SettlementStateUpdate) ProtoReflect ¶
func (x *SettlementStateUpdate) ProtoReflect() protoreflect.Message
func (*SettlementStateUpdate) Reset ¶
func (x *SettlementStateUpdate) Reset()
func (*SettlementStateUpdate) String ¶
func (x *SettlementStateUpdate) String() string
type SettlementType ¶
type SettlementType int32
const ( SettlementType_SETTLEMENT_TYPE_UNSPECIFIED SettlementType = 0 SettlementType_SETTLEMENT_TYPE_AVAILABLE SettlementType = 1 SettlementType_SETTLEMENT_TYPE_FORCE SettlementType = 2 )
func (SettlementType) Descriptor ¶
func (SettlementType) Descriptor() protoreflect.EnumDescriptor
func (SettlementType) Enum ¶
func (x SettlementType) Enum() *SettlementType
func (SettlementType) EnumDescriptor
deprecated
func (SettlementType) EnumDescriptor() ([]byte, []int)
Deprecated: Use SettlementType.Descriptor instead.
func (SettlementType) Number ¶
func (x SettlementType) Number() protoreflect.EnumNumber
func (SettlementType) String ¶
func (x SettlementType) String() string
func (SettlementType) Type ¶
func (SettlementType) Type() protoreflect.EnumType
type Signature ¶
type Signature struct { V uint32 `protobuf:"varint,1,opt,name=v,proto3" json:"v,omitempty"` R []byte `protobuf:"bytes,2,opt,name=r,proto3" json:"r,omitempty"` // 32 bytes S []byte `protobuf:"bytes,3,opt,name=s,proto3" json:"s,omitempty"` // 32 bytes // contains filtered or unexported fields }
* A 132-character hexadecimal string
func (*Signature) Descriptor
deprecated
func (*Signature) ProtoMessage ¶
func (*Signature) ProtoMessage()
func (*Signature) ProtoReflect ¶
func (x *Signature) ProtoReflect() protoreflect.Message
type SignedChallenge ¶
type SignedChallenge struct { Client *Peer `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"` SignedServerChallenge []byte `` /* 126-byte string literal not displayed */ ServerOperatorAddress string `` /* 126-byte string literal not displayed */ // contains filtered or unexported fields }
This should be signed with the client's private key
func (*SignedChallenge) Descriptor
deprecated
func (*SignedChallenge) Descriptor() ([]byte, []int)
Deprecated: Use SignedChallenge.ProtoReflect.Descriptor instead.
func (*SignedChallenge) GetClient ¶
func (x *SignedChallenge) GetClient() *Peer
func (*SignedChallenge) GetServerOperatorAddress ¶ added in v0.0.27
func (x *SignedChallenge) GetServerOperatorAddress() string
func (*SignedChallenge) GetSignedServerChallenge ¶
func (x *SignedChallenge) GetSignedServerChallenge() []byte
func (*SignedChallenge) ProtoMessage ¶
func (*SignedChallenge) ProtoMessage()
func (*SignedChallenge) ProtoReflect ¶
func (x *SignedChallenge) ProtoReflect() protoreflect.Message
func (*SignedChallenge) Reset ¶
func (x *SignedChallenge) Reset()
func (*SignedChallenge) String ¶
func (x *SignedChallenge) String() string
type SignedMarginCall ¶
type SignedMarginCall struct { MarginCall *MarginCall `protobuf:"bytes,1,opt,name=margin_call,json=marginCall,proto3" json:"margin_call,omitempty"` Sigs []*Signature `protobuf:"bytes,2,rep,name=sigs,proto3" json:"sigs,omitempty"` // contains filtered or unexported fields }
func (*SignedMarginCall) Descriptor
deprecated
func (*SignedMarginCall) Descriptor() ([]byte, []int)
Deprecated: Use SignedMarginCall.ProtoReflect.Descriptor instead.
func (*SignedMarginCall) GetMarginCall ¶
func (x *SignedMarginCall) GetMarginCall() *MarginCall
func (*SignedMarginCall) GetSigs ¶
func (x *SignedMarginCall) GetSigs() []*Signature
func (*SignedMarginCall) ProtoMessage ¶
func (*SignedMarginCall) ProtoMessage()
func (*SignedMarginCall) ProtoReflect ¶
func (x *SignedMarginCall) ProtoReflect() protoreflect.Message
func (*SignedMarginCall) Reset ¶
func (x *SignedMarginCall) Reset()
func (*SignedMarginCall) String ¶
func (x *SignedMarginCall) String() string
type SignoutResponse ¶
type SignoutResponse struct {
// contains filtered or unexported fields
}
func (*SignoutResponse) Descriptor
deprecated
func (*SignoutResponse) Descriptor() ([]byte, []int)
Deprecated: Use SignoutResponse.ProtoReflect.Descriptor instead.
func (*SignoutResponse) ProtoMessage ¶
func (*SignoutResponse) ProtoMessage()
func (*SignoutResponse) ProtoReflect ¶
func (x *SignoutResponse) ProtoReflect() protoreflect.Message
func (*SignoutResponse) Reset ¶
func (x *SignoutResponse) Reset()
func (*SignoutResponse) String ¶
func (x *SignoutResponse) String() string
type SingleAssetExit ¶
type SingleAssetExit struct { // Either the zero address (implying the native token) // or the address of an ERC20 contract Asset *Address `protobuf:"bytes,1,opt,name=asset,proto3" json:"asset,omitempty"` AssetMetadata *AssetMetadata `protobuf:"bytes,2,opt,name=asset_metadata,json=assetMetadata,proto3" json:"asset_metadata,omitempty"` Allocations []*Allocation `protobuf:"bytes,3,rep,name=allocations,proto3" json:"allocations,omitempty"` // contains filtered or unexported fields }
func (*SingleAssetExit) Descriptor
deprecated
func (*SingleAssetExit) Descriptor() ([]byte, []int)
Deprecated: Use SingleAssetExit.ProtoReflect.Descriptor instead.
func (*SingleAssetExit) GetAllocations ¶
func (x *SingleAssetExit) GetAllocations() []*Allocation
func (*SingleAssetExit) GetAsset ¶
func (x *SingleAssetExit) GetAsset() *Address
func (*SingleAssetExit) GetAssetMetadata ¶
func (x *SingleAssetExit) GetAssetMetadata() *AssetMetadata
func (*SingleAssetExit) ProtoMessage ¶
func (*SingleAssetExit) ProtoMessage()
func (*SingleAssetExit) ProtoReflect ¶
func (x *SingleAssetExit) ProtoReflect() protoreflect.Message
func (*SingleAssetExit) Reset ¶
func (x *SingleAssetExit) Reset()
func (*SingleAssetExit) String ¶
func (x *SingleAssetExit) String() string
type State ¶
type State struct { Participants []*Address `protobuf:"bytes,1,rep,name=participants,proto3" json:"participants,omitempty"` ChannelNonce uint64 `protobuf:"varint,2,opt,name=channel_nonce,json=channelNonce,proto3" json:"channel_nonce,omitempty"` AppDefinition *Address `protobuf:"bytes,3,opt,name=app_definition,json=appDefinition,proto3" json:"app_definition,omitempty"` ChallengeDuration uint32 `protobuf:"varint,4,opt,name=challenge_duration,json=challengeDuration,proto3" json:"challenge_duration,omitempty"` AppData []byte `protobuf:"bytes,5,opt,name=app_data,json=appData,proto3" json:"app_data,omitempty"` Outcome *Exit `protobuf:"bytes,6,opt,name=outcome,proto3" json:"outcome,omitempty"` TurnNum uint64 `protobuf:"varint,7,opt,name=turn_num,json=turnNum,proto3" json:"turn_num,omitempty"` IsFinal bool `protobuf:"varint,8,opt,name=is_final,json=isFinal,proto3" json:"is_final,omitempty"` // contains filtered or unexported fields }
func (*State) Descriptor
deprecated
func (*State) GetAppData ¶
func (*State) GetAppDefinition ¶
func (*State) GetChallengeDuration ¶
func (*State) GetChannelNonce ¶
func (*State) GetIsFinal ¶
func (*State) GetOutcome ¶
func (*State) GetParticipants ¶
func (*State) GetTurnNum ¶
func (*State) ProtoMessage ¶
func (*State) ProtoMessage()
func (*State) ProtoReflect ¶
func (x *State) ProtoReflect() protoreflect.Message
type StateConfirmation ¶
type StateConfirmation struct { State SettlementState `protobuf:"varint,1,opt,name=state,proto3,enum=settlement.SettlementState" json:"state,omitempty"` // contains filtered or unexported fields }
func (*StateConfirmation) Descriptor
deprecated
func (*StateConfirmation) Descriptor() ([]byte, []int)
Deprecated: Use StateConfirmation.ProtoReflect.Descriptor instead.
func (*StateConfirmation) GetState ¶
func (x *StateConfirmation) GetState() SettlementState
func (*StateConfirmation) ProtoMessage ¶
func (*StateConfirmation) ProtoMessage()
func (*StateConfirmation) ProtoReflect ¶
func (x *StateConfirmation) ProtoReflect() protoreflect.Message
func (*StateConfirmation) Reset ¶
func (x *StateConfirmation) Reset()
func (*StateConfirmation) String ¶
func (x *StateConfirmation) String() string
type StreamNotification ¶
type StreamNotification struct { ChannelId string `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` Event ClearingEvent `protobuf:"varint,2,opt,name=event,proto3,enum=ClearingEvent" json:"event,omitempty"` State ClearingState `protobuf:"varint,3,opt,name=state,proto3,enum=ClearingState" json:"state,omitempty"` MyRole ProtocolIndex `protobuf:"varint,4,opt,name=my_role,json=myRole,proto3,enum=core.ProtocolIndex" json:"my_role,omitempty"` Peer *Peer `protobuf:"bytes,5,opt,name=peer,proto3" json:"peer,omitempty"` MarginLimitType MarginLimitType `` /* 135-byte string literal not displayed */ MarginDeposit string `protobuf:"bytes,7,opt,name=margin_deposit,json=marginDeposit,proto3" json:"margin_deposit,omitempty"` InitiatorMarginBalance string `` // margin updates will be reflected here /* 129-byte string literal not displayed */ FollowerMarginBalance string `` // margin updates will be reflected here /* 126-byte string literal not displayed */ TurnNum uint64 `protobuf:"varint,10,opt,name=turn_num,json=turnNum,proto3" json:"turn_num,omitempty"` ClearingSmState ClearingSMState `` /* 145-byte string literal not displayed */ // contains filtered or unexported fields }
func (*StreamNotification) Descriptor
deprecated
func (*StreamNotification) Descriptor() ([]byte, []int)
Deprecated: Use StreamNotification.ProtoReflect.Descriptor instead.
func (*StreamNotification) GetChannelId ¶
func (x *StreamNotification) GetChannelId() string
func (*StreamNotification) GetClearingSmState ¶ added in v0.0.67
func (x *StreamNotification) GetClearingSmState() ClearingSMState
func (*StreamNotification) GetEvent ¶ added in v0.0.122
func (x *StreamNotification) GetEvent() ClearingEvent
func (*StreamNotification) GetFollowerMarginBalance ¶
func (x *StreamNotification) GetFollowerMarginBalance() string
func (*StreamNotification) GetInitiatorMarginBalance ¶
func (x *StreamNotification) GetInitiatorMarginBalance() string
func (*StreamNotification) GetMarginDeposit ¶
func (x *StreamNotification) GetMarginDeposit() string
func (*StreamNotification) GetMarginLimitType ¶ added in v0.0.5
func (x *StreamNotification) GetMarginLimitType() MarginLimitType
func (*StreamNotification) GetMyRole ¶
func (x *StreamNotification) GetMyRole() ProtocolIndex
func (*StreamNotification) GetPeer ¶
func (x *StreamNotification) GetPeer() *Peer
func (*StreamNotification) GetState ¶ added in v0.0.122
func (x *StreamNotification) GetState() ClearingState
func (*StreamNotification) GetTurnNum ¶
func (x *StreamNotification) GetTurnNum() uint64
func (*StreamNotification) ProtoMessage ¶
func (*StreamNotification) ProtoMessage()
func (*StreamNotification) ProtoReflect ¶
func (x *StreamNotification) ProtoReflect() protoreflect.Message
func (*StreamNotification) Reset ¶
func (x *StreamNotification) Reset()
func (*StreamNotification) String ¶
func (x *StreamNotification) String() string
type SubscribeRequest ¶
type SubscribeRequest struct {
// contains filtered or unexported fields
}
func (*SubscribeRequest) Descriptor
deprecated
func (*SubscribeRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.
func (*SubscribeRequest) ProtoMessage ¶
func (*SubscribeRequest) ProtoMessage()
func (*SubscribeRequest) ProtoReflect ¶
func (x *SubscribeRequest) ProtoReflect() protoreflect.Message
func (*SubscribeRequest) Reset ¶
func (x *SubscribeRequest) Reset()
func (*SubscribeRequest) String ¶
func (x *SubscribeRequest) String() string
type SubscribeTradesRequest ¶ added in v0.0.74
type SubscribeTradesRequest struct { ChannelId string `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` LastExternalId string `protobuf:"bytes,2,opt,name=last_external_id,json=lastExternalId,proto3" json:"last_external_id,omitempty"` // contains filtered or unexported fields }
func (*SubscribeTradesRequest) Descriptor
deprecated
added in
v0.0.74
func (*SubscribeTradesRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeTradesRequest.ProtoReflect.Descriptor instead.
func (*SubscribeTradesRequest) GetChannelId ¶ added in v0.0.74
func (x *SubscribeTradesRequest) GetChannelId() string
func (*SubscribeTradesRequest) GetLastExternalId ¶ added in v0.0.74
func (x *SubscribeTradesRequest) GetLastExternalId() string
func (*SubscribeTradesRequest) ProtoMessage ¶ added in v0.0.74
func (*SubscribeTradesRequest) ProtoMessage()
func (*SubscribeTradesRequest) ProtoReflect ¶ added in v0.0.74
func (x *SubscribeTradesRequest) ProtoReflect() protoreflect.Message
func (*SubscribeTradesRequest) Reset ¶ added in v0.0.74
func (x *SubscribeTradesRequest) Reset()
func (*SubscribeTradesRequest) String ¶ added in v0.0.74
func (x *SubscribeTradesRequest) String() string
type Trade ¶
type Trade struct { ChannelId string `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` ExternalId string `protobuf:"bytes,2,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"` Market *Market `protobuf:"bytes,3,opt,name=market,proto3" json:"market,omitempty"` Direction Direction `protobuf:"varint,4,opt,name=direction,proto3,enum=core.Direction" json:"direction,omitempty"` Amount *Decimal `protobuf:"bytes,5,opt,name=amount,proto3" json:"amount,omitempty"` Price *Decimal `protobuf:"bytes,6,opt,name=price,proto3" json:"price,omitempty"` ExecutedAt int64 `protobuf:"varint,7,opt,name=executed_at,json=executedAt,proto3" json:"executed_at,omitempty"` // contains filtered or unexported fields }
func (*Trade) Descriptor
deprecated
func (*Trade) GetChannelId ¶
func (*Trade) GetDirection ¶
func (*Trade) GetExecutedAt ¶
func (*Trade) GetExternalId ¶
func (*Trade) ProtoMessage ¶
func (*Trade) ProtoMessage()
func (*Trade) ProtoReflect ¶
func (x *Trade) ProtoReflect() protoreflect.Message
type TradeChannelClient ¶
type TradeChannelClient interface { Prefund(ctx context.Context, in *TradeState, opts ...grpc.CallOption) (*TradeState, error) Postfund(ctx context.Context, in *TradeState, opts ...grpc.CallOption) (*TradeState, error) UpdateMargin(ctx context.Context, in *SignedMarginCall, opts ...grpc.CallOption) (*SignedMarginCall, error) // TODO: Message protocol to be defined // Find how to bind with Settlement SVC RequestSettlement(ctx context.Context, in *TradeState, opts ...grpc.CallOption) (*TradeState, error) Finalize(ctx context.Context, in *TradeState, opts ...grpc.CallOption) (*TradeState, error) }
TradeChannelClient is the client API for TradeChannel service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewTradeChannelClient ¶
func NewTradeChannelClient(cc grpc.ClientConnInterface) TradeChannelClient
type TradeChannelServer ¶
type TradeChannelServer interface { Prefund(context.Context, *TradeState) (*TradeState, error) Postfund(context.Context, *TradeState) (*TradeState, error) UpdateMargin(context.Context, *SignedMarginCall) (*SignedMarginCall, error) // TODO: Message protocol to be defined // Find how to bind with Settlement SVC RequestSettlement(context.Context, *TradeState) (*TradeState, error) Finalize(context.Context, *TradeState) (*TradeState, error) // contains filtered or unexported methods }
TradeChannelServer is the server API for TradeChannel service. All implementations must embed UnimplementedTradeChannelServer for forward compatibility
type TradeRequest ¶
type TradeRequest struct { Trade *Trade `protobuf:"bytes,1,opt,name=trade,proto3" json:"trade,omitempty"` // contains filtered or unexported fields }
func (*TradeRequest) Descriptor
deprecated
func (*TradeRequest) Descriptor() ([]byte, []int)
Deprecated: Use TradeRequest.ProtoReflect.Descriptor instead.
func (*TradeRequest) GetTrade ¶
func (x *TradeRequest) GetTrade() *Trade
func (*TradeRequest) ProtoMessage ¶
func (*TradeRequest) ProtoMessage()
func (*TradeRequest) ProtoReflect ¶
func (x *TradeRequest) ProtoReflect() protoreflect.Message
func (*TradeRequest) Reset ¶
func (x *TradeRequest) Reset()
func (*TradeRequest) String ¶
func (x *TradeRequest) String() string
type TradeResponse ¶
type TradeResponse struct { Trade *Trade `protobuf:"bytes,1,opt,name=trade,proto3" json:"trade,omitempty"` // contains filtered or unexported fields }
func (*TradeResponse) Descriptor
deprecated
func (*TradeResponse) Descriptor() ([]byte, []int)
Deprecated: Use TradeResponse.ProtoReflect.Descriptor instead.
func (*TradeResponse) GetTrade ¶
func (x *TradeResponse) GetTrade() *Trade
func (*TradeResponse) ProtoMessage ¶
func (*TradeResponse) ProtoMessage()
func (*TradeResponse) ProtoReflect ¶
func (x *TradeResponse) ProtoReflect() protoreflect.Message
func (*TradeResponse) Reset ¶
func (x *TradeResponse) Reset()
func (*TradeResponse) String ¶
func (x *TradeResponse) String() string
type TradeState ¶
type TradeState struct { ChannelId []byte `protobuf:"bytes,1,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"` State *State `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"` StateHash []byte `protobuf:"bytes,3,opt,name=state_hash,json=stateHash,proto3" json:"state_hash,omitempty"` StateHashSigs []*Signature `protobuf:"bytes,4,rep,name=state_hash_sigs,json=stateHashSigs,proto3" json:"state_hash_sigs,omitempty"` Safety *Decimal `protobuf:"bytes,5,opt,name=safety,proto3" json:"safety,omitempty"` MarginCall *SignedMarginCall `protobuf:"bytes,6,opt,name=margin_call,json=marginCall,proto3" json:"margin_call,omitempty"` // contains filtered or unexported fields }
Message Trading Channel state definition
func (*TradeState) Descriptor
deprecated
func (*TradeState) Descriptor() ([]byte, []int)
Deprecated: Use TradeState.ProtoReflect.Descriptor instead.
func (*TradeState) GetChannelId ¶
func (x *TradeState) GetChannelId() []byte
func (*TradeState) GetMarginCall ¶
func (x *TradeState) GetMarginCall() *SignedMarginCall
func (*TradeState) GetSafety ¶
func (x *TradeState) GetSafety() *Decimal
func (*TradeState) GetState ¶
func (x *TradeState) GetState() *State
func (*TradeState) GetStateHash ¶
func (x *TradeState) GetStateHash() []byte
func (*TradeState) GetStateHashSigs ¶
func (x *TradeState) GetStateHashSigs() []*Signature
func (*TradeState) ProtoMessage ¶
func (*TradeState) ProtoMessage()
func (*TradeState) ProtoReflect ¶
func (x *TradeState) ProtoReflect() protoreflect.Message
func (*TradeState) Reset ¶
func (x *TradeState) Reset()
func (*TradeState) String ¶
func (x *TradeState) String() string
type TradesRequest ¶ added in v0.0.5
type TradesRequest struct { Trades []*Trade `protobuf:"bytes,1,rep,name=trades,proto3" json:"trades,omitempty"` // contains filtered or unexported fields }
Maximum number of trades per request is 6765
func (*TradesRequest) Descriptor
deprecated
added in
v0.0.5
func (*TradesRequest) Descriptor() ([]byte, []int)
Deprecated: Use TradesRequest.ProtoReflect.Descriptor instead.
func (*TradesRequest) GetTrades ¶ added in v0.0.5
func (x *TradesRequest) GetTrades() []*Trade
func (*TradesRequest) ProtoMessage ¶ added in v0.0.5
func (*TradesRequest) ProtoMessage()
func (*TradesRequest) ProtoReflect ¶ added in v0.0.5
func (x *TradesRequest) ProtoReflect() protoreflect.Message
func (*TradesRequest) Reset ¶ added in v0.0.5
func (x *TradesRequest) Reset()
func (*TradesRequest) String ¶ added in v0.0.5
func (x *TradesRequest) String() string
type TradesResponse ¶ added in v0.0.5
type TradesResponse struct {
// contains filtered or unexported fields
}
func (*TradesResponse) Descriptor
deprecated
added in
v0.0.5
func (*TradesResponse) Descriptor() ([]byte, []int)
Deprecated: Use TradesResponse.ProtoReflect.Descriptor instead.
func (*TradesResponse) ProtoMessage ¶ added in v0.0.5
func (*TradesResponse) ProtoMessage()
func (*TradesResponse) ProtoReflect ¶ added in v0.0.5
func (x *TradesResponse) ProtoReflect() protoreflect.Message
func (*TradesResponse) Reset ¶ added in v0.0.5
func (x *TradesResponse) Reset()
func (*TradesResponse) String ¶ added in v0.0.5
func (x *TradesResponse) String() string
type TransactionNotification ¶ added in v0.0.9
type TransactionNotification struct { To string `protobuf:"bytes,1,opt,name=to,proto3" json:"to,omitempty"` Data string `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*TransactionNotification) Descriptor
deprecated
added in
v0.0.9
func (*TransactionNotification) Descriptor() ([]byte, []int)
Deprecated: Use TransactionNotification.ProtoReflect.Descriptor instead.
func (*TransactionNotification) GetData ¶ added in v0.0.9
func (x *TransactionNotification) GetData() string
func (*TransactionNotification) GetTo ¶ added in v0.0.9
func (x *TransactionNotification) GetTo() string
func (*TransactionNotification) ProtoMessage ¶ added in v0.0.9
func (*TransactionNotification) ProtoMessage()
func (*TransactionNotification) ProtoReflect ¶ added in v0.0.9
func (x *TransactionNotification) ProtoReflect() protoreflect.Message
func (*TransactionNotification) Reset ¶ added in v0.0.9
func (x *TransactionNotification) Reset()
func (*TransactionNotification) String ¶ added in v0.0.9
func (x *TransactionNotification) String() string
type UnimplementedAuthServer ¶
type UnimplementedAuthServer struct { }
UnimplementedAuthServer must be embedded to have forward compatible implementations.
func (UnimplementedAuthServer) Authenticate ¶
func (UnimplementedAuthServer) Authenticate(context.Context, *SignedChallenge) (*AuthToken, error)
func (UnimplementedAuthServer) GetChallenge ¶
func (UnimplementedAuthServer) GetChallenge(context.Context, *ChallengeRequest) (*ChallengeResponse, error)
func (UnimplementedAuthServer) Signout ¶
func (UnimplementedAuthServer) Signout(context.Context, *AuthToken) (*SignoutResponse, error)
func (UnimplementedAuthServer) TokenRefresh ¶
type UnimplementedChannelServer ¶
type UnimplementedChannelServer struct { }
UnimplementedChannelServer must be embedded to have forward compatible implementations.
func (UnimplementedChannelServer) Close ¶
func (UnimplementedChannelServer) Close(context.Context, *ChannelState) (*Signature, error)
func (UnimplementedChannelServer) Open ¶
func (UnimplementedChannelServer) Open(context.Context, *ChannelState) (*Signature, error)
func (UnimplementedChannelServer) SubscribeTrades ¶ added in v0.0.74
func (UnimplementedChannelServer) SubscribeTrades(*SubscribeTradesRequest, Channel_SubscribeTradesServer) error
func (UnimplementedChannelServer) Update ¶
func (UnimplementedChannelServer) Update(context.Context, *ChannelState) (*Signature, error)
type UnimplementedEscrowChannelServer ¶
type UnimplementedEscrowChannelServer struct { }
UnimplementedEscrowChannelServer must be embedded to have forward compatible implementations.
func (UnimplementedEscrowChannelServer) Execute ¶
func (UnimplementedEscrowChannelServer) Execute(context.Context, *EscrowState) (*EscrowState, error)
func (UnimplementedEscrowChannelServer) Finalize ¶
func (UnimplementedEscrowChannelServer) Finalize(context.Context, *EscrowState) (*EscrowState, error)
func (UnimplementedEscrowChannelServer) Postfund ¶
func (UnimplementedEscrowChannelServer) Postfund(context.Context, *EscrowState) (*EscrowState, error)
func (UnimplementedEscrowChannelServer) Prefund ¶
func (UnimplementedEscrowChannelServer) Prefund(context.Context, *EscrowState) (*EscrowState, error)
type UnimplementedOperatorServer ¶
type UnimplementedOperatorServer struct { }
UnimplementedOperatorServer must be embedded to have forward compatible implementations.
func (UnimplementedOperatorServer) Authenticate ¶
func (UnimplementedOperatorServer) Authenticate(context.Context, *AuthenticateRequest) (*AuthenticateResponse, error)
func (UnimplementedOperatorServer) CloseChannel ¶
func (UnimplementedOperatorServer) CloseChannel(context.Context, *CloseChannelRequest) (*CloseChannelResponse, error)
func (UnimplementedOperatorServer) GetActiveClearStreams ¶ added in v0.0.106
func (UnimplementedOperatorServer) GetActiveClearStreams(context.Context, *GetActiveClearStreamsRequest) (*GetActiveClearStreamsResponse, error)
func (UnimplementedOperatorServer) GetChallenge ¶
func (UnimplementedOperatorServer) GetChallenge(context.Context, *GetChallengeRequest) (*GetChallengeResponse, error)
func (UnimplementedOperatorServer) GetChannelJwt ¶
func (UnimplementedOperatorServer) GetChannelJwt(context.Context, *GetJwtRequest) (*GetJwtResponse, error)
func (UnimplementedOperatorServer) GetPositions ¶
func (UnimplementedOperatorServer) GetPositions(context.Context, *GetPositionsRequest) (*GetPositionsResponse, error)
func (UnimplementedOperatorServer) GetVersion ¶
func (UnimplementedOperatorServer) GetVersion(context.Context, *VersionRequest) (*VersionResponse, error)
func (UnimplementedOperatorServer) OpenChannel ¶
func (UnimplementedOperatorServer) OpenChannel(context.Context, *OpenChannelRequest) (*OpenChannelResponse, error)
func (UnimplementedOperatorServer) RecordTrade ¶
func (UnimplementedOperatorServer) RecordTrade(context.Context, *TradeRequest) (*TradeResponse, error)
func (UnimplementedOperatorServer) RecordTrades ¶ added in v0.0.5
func (UnimplementedOperatorServer) RecordTrades(context.Context, *TradesRequest) (*TradesResponse, error)
func (UnimplementedOperatorServer) RequestSettlement ¶
func (UnimplementedOperatorServer) RequestSettlement(context.Context, *SettlementRequest) (*SettlementResponse, error)
func (UnimplementedOperatorServer) SubscribeChannelsEvents ¶
func (UnimplementedOperatorServer) SubscribeChannelsEvents(*SubscribeRequest, Operator_SubscribeChannelsEventsServer) error
type UnimplementedPriceFeedServer ¶ added in v0.0.23
type UnimplementedPriceFeedServer struct { }
UnimplementedPriceFeedServer must be embedded to have forward compatible implementations.
func (UnimplementedPriceFeedServer) Subscribe ¶ added in v0.0.23
func (UnimplementedPriceFeedServer) Subscribe(*PriceFeedSubscribeRequest, PriceFeed_SubscribeServer) error
type UnimplementedSettlementServiceServer ¶
type UnimplementedSettlementServiceServer struct { }
UnimplementedSettlementServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedSettlementServiceServer) Finalize ¶
func (UnimplementedSettlementServiceServer) Finalize(context.Context, *FinalizeRequest) (*FinalizeResponse, error)
func (UnimplementedSettlementServiceServer) Prepare ¶
func (UnimplementedSettlementServiceServer) Prepare(context.Context, *PrepareRequest) (*PrepareResponse, error)
func (UnimplementedSettlementServiceServer) Update ¶
func (UnimplementedSettlementServiceServer) Update(context.Context, *SettlementStateUpdate) (*StateConfirmation, error)
type UnimplementedTradeChannelServer ¶
type UnimplementedTradeChannelServer struct { }
UnimplementedTradeChannelServer must be embedded to have forward compatible implementations.
func (UnimplementedTradeChannelServer) Finalize ¶
func (UnimplementedTradeChannelServer) Finalize(context.Context, *TradeState) (*TradeState, error)
func (UnimplementedTradeChannelServer) Postfund ¶
func (UnimplementedTradeChannelServer) Postfund(context.Context, *TradeState) (*TradeState, error)
func (UnimplementedTradeChannelServer) Prefund ¶
func (UnimplementedTradeChannelServer) Prefund(context.Context, *TradeState) (*TradeState, error)
func (UnimplementedTradeChannelServer) RequestSettlement ¶
func (UnimplementedTradeChannelServer) RequestSettlement(context.Context, *TradeState) (*TradeState, error)
func (UnimplementedTradeChannelServer) UpdateMargin ¶
func (UnimplementedTradeChannelServer) UpdateMargin(context.Context, *SignedMarginCall) (*SignedMarginCall, error)
type UnsafeAuthServer ¶
type UnsafeAuthServer interface {
// contains filtered or unexported methods
}
UnsafeAuthServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AuthServer will result in compilation errors.
type UnsafeChannelServer ¶
type UnsafeChannelServer interface {
// contains filtered or unexported methods
}
UnsafeChannelServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ChannelServer will result in compilation errors.
type UnsafeEscrowChannelServer ¶
type UnsafeEscrowChannelServer interface {
// contains filtered or unexported methods
}
UnsafeEscrowChannelServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EscrowChannelServer will result in compilation errors.
type UnsafeOperatorServer ¶
type UnsafeOperatorServer interface {
// contains filtered or unexported methods
}
UnsafeOperatorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OperatorServer will result in compilation errors.
type UnsafePriceFeedServer ¶ added in v0.0.23
type UnsafePriceFeedServer interface {
// contains filtered or unexported methods
}
UnsafePriceFeedServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PriceFeedServer will result in compilation errors.
type UnsafeSettlementServiceServer ¶
type UnsafeSettlementServiceServer interface {
// contains filtered or unexported methods
}
UnsafeSettlementServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SettlementServiceServer will result in compilation errors.
type UnsafeTradeChannelServer ¶
type UnsafeTradeChannelServer interface {
// contains filtered or unexported methods
}
UnsafeTradeChannelServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TradeChannelServer will result in compilation errors.
type VersionRequest ¶
type VersionRequest struct {
// contains filtered or unexported fields
}
func (*VersionRequest) Descriptor
deprecated
func (*VersionRequest) Descriptor() ([]byte, []int)
Deprecated: Use VersionRequest.ProtoReflect.Descriptor instead.
func (*VersionRequest) ProtoMessage ¶
func (*VersionRequest) ProtoMessage()
func (*VersionRequest) ProtoReflect ¶
func (x *VersionRequest) ProtoReflect() protoreflect.Message
func (*VersionRequest) Reset ¶
func (x *VersionRequest) Reset()
func (*VersionRequest) String ¶
func (x *VersionRequest) String() string
type VersionResponse ¶
type VersionResponse struct { Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*VersionResponse) Descriptor
deprecated
func (*VersionResponse) Descriptor() ([]byte, []int)
Deprecated: Use VersionResponse.ProtoReflect.Descriptor instead.
func (*VersionResponse) GetVersion ¶
func (x *VersionResponse) GetVersion() string
func (*VersionResponse) ProtoMessage ¶
func (*VersionResponse) ProtoMessage()
func (*VersionResponse) ProtoReflect ¶
func (x *VersionResponse) ProtoReflect() protoreflect.Message
func (*VersionResponse) Reset ¶
func (x *VersionResponse) Reset()
func (*VersionResponse) String ¶
func (x *VersionResponse) String() string
Source Files ¶
- auth.pb.go
- auth_grpc.pb.go
- channel.pb.go
- channel_grpc.pb.go
- clear_stream.pb.go
- core.pb.go
- escrow.pb.go
- escrow_grpc.pb.go
- exit.pb.go
- operator.pb.go
- operator_grpc.pb.go
- price_feed.pb.go
- price_feed_grpc.pb.go
- session_key.pb.go
- settlement.pb.go
- settlement_grpc.pb.go
- state.pb.go
- state_machine.pb.go
- trade.pb.go
- trade_grpc.pb.go