Documentation

Index

Constants

This section is empty.

Variables

View Source
var ChannelHandlerClientCommand = &cobra.Command{
	Use: "channelhandler",
}
View Source
var NodeHandlerClientCommand = &cobra.Command{
	Use: "nodehandler",
}
View Source
var Operation_name = map[int32]string{
	0: "CREATE",
	1: "DELETE",
	2: "LOCK",
	3: "UNLOCK",
	4: "SYNC_REQUEST",
	5: "SYNC_RECEIVE",
}
View Source
var Operation_value = map[string]int32{
	"CREATE":       0,
	"DELETE":       1,
	"LOCK":         2,
	"UNLOCK":       3,
	"SYNC_REQUEST": 4,
	"SYNC_RECEIVE": 5,
}
View Source
var OrderHandlerClientCommand = &cobra.Command{
	Use: "orderhandler",
}
View Source
var State_name = map[int32]string{
	0: "OPEN",
	1: "LOCKED",
}
View Source
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) Descriptor() ([]byte, []int)

func (*Channel) GetId

func (m *Channel) GetId() []byte

func (*Channel) GetOptions

func (m *Channel) GetOptions() *ChannelOptions

func (*Channel) ProtoMessage

func (*Channel) ProtoMessage()

func (*Channel) Reset

func (m *Channel) Reset()

func (*Channel) String

func (m *Channel) String() string

func (*Channel) XXX_DiscardUnknown

func (m *Channel) XXX_DiscardUnknown()

func (*Channel) XXX_Marshal

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

func (*Channel) XXX_Merge

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

func (*Channel) XXX_Size

func (m *Channel) XXX_Size() int

func (*Channel) XXX_Unmarshal

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

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

      func (*Empty) ProtoMessage

      func (*Empty) ProtoMessage()

      func (*Empty) Reset

      func (m *Empty) Reset()

      func (*Empty) String

      func (m *Empty) String() string

      func (*Empty) XXX_DiscardUnknown

      func (m *Empty) XXX_DiscardUnknown()

      func (*Empty) XXX_Marshal

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

      func (*Empty) XXX_Merge

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

      func (*Empty) XXX_Size

      func (m *Empty) XXX_Size() int

      func (*Empty) XXX_Unmarshal

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

      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 Operation

          type Operation int32
          const (
          	Operation_CREATE       Operation = 0
          	Operation_DELETE       Operation = 1
          	Operation_LOCK         Operation = 2
          	Operation_UNLOCK       Operation = 3
          	Operation_SYNC_REQUEST Operation = 4
          	Operation_SYNC_RECEIVE Operation = 5
          )

          func (Operation) EnumDescriptor

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

          func (Operation) String

          func (x Operation) String() string

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

          func (*Order) GetAmount

          func (m *Order) GetAmount() uint64

          func (*Order) GetAsset

          func (m *Order) GetAsset() string

          func (*Order) GetCounterAsset

          func (m *Order) GetCounterAsset() string

          func (*Order) GetCreated

          func (m *Order) GetCreated() *timestamp.Timestamp

          func (*Order) GetId

          func (m *Order) GetId() []byte

          func (*Order) GetPrice

          func (m *Order) GetPrice() float32

          func (*Order) GetState

          func (m *Order) GetState() State

          func (*Order) ProtoMessage

          func (*Order) ProtoMessage()

          func (*Order) Reset

          func (m *Order) Reset()

          func (*Order) String

          func (m *Order) String() string

          func (*Order) XXX_DiscardUnknown

          func (m *Order) XXX_DiscardUnknown()

          func (*Order) XXX_Marshal

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

          func (*Order) XXX_Merge

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

          func (*Order) XXX_Size

          func (m *Order) XXX_Size() int

          func (*Order) XXX_Unmarshal

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

          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

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

              func (*OrderList) GetOrders

              func (m *OrderList) GetOrders() []*Order

              func (*OrderList) ProtoMessage

              func (*OrderList) ProtoMessage()

              func (*OrderList) Reset

              func (m *OrderList) Reset()

              func (*OrderList) String

              func (m *OrderList) String() string

              func (*OrderList) XXX_DiscardUnknown

              func (m *OrderList) XXX_DiscardUnknown()

              func (*OrderList) XXX_Marshal

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

              func (*OrderList) XXX_Merge

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

              func (*OrderList) XXX_Size

              func (m *OrderList) XXX_Size() int

              func (*OrderList) XXX_Unmarshal

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

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

              func (*Peer) GetId

              func (m *Peer) GetId() string

              func (*Peer) ProtoMessage

              func (*Peer) ProtoMessage()

              func (*Peer) Reset

              func (m *Peer) Reset()

              func (*Peer) String

              func (m *Peer) String() string

              func (*Peer) XXX_DiscardUnknown

              func (m *Peer) XXX_DiscardUnknown()

              func (*Peer) XXX_Marshal

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

              func (*Peer) XXX_Merge

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

              func (*Peer) XXX_Size

              func (m *Peer) XXX_Size() int

              func (*Peer) XXX_Unmarshal

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

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

              func (*Recipient) GetPeerID

              func (m *Recipient) GetPeerID() []byte

              func (*Recipient) ProtoMessage

              func (*Recipient) ProtoMessage()

              func (*Recipient) Reset

              func (m *Recipient) Reset()

              func (*Recipient) String

              func (m *Recipient) String() string

              func (*Recipient) XXX_DiscardUnknown

              func (m *Recipient) XXX_DiscardUnknown()

              func (*Recipient) XXX_Marshal

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

              func (*Recipient) XXX_Merge

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

              func (*Recipient) XXX_Size

              func (m *Recipient) XXX_Size() int

              func (*Recipient) XXX_Unmarshal

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

              type State

              type State int32
              const (
              	State_OPEN   State = 0
              	State_LOCKED State = 1
              )

              func (State) EnumDescriptor

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

              func (State) String

              func (x State) String() string

              type UnimplementedChannelHandlerServer

              type UnimplementedChannelHandlerServer struct {
              }

                UnimplementedChannelHandlerServer can be embedded to have forward compatible implementations.

                func (*UnimplementedChannelHandlerServer) GetAllChannels

                func (*UnimplementedChannelHandlerServer) GetChannel

                func (*UnimplementedChannelHandlerServer) Join

                func (*UnimplementedChannelHandlerServer) Leave

                type UnimplementedNodeHandlerServer

                type UnimplementedNodeHandlerServer struct {
                }

                  UnimplementedNodeHandlerServer can be embedded to have forward compatible implementations.

                  func (*UnimplementedNodeHandlerServer) BlacklistPeer

                  func (*UnimplementedNodeHandlerServer) BlacklistPeer(ctx context.Context, req *Peer) (*Empty, error)

                  func (*UnimplementedNodeHandlerServer) GetAllPeers

                  type UnimplementedOrderHandlerServer

                  type UnimplementedOrderHandlerServer struct {
                  }

                    UnimplementedOrderHandlerServer can be embedded to have forward compatible implementations.

                    func (*UnimplementedOrderHandlerServer) Create

                    func (*UnimplementedOrderHandlerServer) Delete

                    func (*UnimplementedOrderHandlerServer) GetAllOrders

                    func (*UnimplementedOrderHandlerServer) GetAllOrders(ctx context.Context, req *Empty) (*OrderList, error)

                    func (*UnimplementedOrderHandlerServer) GetOrder

                    func (*UnimplementedOrderHandlerServer) Lock

                    func (*UnimplementedOrderHandlerServer) Unlock

                    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