proto

package
v0.0.55 Latest Latest
Warning

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

 Go to latest Published: Apr 3, 2024 License: GPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
var (
	NotificationType_name = map[int32]string{
		0: "NOTIFICATION_TYPE_UNSPECIFIED",
		1: "NOTIFICATION_TYPE_CHANNEL_OPENING",
		2: "NOTIFICATION_TYPE_CHANNEL_OPENED",
		3: "NOTIFICATION_TYPE_CHANNEL_CLOSED",
		4: "NOTIFICATION_TYPE_CHALLENGE_STARTED",
		5: "NOTIFICATION_TYPE_CHALLENGE_CLEARED",
		6: "NOTIFICATION_TYPE_CHALLENGE_FINISHED",
		7: "NOTIFICATION_TYPE_MARGIN_UPDATED",
	}
	NotificationType_value = map[string]int32{
		"NOTIFICATION_TYPE_UNSPECIFIED":        0,
		"NOTIFICATION_TYPE_CHANNEL_OPENING":    1,
		"NOTIFICATION_TYPE_CHANNEL_OPENED":     2,
		"NOTIFICATION_TYPE_CHANNEL_CLOSED":     3,
		"NOTIFICATION_TYPE_CHALLENGE_STARTED":  4,
		"NOTIFICATION_TYPE_CHALLENGE_CLEARED":  5,
		"NOTIFICATION_TYPE_CHALLENGE_FINISHED": 6,
		"NOTIFICATION_TYPE_MARGIN_UPDATED":     7,
	}
)

Enum value maps for NotificationType.

View Source 
var (
	ChannelStatus_name = map[int32]string{
		0: "CHANNEL_STATUS_UNSPECIFIED",
		1: "CHANNEL_STATUS_OPENING",
		2: "CHANNEL_STATUS_OPEN",
		3: "CHANNEL_STATUS_CHALLENGING",
		4: "CHANNEL_STATUS_CLOSED",
	}
	ChannelStatus_value = map[string]int32{
		"CHANNEL_STATUS_UNSPECIFIED": 0,
		"CHANNEL_STATUS_OPENING":     1,
		"CHANNEL_STATUS_OPEN":        2,
		"CHANNEL_STATUS_CHALLENGING": 3,
		"CHANNEL_STATUS_CLOSED":      4,
	}
)

Enum value maps for ChannelStatus.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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)

View Source 
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{},
	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)

View Source 
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)

View Source 
var File_auth_proto protoreflect.FileDescriptor
View Source 
var File_channel_proto protoreflect.FileDescriptor
View Source 
var File_core_proto protoreflect.FileDescriptor
View Source 
var File_escrow_proto protoreflect.FileDescriptor
View Source 
var File_exit_proto protoreflect.FileDescriptor
View Source 
var File_operator_proto protoreflect.FileDescriptor
View Source 
var File_price_feed_proto protoreflect.FileDescriptor
View Source 
var File_settlement_proto protoreflect.FileDescriptor
View Source 
var File_state_proto protoreflect.FileDescriptor
View Source 
var File_trade_proto protoreflect.FileDescriptor
View Source 
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: "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)

View Source 
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)

View Source 
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)

View Source 
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) Descriptor() ([]byte, []int)

Deprecated: Use Address.ProtoReflect.Descriptor instead.

func (*Address) GetValue 

func (x *Address) GetValue() string

func (*Address) ProtoMessage 

func (*Address) ProtoMessage()

func (*Address) ProtoReflect 

func (x *Address) ProtoReflect() protoreflect.Message

func (*Address) Reset 

func (x *Address) Reset()

func (*Address) String 

func (x *Address) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Asset.ProtoReflect.Descriptor instead.

func (*Asset) GetAddress 

func (x *Asset) GetAddress() *Address

func (*Asset) GetChainId 

func (x *Asset) GetChainId() uint64

func (*Asset) GetDecimals 

func (x *Asset) GetDecimals() uint32

func (*Asset) GetSymbol 

func (x *Asset) GetSymbol() string

func (*Asset) ProtoMessage 

func (*Asset) ProtoMessage()

func (*Asset) ProtoReflect 

func (x *Asset) ProtoReflect() protoreflect.Message

