Documentation ¶
Index ¶
- Variables
- func RegisterChannelHandlerServer(s *grpc.Server, srv ChannelHandlerServer)
- func RegisterNodeHandlerServer(s *grpc.Server, srv NodeHandlerServer)
- func RegisterOrderHandlerServer(s *grpc.Server, srv OrderHandlerServer)
- type Channel
- func (*Channel) Descriptor() ([]byte, []int)
- func (m *Channel) GetId() []byte
- func (m *Channel) GetOptions() *ChannelOptions
- func (*Channel) ProtoMessage()
- 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
- type ChannelHandlerServer
- type ChannelList
- func (*ChannelList) Descriptor() ([]byte, []int)
- func (m *ChannelList) GetChannels() []*Channel
- func (*ChannelList) ProtoMessage()
- 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
- func (*ChannelListResponse) Descriptor() ([]byte, []int)
- func (m *ChannelListResponse) GetChannels() []*Channel
- func (*ChannelListResponse) ProtoMessage()
- 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
- func (*ChannelOptions) Descriptor() ([]byte, []int)
- func (m *ChannelOptions) GetAssetPair() string
- func (*ChannelOptions) ProtoMessage()
- 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
- func (*ChannelSpecificRequest) Descriptor() ([]byte, []int)
- func (m *ChannelSpecificRequest) GetId() []byte
- func (*ChannelSpecificRequest) ProtoMessage()
- 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
- func (*CreateRequest) Descriptor() ([]byte, []int)
- 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 (*CreateRequest) ProtoMessage()
- 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
- func (*CreateResponse) Descriptor() ([]byte, []int)
- func (m *CreateResponse) GetCreatedOrder() *Order
- func (*CreateResponse) ProtoMessage()
- 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
- 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
- func (*JoinRequest) Descriptor() ([]byte, []int)
- func (m *JoinRequest) GetAsset() string
- func (m *JoinRequest) GetCounterAsset() string
- func (*JoinRequest) ProtoMessage()
- 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
- func (*JoinResponse) Descriptor() ([]byte, []int)
- func (m *JoinResponse) GetJoinedChannel() *Channel
- func (*JoinResponse) ProtoMessage()
- 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
- type NodeHandlerServer
- type Operation
- type Order
- func (*Order) Descriptor() ([]byte, []int)
- 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 (*Order) ProtoMessage()
- 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
- type OrderHandlerServer
- type OrderList
- func (*OrderList) Descriptor() ([]byte, []int)
- func (m *OrderList) GetOrders() []*Order
- func (*OrderList) ProtoMessage()
- 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
- func (*OrderListResponse) Descriptor() ([]byte, []int)
- func (m *OrderListResponse) GetOrders() []*Order
- func (*OrderListResponse) ProtoMessage()
- 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
- func (*OrderSpecificRequest) Descriptor() ([]byte, []int)
- func (m *OrderSpecificRequest) GetChannelID() []byte
- func (m *OrderSpecificRequest) GetOrderID() []byte
- func (*OrderSpecificRequest) ProtoMessage()
- 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
- func (*Peer) Descriptor() ([]byte, []int)
- func (m *Peer) GetId() string
- func (*Peer) ProtoMessage()
- 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
- func (*PeerListResponse) Descriptor() ([]byte, []int)
- func (m *PeerListResponse) GetPeerIDs() []string
- func (*PeerListResponse) ProtoMessage()
- 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
- func (*Recipient) Descriptor() ([]byte, []int)
- func (m *Recipient) GetPeerID() []byte
- func (*Recipient) ProtoMessage()
- 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
- type UnimplementedChannelHandlerServer
- 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
- type UnimplementedOrderHandlerServer
- 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
- func (*WireMessage) Descriptor() ([]byte, []int)
- func (m *WireMessage) GetChannelID() []byte
- func (m *WireMessage) GetData() []byte
- func (m *WireMessage) GetOperation() Operation
- func (*WireMessage) ProtoMessage()
- 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
Constants ¶
This section is empty.
Variables ¶
var ChannelHandlerClientCommand = &cobra.Command{
Use: "channelhandler",
}
var NodeHandlerClientCommand = &cobra.Command{
Use: "nodehandler",
}
var Operation_name = map[int32]string{
0: "CREATE",
1: "DELETE",
2: "LOCK",
3: "UNLOCK",
4: "SYNC_REQUEST",
5: "SYNC_RECEIVE",
}
var Operation_value = map[string]int32{
"CREATE": 0,
"DELETE": 1,
"LOCK": 2,
"UNLOCK": 3,
"SYNC_REQUEST": 4,
"SYNC_RECEIVE": 5,
}
var OrderHandlerClientCommand = &cobra.Command{
Use: "orderhandler",
}
var State_name = map[int32]string{
0: "OPEN",
1: "LOCKED",
}
var State_value = map[string]int32{
"OPEN": 0,
"LOCKED": 1,
}
Functions ¶
func RegisterChannelHandlerServer ¶
func RegisterChannelHandlerServer(s *grpc.Server, srv ChannelHandlerServer)
func RegisterNodeHandlerServer ¶
func RegisterNodeHandlerServer(s *grpc.Server, srv NodeHandlerServer)
func RegisterOrderHandlerServer ¶
func RegisterOrderHandlerServer(s *grpc.Server, srv OrderHandlerServer)
Types ¶
type Channel ¶
type Channel struct { Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Options *ChannelOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Channel) Descriptor ¶
func (*Channel) GetOptions ¶
func (m *Channel) GetOptions() *ChannelOptions
func (*Channel) ProtoMessage ¶
func (*Channel) ProtoMessage()
func (*Channel) XXX_DiscardUnknown ¶
func (m *Channel) XXX_DiscardUnknown()
func (*Channel) XXX_Marshal ¶
func (*Channel) XXX_Unmarshal ¶
type ChannelHandlerClient ¶
type ChannelHandlerClient interface { Join(ctx context.Context, in *JoinRequest, opts ...grpc.CallOption) (*JoinResponse, error) Leave(ctx context.Context, in *ChannelSpecificRequest, opts ...grpc.CallOption) (*Empty, error) GetChannel(ctx context.Context, in *ChannelSpecificRequest, opts ...grpc.CallOption) (*Channel, error) GetAllChannels(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ChannelList, error) }
ChannelHandlerClient is the client API for ChannelHandler service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewChannelHandlerClient ¶
func NewChannelHandlerClient(cc *grpc.ClientConn) ChannelHandlerClient
type ChannelHandlerServer ¶
type ChannelHandlerServer interface { Join(context.Context, *JoinRequest) (*JoinResponse, error) Leave(context.Context, *ChannelSpecificRequest) (*Empty, error) GetChannel(context.Context, *ChannelSpecificRequest) (*Channel, error) GetAllChannels(context.Context, *Empty) (*ChannelList, error) }
ChannelHandlerServer is the server API for ChannelHandler service.
type ChannelList ¶
type ChannelList struct { Channels []*Channel `protobuf:"bytes,1,rep,name=channels,proto3" json:"channels,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ChannelList) Descriptor ¶
func (*ChannelList) Descriptor() ([]byte, []int)
func (*ChannelList) GetChannels ¶
func (m *ChannelList) GetChannels() []*Channel
func (*ChannelList) ProtoMessage ¶
func (*ChannelList) ProtoMessage()
func (*ChannelList) Reset ¶
func (m *ChannelList) Reset()
func (*ChannelList) String ¶
func (m *ChannelList) String() string
func (*ChannelList) XXX_DiscardUnknown ¶
func (m *ChannelList) XXX_DiscardUnknown()
func (*ChannelList) XXX_Marshal ¶
func (m *ChannelList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChannelList) XXX_Merge ¶
func (m *ChannelList) XXX_Merge(src proto.Message)
func (*ChannelList) XXX_Size ¶
func (m *ChannelList) XXX_Size() int
func (*ChannelList) XXX_Unmarshal ¶
func (m *ChannelList) XXX_Unmarshal(b []byte) error
type ChannelListResponse ¶
type ChannelListResponse struct { Channels []*Channel `protobuf:"bytes,1,rep,name=channels,proto3" json:"channels,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ChannelListResponse) Descriptor ¶
func (*ChannelListResponse) Descriptor() ([]byte, []int)
func (*ChannelListResponse) GetChannels ¶
func (m *ChannelListResponse) GetChannels() []*Channel
func (*ChannelListResponse) ProtoMessage ¶
func (*ChannelListResponse) ProtoMessage()
func (*ChannelListResponse) Reset ¶
func (m *ChannelListResponse) Reset()
func (*ChannelListResponse) String ¶
func (m *ChannelListResponse) String() string
func (*ChannelListResponse) XXX_DiscardUnknown ¶
func (m *ChannelListResponse) XXX_DiscardUnknown()
func (*ChannelListResponse) XXX_Marshal ¶
func (m *ChannelListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChannelListResponse) XXX_Merge ¶
func (m *ChannelListResponse) XXX_Merge(src proto.Message)
func (*ChannelListResponse) XXX_Size ¶
func (m *ChannelListResponse) XXX_Size() int
func (*ChannelListResponse) XXX_Unmarshal ¶
func (m *ChannelListResponse) XXX_Unmarshal(b []byte) error
type ChannelOptions ¶
type ChannelOptions struct { AssetPair string `protobuf:"bytes,1,opt,name=assetPair,proto3" json:"assetPair,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ChannelOptions) Descriptor ¶
func (*ChannelOptions) Descriptor() ([]byte, []int)
func (*ChannelOptions) GetAssetPair ¶
func (m *ChannelOptions) GetAssetPair() string
func (*ChannelOptions) ProtoMessage ¶
func (*ChannelOptions) ProtoMessage()
func (*ChannelOptions) Reset ¶
func (m *ChannelOptions) Reset()
func (*ChannelOptions) String ¶
func (m *ChannelOptions) String() string
func (*ChannelOptions) XXX_DiscardUnknown ¶
func (m *ChannelOptions) XXX_DiscardUnknown()
func (*ChannelOptions) XXX_Marshal ¶
func (m *ChannelOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChannelOptions) XXX_Merge ¶
func (m *ChannelOptions) XXX_Merge(src proto.Message)
func (*ChannelOptions) XXX_Size ¶
func (m *ChannelOptions) XXX_Size() int
func (*ChannelOptions) XXX_Unmarshal ¶
func (m *ChannelOptions) XXX_Unmarshal(b []byte) error
type ChannelSpecificRequest ¶
type ChannelSpecificRequest struct { Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ChannelSpecificRequest) Descriptor ¶
func (*ChannelSpecificRequest) Descriptor() ([]byte, []int)
func (*ChannelSpecificRequest) GetId ¶
func (m *ChannelSpecificRequest) GetId() []byte
func (*ChannelSpecificRequest) ProtoMessage ¶
func (*ChannelSpecificRequest) ProtoMessage()
func (*ChannelSpecificRequest) Reset ¶
func (m *ChannelSpecificRequest) Reset()
func (*ChannelSpecificRequest) String ¶
func (m *ChannelSpecificRequest) String() string
func (*ChannelSpecificRequest) XXX_DiscardUnknown ¶
func (m *ChannelSpecificRequest) XXX_DiscardUnknown()
func (*ChannelSpecificRequest) XXX_Marshal ¶
func (m *ChannelSpecificRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChannelSpecificRequest) XXX_Merge ¶
func (m *ChannelSpecificRequest) XXX_Merge(src proto.Message)
func (*ChannelSpecificRequest) XXX_Size ¶
func (m *ChannelSpecificRequest) XXX_Size() int
func (*ChannelSpecificRequest) XXX_Unmarshal ¶
func (m *ChannelSpecificRequest) XXX_Unmarshal(b []byte) error
type CreateRequest ¶
type CreateRequest struct { ChannelID []byte `protobuf:"bytes,1,opt,name=channelID,proto3" json:"channelID,omitempty"` Asset string `protobuf:"bytes,2,opt,name=asset,proto3" json:"asset,omitempty"` CounterAsset string `protobuf:"bytes,3,opt,name=counterAsset,proto3" json:"counterAsset,omitempty"` Amount uint64 `protobuf:"varint,4,opt,name=amount,proto3" json:"amount,omitempty"` Price float32 `protobuf:"fixed32,5,opt,name=price,proto3" json:"price,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateRequest) Descriptor ¶
func (*CreateRequest) Descriptor() ([]byte, []int)
func (*CreateRequest) GetAmount ¶
func (m *CreateRequest) GetAmount() uint64
func (*CreateRequest) GetAsset ¶
func (m *CreateRequest) GetAsset() string
func (*CreateRequest) GetChannelID ¶
func (m *CreateRequest) GetChannelID() []byte
func (*CreateRequest) GetCounterAsset ¶
func (m *CreateRequest) GetCounterAsset() string
func (*CreateRequest) GetPrice ¶
func (m *CreateRequest) GetPrice() float32
func (*CreateRequest) ProtoMessage ¶
func (*CreateRequest) ProtoMessage()
func (*CreateRequest) Reset ¶
func (m *CreateRequest) Reset()
func (*CreateRequest) String ¶
func (m *CreateRequest) String() string
func (*CreateRequest) XXX_DiscardUnknown ¶
func (m *CreateRequest) XXX_DiscardUnknown()
func (*CreateRequest) XXX_Marshal ¶
func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateRequest) XXX_Merge ¶
func (m *CreateRequest) XXX_Merge(src proto.Message)
func (*CreateRequest) XXX_Size ¶
func (m *CreateRequest) XXX_Size() int
func (*CreateRequest) XXX_Unmarshal ¶
func (m *CreateRequest) XXX_Unmarshal(b []byte) error
type CreateResponse ¶
type CreateResponse struct { CreatedOrder *Order `protobuf:"bytes,1,opt,name=createdOrder,proto3" json:"createdOrder,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateResponse) Descriptor ¶
func (*CreateResponse) Descriptor() ([]byte, []int)
func (*CreateResponse) GetCreatedOrder ¶
func (m *CreateResponse) GetCreatedOrder() *Order
func (*CreateResponse) ProtoMessage ¶
func (*CreateResponse) ProtoMessage()
func (*CreateResponse) Reset ¶
func (m *CreateResponse) Reset()
func (*CreateResponse) String ¶
func (m *CreateResponse) String() string
func (*CreateResponse) XXX_DiscardUnknown ¶
func (m *CreateResponse) XXX_DiscardUnknown()
func (*CreateResponse) XXX_Marshal ¶
func (m *CreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateResponse) XXX_Merge ¶
func (m *CreateResponse) XXX_Merge(src proto.Message)
func (*CreateResponse) XXX_Size ¶
func (m *CreateResponse) XXX_Size() int
func (*CreateResponse) XXX_Unmarshal ¶
func (m *CreateResponse) XXX_Unmarshal(b []byte) error
type Empty ¶
type Empty struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Empty) Descriptor ¶
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) XXX_DiscardUnknown ¶
func (m *Empty) XXX_DiscardUnknown()
func (*Empty) XXX_Marshal ¶
func (*Empty) XXX_Unmarshal ¶
type JoinRequest ¶
type JoinRequest struct { Asset string `protobuf:"bytes,1,opt,name=asset,proto3" json:"asset,omitempty"` CounterAsset string `protobuf:"bytes,2,opt,name=counterAsset,proto3" json:"counterAsset,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*JoinRequest) Descriptor ¶
func (*JoinRequest) Descriptor() ([]byte, []int)
func (*JoinRequest) GetAsset ¶
func (m *JoinRequest) GetAsset() string
func (*JoinRequest) GetCounterAsset ¶
func (m *JoinRequest) GetCounterAsset() string
func (*JoinRequest) ProtoMessage ¶
func (*JoinRequest) ProtoMessage()
func (*JoinRequest) Reset ¶
func (m *JoinRequest) Reset()
func (*JoinRequest) String ¶
func (m *JoinRequest) String() string
func (*JoinRequest) XXX_DiscardUnknown ¶
func (m *JoinRequest) XXX_DiscardUnknown()
func (*JoinRequest) XXX_Marshal ¶
func (m *JoinRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JoinRequest) XXX_Merge ¶
func (m *JoinRequest) XXX_Merge(src proto.Message)
func (*JoinRequest) XXX_Size ¶
func (m *JoinRequest) XXX_Size() int
func (*JoinRequest) XXX_Unmarshal ¶
func (m *JoinRequest) XXX_Unmarshal(b []byte) error
type JoinResponse ¶
type JoinResponse struct { JoinedChannel *Channel `protobuf:"bytes,1,opt,name=joinedChannel,proto3" json:"joinedChannel,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*JoinResponse) Descriptor ¶
func (*JoinResponse) Descriptor() ([]byte, []int)
func (*JoinResponse) GetJoinedChannel ¶
func (m *JoinResponse) GetJoinedChannel() *Channel
func (*JoinResponse) ProtoMessage ¶
func (*JoinResponse) ProtoMessage()
func (*JoinResponse) Reset ¶
func (m *JoinResponse) Reset()
func (*JoinResponse) String ¶
func (m *JoinResponse) String() string
func (*JoinResponse) XXX_DiscardUnknown ¶
func (m *JoinResponse) XXX_DiscardUnknown()
func (*JoinResponse) XXX_Marshal ¶
func (m *JoinResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*JoinResponse) XXX_Merge ¶
func (m *JoinResponse) XXX_Merge(src proto.Message)
func (*JoinResponse) XXX_Size ¶
func (m *JoinResponse) XXX_Size() int
func (*JoinResponse) XXX_Unmarshal ¶
func (m *JoinResponse) XXX_Unmarshal(b []byte) error
type NodeHandlerClient ¶
type NodeHandlerClient interface { GetAllPeers(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PeerListResponse, error) BlacklistPeer(ctx context.Context, in *Peer, opts ...grpc.CallOption) (*Empty, error) }
NodeHandlerClient is the client API for NodeHandler service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewNodeHandlerClient ¶
func NewNodeHandlerClient(cc *grpc.ClientConn) NodeHandlerClient
type NodeHandlerServer ¶
type NodeHandlerServer interface { GetAllPeers(context.Context, *Empty) (*PeerListResponse, error) BlacklistPeer(context.Context, *Peer) (*Empty, error) }
NodeHandlerServer is the server API for NodeHandler service.
type Order ¶
type Order struct { Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Created *timestamp.Timestamp `protobuf:"bytes,2,opt,name=created,proto3" json:"created,omitempty"` Asset string `protobuf:"bytes,3,opt,name=asset,proto3" json:"asset,omitempty"` CounterAsset string `protobuf:"bytes,4,opt,name=counterAsset,proto3" json:"counterAsset,omitempty"` Amount uint64 `protobuf:"varint,5,opt,name=amount,proto3" json:"amount,omitempty"` Price float32 `protobuf:"fixed32,6,opt,name=price,proto3" json:"price,omitempty"` State State `protobuf:"varint,7,opt,name=state,proto3,enum=pb.State" json:"state,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Order) Descriptor ¶
func (*Order) GetCounterAsset ¶
func (*Order) GetCreated ¶
func (*Order) ProtoMessage ¶
func (*Order) ProtoMessage()
func (*Order) XXX_DiscardUnknown ¶
func (m *Order) XXX_DiscardUnknown()
func (*Order) XXX_Marshal ¶
func (*Order) XXX_Unmarshal ¶
type OrderHandlerClient ¶
type OrderHandlerClient interface { Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error) Delete(ctx context.Context, in *OrderSpecificRequest, opts ...grpc.CallOption) (*Empty, error) Lock(ctx context.Context, in *OrderSpecificRequest, opts ...grpc.CallOption) (*Empty, error) Unlock(ctx context.Context, in *OrderSpecificRequest, opts ...grpc.CallOption) (*Empty, error) GetOrder(ctx context.Context, in *OrderSpecificRequest, opts ...grpc.CallOption) (*Order, error) GetAllOrders(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*OrderList, error) }
OrderHandlerClient is the client API for OrderHandler service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewOrderHandlerClient ¶
func NewOrderHandlerClient(cc *grpc.ClientConn) OrderHandlerClient
type OrderHandlerServer ¶
type OrderHandlerServer interface { Create(context.Context, *CreateRequest) (*CreateResponse, error) Delete(context.Context, *OrderSpecificRequest) (*Empty, error) Lock(context.Context, *OrderSpecificRequest) (*Empty, error) Unlock(context.Context, *OrderSpecificRequest) (*Empty, error) GetOrder(context.Context, *OrderSpecificRequest) (*Order, error) GetAllOrders(context.Context, *Empty) (*OrderList, error) }
OrderHandlerServer is the server API for OrderHandler service.
type OrderList ¶
type OrderList struct { Orders []*Order `protobuf:"bytes,1,rep,name=orders,proto3" json:"orders,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*OrderList) Descriptor ¶
func (*OrderList) ProtoMessage ¶
func (*OrderList) ProtoMessage()
func (*OrderList) XXX_DiscardUnknown ¶
func (m *OrderList) XXX_DiscardUnknown()
func (*OrderList) XXX_Marshal ¶
func (*OrderList) XXX_Unmarshal ¶
type OrderListResponse ¶
type OrderListResponse struct { Orders []*Order `protobuf:"bytes,1,rep,name=orders,proto3" json:"orders,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*OrderListResponse) Descriptor ¶
func (*OrderListResponse) Descriptor() ([]byte, []int)
func (*OrderListResponse) GetOrders ¶
func (m *OrderListResponse) GetOrders() []*Order
func (*OrderListResponse) ProtoMessage ¶
func (*OrderListResponse) ProtoMessage()
func (*OrderListResponse) Reset ¶
func (m *OrderListResponse) Reset()
func (*OrderListResponse) String ¶
func (m *OrderListResponse) String() string
func (*OrderListResponse) XXX_DiscardUnknown ¶
func (m *OrderListResponse) XXX_DiscardUnknown()
func (*OrderListResponse) XXX_Marshal ¶
func (m *OrderListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OrderListResponse) XXX_Merge ¶
func (m *OrderListResponse) XXX_Merge(src proto.Message)
func (*OrderListResponse) XXX_Size ¶
func (m *OrderListResponse) XXX_Size() int
func (*OrderListResponse) XXX_Unmarshal ¶
func (m *OrderListResponse) XXX_Unmarshal(b []byte) error
type OrderSpecificRequest ¶
type OrderSpecificRequest struct { OrderID []byte `protobuf:"bytes,1,opt,name=orderID,proto3" json:"orderID,omitempty"` ChannelID []byte `protobuf:"bytes,2,opt,name=channelID,proto3" json:"channelID,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*OrderSpecificRequest) Descriptor ¶
func (*OrderSpecificRequest) Descriptor() ([]byte, []int)
func (*OrderSpecificRequest) GetChannelID ¶
func (m *OrderSpecificRequest) GetChannelID() []byte
func (*OrderSpecificRequest) GetOrderID ¶
func (m *OrderSpecificRequest) GetOrderID() []byte
func (*OrderSpecificRequest) ProtoMessage ¶
func (*OrderSpecificRequest) ProtoMessage()
func (*OrderSpecificRequest) Reset ¶
func (m *OrderSpecificRequest) Reset()
func (*OrderSpecificRequest) String ¶
func (m *OrderSpecificRequest) String() string
func (*OrderSpecificRequest) XXX_DiscardUnknown ¶
func (m *OrderSpecificRequest) XXX_DiscardUnknown()
func (*OrderSpecificRequest) XXX_Marshal ¶
func (m *OrderSpecificRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OrderSpecificRequest) XXX_Merge ¶
func (m *OrderSpecificRequest) XXX_Merge(src proto.Message)
func (*OrderSpecificRequest) XXX_Size ¶
func (m *OrderSpecificRequest) XXX_Size() int
func (*OrderSpecificRequest) XXX_Unmarshal ¶
func (m *OrderSpecificRequest) XXX_Unmarshal(b []byte) error
type Peer ¶
type Peer struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Peer) Descriptor ¶
func (*Peer) ProtoMessage ¶
func (*Peer) ProtoMessage()
func (*Peer) XXX_DiscardUnknown ¶
func (m *Peer) XXX_DiscardUnknown()
func (*Peer) XXX_Unmarshal ¶
type PeerListResponse ¶
type PeerListResponse struct { PeerIDs []string `protobuf:"bytes,1,rep,name=peerIDs,proto3" json:"peerIDs,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PeerListResponse) Descriptor ¶
func (*PeerListResponse) Descriptor() ([]byte, []int)
func (*PeerListResponse) GetPeerIDs ¶
func (m *PeerListResponse) GetPeerIDs() []string
func (*PeerListResponse) ProtoMessage ¶
func (*PeerListResponse) ProtoMessage()
func (*PeerListResponse) Reset ¶
func (m *PeerListResponse) Reset()
func (*PeerListResponse) String ¶
func (m *PeerListResponse) String() string
func (*PeerListResponse) XXX_DiscardUnknown ¶
func (m *PeerListResponse) XXX_DiscardUnknown()
func (*PeerListResponse) XXX_Marshal ¶
func (m *PeerListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PeerListResponse) XXX_Merge ¶
func (m *PeerListResponse) XXX_Merge(src proto.Message)
func (*PeerListResponse) XXX_Size ¶
func (m *PeerListResponse) XXX_Size() int
func (*PeerListResponse) XXX_Unmarshal ¶
func (m *PeerListResponse) XXX_Unmarshal(b []byte) error
type Recipient ¶
type Recipient struct { PeerID []byte `protobuf:"bytes,1,opt,name=peerID,proto3" json:"peerID,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Recipient) Descriptor ¶
func (*Recipient) ProtoMessage ¶
func (*Recipient) ProtoMessage()
func (*Recipient) XXX_DiscardUnknown ¶
func (m *Recipient) XXX_DiscardUnknown()
func (*Recipient) XXX_Marshal ¶
func (*Recipient) XXX_Unmarshal ¶
type UnimplementedChannelHandlerServer ¶
type UnimplementedChannelHandlerServer struct { }
UnimplementedChannelHandlerServer can be embedded to have forward compatible implementations.
func (*UnimplementedChannelHandlerServer) GetAllChannels ¶
func (*UnimplementedChannelHandlerServer) GetAllChannels(ctx context.Context, req *Empty) (*ChannelList, error)
func (*UnimplementedChannelHandlerServer) GetChannel ¶
func (*UnimplementedChannelHandlerServer) GetChannel(ctx context.Context, req *ChannelSpecificRequest) (*Channel, error)
func (*UnimplementedChannelHandlerServer) Join ¶
func (*UnimplementedChannelHandlerServer) Join(ctx context.Context, req *JoinRequest) (*JoinResponse, error)
func (*UnimplementedChannelHandlerServer) Leave ¶
func (*UnimplementedChannelHandlerServer) Leave(ctx context.Context, req *ChannelSpecificRequest) (*Empty, error)
type UnimplementedNodeHandlerServer ¶
type UnimplementedNodeHandlerServer struct { }
UnimplementedNodeHandlerServer can be embedded to have forward compatible implementations.
func (*UnimplementedNodeHandlerServer) BlacklistPeer ¶
func (*UnimplementedNodeHandlerServer) GetAllPeers ¶
func (*UnimplementedNodeHandlerServer) GetAllPeers(ctx context.Context, req *Empty) (*PeerListResponse, error)
type UnimplementedOrderHandlerServer ¶
type UnimplementedOrderHandlerServer struct { }
UnimplementedOrderHandlerServer can be embedded to have forward compatible implementations.
func (*UnimplementedOrderHandlerServer) Create ¶
func (*UnimplementedOrderHandlerServer) Create(ctx context.Context, req *CreateRequest) (*CreateResponse, error)
func (*UnimplementedOrderHandlerServer) Delete ¶
func (*UnimplementedOrderHandlerServer) Delete(ctx context.Context, req *OrderSpecificRequest) (*Empty, error)
func (*UnimplementedOrderHandlerServer) GetAllOrders ¶
func (*UnimplementedOrderHandlerServer) GetOrder ¶
func (*UnimplementedOrderHandlerServer) GetOrder(ctx context.Context, req *OrderSpecificRequest) (*Order, error)
func (*UnimplementedOrderHandlerServer) Lock ¶
func (*UnimplementedOrderHandlerServer) Lock(ctx context.Context, req *OrderSpecificRequest) (*Empty, error)
func (*UnimplementedOrderHandlerServer) Unlock ¶
func (*UnimplementedOrderHandlerServer) Unlock(ctx context.Context, req *OrderSpecificRequest) (*Empty, error)
type WireMessage ¶
type WireMessage struct { ChannelID []byte `protobuf:"bytes,1,opt,name=channelID,proto3" json:"channelID,omitempty"` Operation Operation `protobuf:"varint,2,opt,name=operation,proto3,enum=pb.Operation" json:"operation,omitempty"` Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*WireMessage) Descriptor ¶
func (*WireMessage) Descriptor() ([]byte, []int)
func (*WireMessage) GetChannelID ¶
func (m *WireMessage) GetChannelID() []byte
func (*WireMessage) GetData ¶
func (m *WireMessage) GetData() []byte
func (*WireMessage) GetOperation ¶
func (m *WireMessage) GetOperation() Operation
func (*WireMessage) ProtoMessage ¶
func (*WireMessage) ProtoMessage()
func (*WireMessage) Reset ¶
func (m *WireMessage) Reset()
func (*WireMessage) String ¶
func (m *WireMessage) String() string
func (*WireMessage) XXX_DiscardUnknown ¶
func (m *WireMessage) XXX_DiscardUnknown()
func (*WireMessage) XXX_Marshal ¶
func (m *WireMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WireMessage) XXX_Merge ¶
func (m *WireMessage) XXX_Merge(src proto.Message)
func (*WireMessage) XXX_Size ¶
func (m *WireMessage) XXX_Size() int
func (*WireMessage) XXX_Unmarshal ¶
func (m *WireMessage) XXX_Unmarshal(b []byte) error