pb

package
v0.0.4 Latest Latest
Warning

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

 Go to latest Published: Feb 7, 2020 License: MIT Imports: 27 Imported by: 0

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 

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) 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) 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) BlacklistPeer(ctx context.Context, req *Peer) (*Empty, error)

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) GetAllOrders(ctx context.Context, req *Empty) (*OrderList, error)

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

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.