func (*Asset) Reset 

func (x *Asset) Reset()

func (*Asset) String 

func (x *Asset) String() string

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
const (
	AssetType_ASSET_TYPE_UNSPECIFIED AssetType = 0
	AssetType_ASSET_TYPE_ERC721      AssetType = 1
	AssetType_ASSET_TYPE_ERC1155     AssetType = 2
	AssetType_ASSET_TYPE_QUALIFIED   AssetType = 3
)

func (AssetType) Descriptor 

func (AssetType) Descriptor() protoreflect.EnumDescriptor

func (AssetType) Enum 

func (x AssetType) Enum() *AssetType

func (AssetType) EnumDescriptor deprecated 

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

Deprecated: Use AssetType.Descriptor instead.

func (AssetType) Number 

func (x AssetType) Number() protoreflect.EnumNumber

func (AssetType) String 

func (x AssetType) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use AuthToken.ProtoReflect.Descriptor instead.

func (*AuthToken) GetToken 

func (x *AuthToken) GetToken() string

func (*AuthToken) ProtoMessage 

func (*AuthToken) ProtoMessage()

func (*AuthToken) ProtoReflect 

func (x *AuthToken) ProtoReflect() protoreflect.Message

func (*AuthToken) Reset 

func (x *AuthToken) Reset()

func (*AuthToken) String 

func (x *AuthToken) String() string

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 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)
}

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)
	// 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 ChannelStatus 

type ChannelStatus int32
const (
	ChannelStatus_CHANNEL_STATUS_UNSPECIFIED ChannelStatus = 0
	ChannelStatus_CHANNEL_STATUS_OPENING     ChannelStatus = 1
	ChannelStatus_CHANNEL_STATUS_OPEN        ChannelStatus = 2
	ChannelStatus_CHANNEL_STATUS_CHALLENGING ChannelStatus = 3
	ChannelStatus_CHANNEL_STATUS_CLOSED      ChannelStatus = 4
)

func (ChannelStatus) Descriptor 

func (ChannelStatus) Descriptor() protoreflect.EnumDescriptor

func (ChannelStatus) Enum 

func (x ChannelStatus) Enum() *ChannelStatus

func (ChannelStatus) EnumDescriptor deprecated 

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

Deprecated: Use ChannelStatus.Descriptor instead.

func (ChannelStatus) Number 

func (x ChannelStatus) Number() protoreflect.EnumNumber

func (ChannelStatus) String 

func (x ChannelStatus) String() string

func (ChannelStatus) Type 

func (ChannelStatus) 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) Descriptor() ([]byte, []int)

Deprecated: Use Decimal.ProtoReflect.Descriptor instead.

func (*Decimal) GetValue 

func (x *Decimal) GetValue() string

func (*Decimal) ProtoMessage 

func (*Decimal) ProtoMessage()

func (*Decimal) ProtoReflect 

func (x *Decimal) ProtoReflect() protoreflect.Message

func (*Decimal) Reset 

func (x *Decimal) Reset()

func (*Decimal) String 

func (x *Decimal) String() string

type Direction 

type Direction int32
const (
	Direction_DIRECTION_UNSPECIFIED Direction = 0
	Direction_DIRECTION_BUY         Direction = 1
	Direction_DIRECTION_SELL        Direction = 2
)

func (Direction) Descriptor 

func (Direction) Descriptor() protoreflect.EnumDescriptor

func (Direction) Enum 

func (x Direction) Enum() *Direction

func (Direction) EnumDescriptor deprecated 

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

Deprecated: Use Direction.Descriptor instead.

func (Direction) Number 

func (x Direction) Number() protoreflect.EnumNumber

func (Direction) String 

func (x Direction) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Exit.ProtoReflect.Descriptor instead.

func (*Exit) GetSingleAssetExits 

func (x *Exit) GetSingleAssetExits() []*SingleAssetExit

func (*Exit) ProtoMessage 

func (*Exit) ProtoMessage()

func (*Exit) ProtoReflect 

func (x *Exit) ProtoReflect() protoreflect.Message

func (*Exit) Reset 

func (x *Exit) Reset()

func (*Exit) String 

func (x *Exit) String() string

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 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 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) Descriptor() ([]byte, []int)

