Versions in this module Expand all Collapse all v0 v0.0.4 Feb 7, 2020 Changes in this version + var ChannelHandlerClientCommand = &cobra.Command + var NodeHandlerClientCommand = &cobra.Command + var Operation_name = map[int32]string + var Operation_value = map[string]int32 + var OrderHandlerClientCommand = &cobra.Command + var State_name = map[int32]string + var State_value = map[string]int32 + func RegisterChannelHandlerServer(s *grpc.Server, srv ChannelHandlerServer) + func RegisterNodeHandlerServer(s *grpc.Server, srv NodeHandlerServer) + func RegisterOrderHandlerServer(s *grpc.Server, srv OrderHandlerServer) + type Channel struct + Id []byte + Options *ChannelOptions + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Channel) Descriptor() ([]byte, []int) + func (*Channel) ProtoMessage() + func (m *Channel) GetId() []byte + func (m *Channel) GetOptions() *ChannelOptions + func (m *Channel) Reset() + func (m *Channel) String() string + func (m *Channel) XXX_DiscardUnknown() + func (m *Channel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Channel) XXX_Merge(src proto.Message) + func (m *Channel) XXX_Size() int + func (m *Channel) XXX_Unmarshal(b []byte) error + type ChannelHandlerClient interface + GetAllChannels func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ChannelList, error) + GetChannel func(ctx context.Context, in *ChannelSpecificRequest, opts ...grpc.CallOption) (*Channel, error) + Join func(ctx context.Context, in *JoinRequest, opts ...grpc.CallOption) (*JoinResponse, error) + Leave func(ctx context.Context, in *ChannelSpecificRequest, opts ...grpc.CallOption) (*Empty, error) + func NewChannelHandlerClient(cc *grpc.ClientConn) ChannelHandlerClient + type ChannelHandlerServer interface + GetAllChannels func(context.Context, *Empty) (*ChannelList, error) + GetChannel func(context.Context, *ChannelSpecificRequest) (*Channel, error) + Join func(context.Context, *JoinRequest) (*JoinResponse, error) + Leave func(context.Context, *ChannelSpecificRequest) (*Empty, error) + type ChannelList struct + Channels []*Channel + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ChannelList) Descriptor() ([]byte, []int) + func (*ChannelList) ProtoMessage() + func (m *ChannelList) GetChannels() []*Channel + func (m *ChannelList) Reset() + func (m *ChannelList) String() string + func (m *ChannelList) XXX_DiscardUnknown() + func (m *ChannelList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ChannelList) XXX_Merge(src proto.Message) + func (m *ChannelList) XXX_Size() int + func (m *ChannelList) XXX_Unmarshal(b []byte) error + type ChannelListResponse struct + Channels []*Channel + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ChannelListResponse) Descriptor() ([]byte, []int) + func (*ChannelListResponse) ProtoMessage() + func (m *ChannelListResponse) GetChannels() []*Channel + func (m *ChannelListResponse) Reset() + func (m *ChannelListResponse) String() string + func (m *ChannelListResponse) XXX_DiscardUnknown() + func (m *ChannelListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ChannelListResponse) XXX_Merge(src proto.Message) + func (m *ChannelListResponse) XXX_Size() int + func (m *ChannelListResponse) XXX_Unmarshal(b []byte) error + type ChannelOptions struct + AssetPair string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ChannelOptions) Descriptor() ([]byte, []int) + func (*ChannelOptions) ProtoMessage() + func (m *ChannelOptions) GetAssetPair() string + func (m *ChannelOptions) Reset() + func (m *ChannelOptions) String() string + func (m *ChannelOptions) XXX_DiscardUnknown() + func (m *ChannelOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ChannelOptions) XXX_Merge(src proto.Message) + func (m *ChannelOptions) XXX_Size() int + func (m *ChannelOptions) XXX_Unmarshal(b []byte) error + type ChannelSpecificRequest struct + Id []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ChannelSpecificRequest) Descriptor() ([]byte, []int) + func (*ChannelSpecificRequest) ProtoMessage() + func (m *ChannelSpecificRequest) GetId() []byte + func (m *ChannelSpecificRequest) Reset() + func (m *ChannelSpecificRequest) String() string + func (m *ChannelSpecificRequest) XXX_DiscardUnknown() + func (m *ChannelSpecificRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ChannelSpecificRequest) XXX_Merge(src proto.Message) + func (m *ChannelSpecificRequest) XXX_Size() int + func (m *ChannelSpecificRequest) XXX_Unmarshal(b []byte) error + type CreateRequest struct + Amount uint64 + Asset string + ChannelID []byte + CounterAsset string + Price float32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateRequest) Descriptor() ([]byte, []int) + func (*CreateRequest) ProtoMessage() + func (m *CreateRequest) GetAmount() uint64 + func (m *CreateRequest) GetAsset() string + func (m *CreateRequest) GetChannelID() []byte + func (m *CreateRequest) GetCounterAsset() string + func (m *CreateRequest) GetPrice() float32 + func (m *CreateRequest) Reset() + func (m *CreateRequest) String() string + func (m *CreateRequest) XXX_DiscardUnknown() + func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateRequest) XXX_Merge(src proto.Message) + func (m *CreateRequest) XXX_Size() int + func (m *CreateRequest) XXX_Unmarshal(b []byte) error + type CreateResponse struct + CreatedOrder *Order + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateResponse) Descriptor() ([]byte, []int) + func (*CreateResponse) ProtoMessage() + func (m *CreateResponse) GetCreatedOrder() *Order + func (m *CreateResponse) Reset() + func (m *CreateResponse) String() string + func (m *CreateResponse) XXX_DiscardUnknown() + func (m *CreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateResponse) XXX_Merge(src proto.Message) + func (m *CreateResponse) XXX_Size() int + func (m *CreateResponse) XXX_Unmarshal(b []byte) error + type Empty struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Empty) Descriptor() ([]byte, []int) + func (*Empty) ProtoMessage() + func (m *Empty) Reset() + func (m *Empty) String() string + func (m *Empty) XXX_DiscardUnknown() + func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Empty) XXX_Merge(src proto.Message) + func (m *Empty) XXX_Size() int + func (m *Empty) XXX_Unmarshal(b []byte) error + type JoinRequest struct + Asset string + CounterAsset string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*JoinRequest) Descriptor() ([]byte, []int) + func (*JoinRequest) ProtoMessage() + func (m *JoinRequest) GetAsset() string + func (m *JoinRequest) GetCounterAsset() string + func (m *JoinRequest) Reset() + func (m *JoinRequest) String() string + func (m *JoinRequest) XXX_DiscardUnknown() + func (m *JoinRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *JoinRequest) XXX_Merge(src proto.Message) + func (m *JoinRequest) XXX_Size() int + func (m *JoinRequest) XXX_Unmarshal(b []byte) error + type JoinResponse struct + JoinedChannel *Channel + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*JoinResponse) Descriptor() ([]byte, []int) + func (*JoinResponse) ProtoMessage() + func (m *JoinResponse) GetJoinedChannel() *Channel + func (m *JoinResponse) Reset() + func (m *JoinResponse) String() string + func (m *JoinResponse) XXX_DiscardUnknown() + func (m *JoinResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *JoinResponse) XXX_Merge(src proto.Message) + func (m *JoinResponse) XXX_Size() int + func (m *JoinResponse) XXX_Unmarshal(b []byte) error + type NodeHandlerClient interface + BlacklistPeer func(ctx context.Context, in *Peer, opts ...grpc.CallOption) (*Empty, error) + GetAllPeers func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PeerListResponse, error) + func NewNodeHandlerClient(cc *grpc.ClientConn) NodeHandlerClient + type NodeHandlerServer interface + BlacklistPeer func(context.Context, *Peer) (*Empty, error) + GetAllPeers func(context.Context, *Empty) (*PeerListResponse, error) + type Operation int32 + const Operation_CREATE + const Operation_DELETE + const Operation_LOCK + const Operation_SYNC_RECEIVE + const Operation_SYNC_REQUEST + const Operation_UNLOCK + func (Operation) EnumDescriptor() ([]byte, []int) + func (x Operation) String() string + type Order struct + Amount uint64 + Asset string + CounterAsset string + Created *timestamp.Timestamp + Id []byte + Price float32 + State State + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Order) Descriptor() ([]byte, []int) + func (*Order) ProtoMessage() + func (m *Order) GetAmount() uint64 + func (m *Order) GetAsset() string + func (m *Order) GetCounterAsset() string + func (m *Order) GetCreated() *timestamp.Timestamp + func (m *Order) GetId() []byte + func (m *Order) GetPrice() float32 + func (m *Order) GetState() State + func (m *Order) Reset() + func (m *Order) String() string + func (m *Order) XXX_DiscardUnknown() + func (m *Order) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Order) XXX_Merge(src proto.Message) + func (m *Order) XXX_Size() int + func (m *Order) XXX_Unmarshal(b []byte) error + type OrderHandlerClient interface + Create func(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error) + Delete func(ctx context.Context, in *OrderSpecificRequest, opts ...grpc.CallOption) (*Empty, error) + GetAllOrders func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*OrderList, error) + GetOrder func(ctx context.Context, in *OrderSpecificRequest, opts ...grpc.CallOption) (*Order, error) + Lock func(ctx context.Context, in *OrderSpecificRequest, opts ...grpc.CallOption) (*Empty, error) + Unlock func(ctx context.Context, in *OrderSpecificRequest, opts ...grpc.CallOption) (*Empty, error) + func NewOrderHandlerClient(cc *grpc.ClientConn) OrderHandlerClient + type OrderHandlerServer interface + Create func(context.Context, *CreateRequest) (*CreateResponse, error) + Delete func(context.Context, *OrderSpecificRequest) (*Empty, error) + GetAllOrders func(context.Context, *Empty) (*OrderList, error) + GetOrder func(context.Context, *OrderSpecificRequest) (*Order, error) + Lock func(context.Context, *OrderSpecificRequest) (*Empty, error) + Unlock func(context.Context, *OrderSpecificRequest) (*Empty, error) + type OrderList struct + Orders []*Order + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*OrderList) Descriptor() ([]byte, []int) + func (*OrderList) ProtoMessage() + func (m *OrderList) GetOrders() []*Order + func (m *OrderList) Reset() + func (m *OrderList) String() string + func (m *OrderList) XXX_DiscardUnknown() + func (m *OrderList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *OrderList) XXX_Merge(src proto.Message) + func (m *OrderList) XXX_Size() int + func (m *OrderList) XXX_Unmarshal(b []byte) error + type OrderListResponse struct + Orders []*Order + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*OrderListResponse) Descriptor() ([]byte, []int) + func (*OrderListResponse) ProtoMessage() + func (m *OrderListResponse) GetOrders() []*Order + func (m *OrderListResponse) Reset() + func (m *OrderListResponse) String() string + func (m *OrderListResponse) XXX_DiscardUnknown() + func (m *OrderListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *OrderListResponse) XXX_Merge(src proto.Message) + func (m *OrderListResponse) XXX_Size() int + func (m *OrderListResponse) XXX_Unmarshal(b []byte) error + type OrderSpecificRequest struct + ChannelID []byte + OrderID []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*OrderSpecificRequest) Descriptor() ([]byte, []int) + func (*OrderSpecificRequest) ProtoMessage() + func (m *OrderSpecificRequest) GetChannelID() []byte + func (m *OrderSpecificRequest) GetOrderID() []byte + func (m *OrderSpecificRequest) Reset() + func (m *OrderSpecificRequest) String() string + func (m *OrderSpecificRequest) XXX_DiscardUnknown() + func (m *OrderSpecificRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *OrderSpecificRequest) XXX_Merge(src proto.Message) + func (m *OrderSpecificRequest) XXX_Size() int + func (m *OrderSpecificRequest) XXX_Unmarshal(b []byte) error + type Peer struct + Id string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Peer) Descriptor() ([]byte, []int) + func (*Peer) ProtoMessage() + func (m *Peer) GetId() string + func (m *Peer) Reset() + func (m *Peer) String() string + func (m *Peer) XXX_DiscardUnknown() + func (m *Peer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Peer) XXX_Merge(src proto.Message) + func (m *Peer) XXX_Size() int + func (m *Peer) XXX_Unmarshal(b []byte) error + type PeerListResponse struct + PeerIDs []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PeerListResponse) Descriptor() ([]byte, []int) + func (*PeerListResponse) ProtoMessage() + func (m *PeerListResponse) GetPeerIDs() []string + func (m *PeerListResponse) Reset() + func (m *PeerListResponse) String() string + func (m *PeerListResponse) XXX_DiscardUnknown() + func (m *PeerListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PeerListResponse) XXX_Merge(src proto.Message) + func (m *PeerListResponse) XXX_Size() int + func (m *PeerListResponse) XXX_Unmarshal(b []byte) error + type Recipient struct + PeerID []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Recipient) Descriptor() ([]byte, []int) + func (*Recipient) ProtoMessage() + func (m *Recipient) GetPeerID() []byte + func (m *Recipient) Reset() + func (m *Recipient) String() string + func (m *Recipient) XXX_DiscardUnknown() + func (m *Recipient) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Recipient) XXX_Merge(src proto.Message) + func (m *Recipient) XXX_Size() int + func (m *Recipient) XXX_Unmarshal(b []byte) error + type State int32 + const State_LOCKED + const State_OPEN + func (State) EnumDescriptor() ([]byte, []int) + func (x State) String() string + type UnimplementedChannelHandlerServer struct + func (*UnimplementedChannelHandlerServer) GetAllChannels(ctx context.Context, req *Empty) (*ChannelList, error) + func (*UnimplementedChannelHandlerServer) GetChannel(ctx context.Context, req *ChannelSpecificRequest) (*Channel, error) + func (*UnimplementedChannelHandlerServer) Join(ctx context.Context, req *JoinRequest) (*JoinResponse, error) + func (*UnimplementedChannelHandlerServer) Leave(ctx context.Context, req *ChannelSpecificRequest) (*Empty, error) + type UnimplementedNodeHandlerServer struct + func (*UnimplementedNodeHandlerServer) BlacklistPeer(ctx context.Context, req *Peer) (*Empty, error) + func (*UnimplementedNodeHandlerServer) GetAllPeers(ctx context.Context, req *Empty) (*PeerListResponse, error) + type UnimplementedOrderHandlerServer struct + func (*UnimplementedOrderHandlerServer) Create(ctx context.Context, req *CreateRequest) (*CreateResponse, error) + func (*UnimplementedOrderHandlerServer) Delete(ctx context.Context, req *OrderSpecificRequest) (*Empty, error) + func (*UnimplementedOrderHandlerServer) GetAllOrders(ctx context.Context, req *Empty) (*OrderList, error) + func (*UnimplementedOrderHandlerServer) GetOrder(ctx context.Context, req *OrderSpecificRequest) (*Order, error) + func (*UnimplementedOrderHandlerServer) Lock(ctx context.Context, req *OrderSpecificRequest) (*Empty, error) + func (*UnimplementedOrderHandlerServer) Unlock(ctx context.Context, req *OrderSpecificRequest) (*Empty, error) + type WireMessage struct + ChannelID []byte + Data []byte + Operation Operation + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WireMessage) Descriptor() ([]byte, []int) + func (*WireMessage) ProtoMessage() + func (m *WireMessage) GetChannelID() []byte + func (m *WireMessage) GetData() []byte + func (m *WireMessage) GetOperation() Operation + func (m *WireMessage) Reset() + func (m *WireMessage) String() string + func (m *WireMessage) XXX_DiscardUnknown() + func (m *WireMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WireMessage) XXX_Merge(src proto.Message) + func (m *WireMessage) XXX_Size() int + func (m *WireMessage) XXX_Unmarshal(b []byte) error