Back to godoc.org

Package pb

v0.0.4
Latest Go to latest

The latest major version is .

Published: Feb 7, 2020 | License: MIT | Module: github.com/sprawl/sprawl

Index

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

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)

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

Package Files

Documentation was rendered with GOOS=linux and GOARCH=amd64.

Jump to identifier

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to identifier