Deprecated: Use Liability.ProtoReflect.Descriptor instead.

func (*Liability) GetAmount 

func (x *Liability) GetAmount() string

func (*Liability) GetAsset 

func (x *Liability) GetAsset() *Asset

func (*Liability) ProtoMessage 

func (*Liability) ProtoMessage()

func (*Liability) ProtoReflect 

func (x *Liability) ProtoReflect() protoreflect.Message

func (*Liability) Reset 

func (x *Liability) Reset()

func (*Liability) String 

func (x *Liability) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Market.ProtoReflect.Descriptor instead.

func (*Market) GetBase 

func (x *Market) GetBase() string

func (*Market) GetQuote 

func (x *Market) GetQuote() string

func (*Market) ProtoMessage 

func (*Market) ProtoMessage()

func (*Market) ProtoReflect 

func (x *Market) ProtoReflect() protoreflect.Message

func (*Market) Reset 

func (x *Market) Reset()

func (*Market) String 

func (x *Market) String() string

type Notification 

type Notification struct {

	// Types that are assignable to Notification:
	//
	//	*Notification_StreamNotification
	//	*Notification_SettlementNotification
	//	*Notification_PositionNotification
	//	*Notification_ErrorNotification
	//	*Notification_TransactionNotification
	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) 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 NotificationType 

type NotificationType int32
const (
	NotificationType_NOTIFICATION_TYPE_UNSPECIFIED        NotificationType = 0
	NotificationType_NOTIFICATION_TYPE_CHANNEL_OPENING    NotificationType = 1
	NotificationType_NOTIFICATION_TYPE_CHANNEL_OPENED     NotificationType = 2
	NotificationType_NOTIFICATION_TYPE_CHANNEL_CLOSED     NotificationType = 3
	NotificationType_NOTIFICATION_TYPE_CHALLENGE_STARTED  NotificationType = 4
	NotificationType_NOTIFICATION_TYPE_CHALLENGE_CLEARED  NotificationType = 5
	NotificationType_NOTIFICATION_TYPE_CHALLENGE_FINISHED NotificationType = 6
	NotificationType_NOTIFICATION_TYPE_MARGIN_UPDATED     NotificationType = 7
)

func (NotificationType) Descriptor 

func (NotificationType) Descriptor() protoreflect.EnumDescriptor

func (NotificationType) Enum 

func (x NotificationType) Enum() *NotificationType

func (NotificationType) EnumDescriptor deprecated 

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

Deprecated: Use NotificationType.Descriptor instead.

func (NotificationType) Number 

func (x NotificationType) Number() protoreflect.EnumNumber

func (NotificationType) String 

func (x NotificationType) String() string

func (NotificationType) Type 

func (NotificationType) Type() protoreflect.EnumType

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_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)
	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)
	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 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) Descriptor() ([]byte, []int)

Deprecated: Use Peer.ProtoReflect.Descriptor instead.

func (*Peer) GetName 

func (x *Peer) GetName() string

func (*Peer) GetOperatorAddress added in v0.0.27 

func (x *Peer) GetOperatorAddress() string

func (*Peer) GetParticipantAddress added in v0.0.12 

func (x *Peer) GetParticipantAddress() string

func (*Peer) GetUrl 

func (x *Peer) GetUrl() string

func (*Peer) ProtoMessage 

func (*Peer) ProtoMessage()

func (*Peer) ProtoReflect 

func (x *Peer) ProtoReflect() protoreflect.Message

func (*Peer) Reset 

func (x *Peer) Reset()

func (*Peer) String 

func (x *Peer) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Position.ProtoReflect.Descriptor instead.

func (*Position) GetAmount 

func (x *Position) GetAmount() string

func (*Position) GetChannelId 

func (x *Position) GetChannelId() string

func (*Position) GetCost 

func (x *Position) GetCost() string

func (*Position) GetDirection 

func (x *Position) GetDirection() Direction

func (*Position) GetId added in v0.0.13 

func (x *Position) GetId() string

func (*Position) GetMarket 

func (x *Position) GetMarket() *Market

func (*Position) GetMarketValue 

func (x *Position) GetMarketValue() string

func (*Position) GetPnl 

func (x *Position) GetPnl() string

func (*Position) GetStatus 

func (x *Position) GetStatus() PositionStatus

func (*Position) ProtoMessage 

func (*Position) ProtoMessage()

func (*Position) ProtoReflect 

func (x *Position) ProtoReflect() protoreflect.Message

func (*Position) Reset 

func (x *Position) Reset()

func (*Position) String 

func (x *Position) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Quote.ProtoReflect.Descriptor instead.

func (*Quote) GetMarket added in v0.0.23 

func (x *Quote) GetMarket() *Market

func (*Quote) GetPrice added in v0.0.23 

func (x *Quote) GetPrice() *Decimal

func (*Quote) GetTimestamp added in v0.0.23 

func (x *Quote) GetTimestamp() int64

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

func (*Quote) Reset added in v0.0.23 

func (x *Quote) Reset()

func (*Quote) String added in v0.0.23 

func (x *Quote) 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 */
	// 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) 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) Descriptor() ([]byte, []int)

Deprecated: Use Signature.ProtoReflect.Descriptor instead.

func (*Signature) GetR 

func (x *Signature) GetR() []byte

func (*Signature) GetS 

func (x *Signature) GetS() []byte

func (*Signature) GetV 

func (x *Signature) GetV() uint32

func (*Signature) ProtoMessage 

func (*Signature) ProtoMessage()

func (*Signature) ProtoReflect 

func (x *Signature) ProtoReflect() protoreflect.Message

func (*Signature) Reset 

func (x *Signature) Reset()

func (*Signature) String 

func (x *Signature) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use State.ProtoReflect.Descriptor instead.

func (*State) GetAppData 

func (x *State) GetAppData() []byte

func (*State) GetAppDefinition 

func (x *State) GetAppDefinition() *Address

func (*State) GetChallengeDuration 

func (x *State) GetChallengeDuration() uint32

func (*State) GetChannelNonce 

func (x *State) GetChannelNonce() uint64

func (*State) GetIsFinal 

func (x *State) GetIsFinal() bool

func (*State) GetOutcome 

func (x *State) GetOutcome() *Exit

func (*State) GetParticipants 

func (x *State) GetParticipants() []*Address

func (*State) GetTurnNum 

func (x *State) GetTurnNum() uint64

func (*State) ProtoMessage 

func (*State) ProtoMessage()

func (*State) ProtoReflect 

func (x *State) ProtoReflect() protoreflect.Message

func (*State) Reset 

func (x *State) Reset()

func (*State) String 

func (x *State) String() string

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"`
	NotificationType       NotificationType `` /* 132-byte string literal not displayed */
	ChannelStatus          ChannelStatus    `protobuf:"varint,3,opt,name=channel_status,json=channelStatus,proto3,enum=ChannelStatus" json:"channel_status,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"`
	// 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) GetChannelStatus 

func (x *StreamNotification) GetChannelStatus() ChannelStatus

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) GetNotificationType 

func (x *StreamNotification) GetNotificationType() NotificationType

func (*StreamNotification) GetPeer 

func (x *StreamNotification) GetPeer() *Peer

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 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) Descriptor() ([]byte, []int)

Deprecated: Use Trade.ProtoReflect.Descriptor instead.

func (*Trade) GetAmount 

func (x *Trade) GetAmount() *Decimal

func (*Trade) GetChannelId 

func (x *Trade) GetChannelId() string

func (*Trade) GetDirection 

func (x *Trade) GetDirection() Direction

func (*Trade) GetExecutedAt 

func (x *Trade) GetExecutedAt() int64

func (*Trade) GetExternalId 

func (x *Trade) GetExternalId() string

func (*Trade) GetMarket 

func (x *Trade) GetMarket() *Market

func (*Trade) GetPrice 

func (x *Trade) GetPrice() *Decimal

func (*Trade) ProtoMessage 

func (*Trade) ProtoMessage()

func (*Trade) ProtoReflect 

func (x *Trade) ProtoReflect() protoreflect.Message

func (*Trade) Reset 

func (x *Trade) Reset()

func (*Trade) String 

func (x *Trade) String() string

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 

func (UnimplementedAuthServer) TokenRefresh(context.Context, *AuthToken) (*AuthToken, error)

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) 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) 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

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.