sprawl: github.com/sprawl/sprawl/pb Index | Files

package pb

import "github.com/sprawl/sprawl/pb"

Index

Package Files

sprawl.cobra.pb.go sprawl.pb.go

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 Uses

func RegisterChannelHandlerServer(s *grpc.Server, srv ChannelHandlerServer)

func RegisterNodeHandlerServer Uses

func RegisterNodeHandlerServer(s *grpc.Server, srv NodeHandlerServer)

func RegisterOrderHandlerServer Uses

func RegisterOrderHandlerServer(s *grpc.Server, srv OrderHandlerServer)

type Channel Uses

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 Uses

func (*Channel) Descriptor() ([]byte, []int)

func (*Channel) GetId Uses

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

func (*Channel) GetOptions Uses

func (m *Channel) GetOptions() *ChannelOptions

func (*Channel) ProtoMessage Uses

func (*Channel) ProtoMessage()

func (*Channel) Reset Uses

func (m *Channel) Reset()

func (*Channel) String Uses

func (m *Channel) String() string

func (*Channel) XXX_DiscardUnknown Uses

func (m *Channel) XXX_DiscardUnknown()

func (*Channel) XXX_Marshal Uses

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

func (*Channel) XXX_Merge Uses

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

func (*Channel) XXX_Size Uses

func (m *Channel) XXX_Size() int

func (*Channel) XXX_Unmarshal Uses

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

type ChannelHandlerClient Uses

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 Uses

func NewChannelHandlerClient(cc *grpc.ClientConn) ChannelHandlerClient

type ChannelHandlerServer Uses

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 Uses

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 Uses

func (*ChannelList) Descriptor() ([]byte, []int)

func (*ChannelList) GetChannels Uses

func (m *ChannelList) GetChannels() []*Channel

func (*ChannelList) ProtoMessage Uses

func (*ChannelList) ProtoMessage()

func (*ChannelList) Reset Uses

func (m *ChannelList) Reset()

func (*ChannelList) String Uses

func (m *ChannelList) String() string

func (*ChannelList) XXX_DiscardUnknown Uses

func (m *ChannelList) XXX_DiscardUnknown()

func (*ChannelList) XXX_Marshal Uses

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

func (*ChannelList) XXX_Merge Uses

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

func (*ChannelList) XXX_Size Uses

func (m *ChannelList) XXX_Size() int

func (*ChannelList) XXX_Unmarshal Uses

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

type ChannelListResponse Uses

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 Uses

func (*ChannelListResponse) Descriptor() ([]byte, []int)

func (*ChannelListResponse) GetChannels Uses

func (m *ChannelListResponse) GetChannels() []*Channel

func (*ChannelListResponse) ProtoMessage Uses

func (*ChannelListResponse) ProtoMessage()

func (*ChannelListResponse) Reset Uses

func (m *ChannelListResponse) Reset()

func (*ChannelListResponse) String Uses

func (m *ChannelListResponse) String() string

func (*ChannelListResponse) XXX_DiscardUnknown Uses

func (m *ChannelListResponse) XXX_DiscardUnknown()

func (*ChannelListResponse) XXX_Marshal Uses

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

func (*ChannelListResponse) XXX_Merge Uses

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

func (*ChannelListResponse) XXX_Size Uses

func (m *ChannelListResponse) XXX_Size() int

func (*ChannelListResponse) XXX_Unmarshal Uses

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

type ChannelOptions Uses

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 Uses

func (*ChannelOptions) Descriptor() ([]byte, []int)

func (*ChannelOptions) GetAssetPair Uses

func (m *ChannelOptions) GetAssetPair() string

func (*ChannelOptions) ProtoMessage Uses

func (*ChannelOptions) ProtoMessage()

func (*ChannelOptions) Reset Uses

func (m *ChannelOptions) Reset()

func (*ChannelOptions) String Uses

func (m *ChannelOptions) String() string

func (*ChannelOptions) XXX_DiscardUnknown Uses

func (m *ChannelOptions) XXX_DiscardUnknown()

func (*ChannelOptions) XXX_Marshal Uses

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

func (*ChannelOptions) XXX_Merge Uses

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

func (*ChannelOptions) XXX_Size Uses

func (m *ChannelOptions) XXX_Size() int

func (*ChannelOptions) XXX_Unmarshal Uses

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

type ChannelSpecificRequest Uses

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 Uses

func (*ChannelSpecificRequest) Descriptor() ([]byte, []int)

func (*ChannelSpecificRequest) GetId Uses

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

func (*ChannelSpecificRequest) ProtoMessage Uses

func (*ChannelSpecificRequest) ProtoMessage()

func (*ChannelSpecificRequest) Reset Uses

func (m *ChannelSpecificRequest) Reset()

func (*ChannelSpecificRequest) String Uses

func (m *ChannelSpecificRequest) String() string

func (*ChannelSpecificRequest) XXX_DiscardUnknown Uses

func (m *ChannelSpecificRequest) XXX_DiscardUnknown()

func (*ChannelSpecificRequest) XXX_Marshal Uses

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

func (*ChannelSpecificRequest) XXX_Merge Uses

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

func (*ChannelSpecificRequest) XXX_Size Uses

func (m *ChannelSpecificRequest) XXX_Size() int

func (*ChannelSpecificRequest) XXX_Unmarshal Uses

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

type CreateRequest Uses

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 Uses

func (*CreateRequest) Descriptor() ([]byte, []int)

func (*CreateRequest) GetAmount Uses

func (m *CreateRequest) GetAmount() uint64

func (*CreateRequest) GetAsset Uses

func (m *CreateRequest) GetAsset() string

func (*CreateRequest) GetChannelID Uses

func (m *CreateRequest) GetChannelID() []byte

func (*CreateRequest) GetCounterAsset Uses

func (m *CreateRequest) GetCounterAsset() string

func (*CreateRequest) GetPrice Uses

func (m *CreateRequest) GetPrice() float32

func (*CreateRequest) ProtoMessage Uses

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) Reset Uses

func (m *CreateRequest) Reset()

func (*CreateRequest) String Uses

func (m *CreateRequest) String() string

func (*CreateRequest) XXX_DiscardUnknown Uses

func (m *CreateRequest) XXX_DiscardUnknown()

func (*CreateRequest) XXX_Marshal Uses

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

func (*CreateRequest) XXX_Merge Uses

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

func (*CreateRequest) XXX_Size Uses

func (m *CreateRequest) XXX_Size() int

func (*CreateRequest) XXX_Unmarshal Uses

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

type CreateResponse Uses

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 Uses

func (*CreateResponse) Descriptor() ([]byte, []int)

func (*CreateResponse) GetCreatedOrder Uses

func (m *CreateResponse) GetCreatedOrder() *Order

func (*CreateResponse) ProtoMessage Uses

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) Reset Uses

func (m *CreateResponse) Reset()

func (*CreateResponse) String Uses

func (m *CreateResponse) String() string

func (*CreateResponse) XXX_DiscardUnknown Uses

func (m *CreateResponse) XXX_DiscardUnknown()

func (*CreateResponse) XXX_Marshal Uses

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

func (*CreateResponse) XXX_Merge Uses

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

func (*CreateResponse) XXX_Size Uses

func (m *CreateResponse) XXX_Size() int

func (*CreateResponse) XXX_Unmarshal Uses

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

type Empty Uses

type Empty struct {
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*Empty) Descriptor Uses

func (*Empty) Descriptor() ([]byte, []int)

func (*Empty) ProtoMessage Uses

func (*Empty) ProtoMessage()

func (*Empty) Reset Uses

func (m *Empty) Reset()

func (*Empty) String Uses

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown Uses

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal Uses

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

func (*Empty) XXX_Merge Uses

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

func (*Empty) XXX_Size Uses

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal Uses

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

type JoinRequest Uses

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 Uses

func (*JoinRequest) Descriptor() ([]byte, []int)

func (*JoinRequest) GetAsset Uses

func (m *JoinRequest) GetAsset() string

func (*JoinRequest) GetCounterAsset Uses

func (m *JoinRequest) GetCounterAsset() string

func (*JoinRequest) ProtoMessage Uses

func (*JoinRequest) ProtoMessage()

func (*JoinRequest) Reset Uses

func (m *JoinRequest) Reset()

func (*JoinRequest) String Uses

func (m *JoinRequest) String() string

func (*JoinRequest) XXX_DiscardUnknown Uses

func (m *JoinRequest) XXX_DiscardUnknown()

func (*JoinRequest) XXX_Marshal Uses

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

func (*JoinRequest) XXX_Merge Uses

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

func (*JoinRequest) XXX_Size Uses

func (m *JoinRequest) XXX_Size() int

func (*JoinRequest) XXX_Unmarshal Uses

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

type JoinResponse Uses

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 Uses

func (*JoinResponse) Descriptor() ([]byte, []int)

func (*JoinResponse) GetJoinedChannel Uses

func (m *JoinResponse) GetJoinedChannel() *Channel

func (*JoinResponse) ProtoMessage Uses

func (*JoinResponse) ProtoMessage()

func (*JoinResponse) Reset Uses

func (m *JoinResponse) Reset()

func (*JoinResponse) String Uses

func (m *JoinResponse) String() string

func (*JoinResponse) XXX_DiscardUnknown Uses

func (m *JoinResponse) XXX_DiscardUnknown()

func (*JoinResponse) XXX_Marshal Uses

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

func (*JoinResponse) XXX_Merge Uses

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

func (*JoinResponse) XXX_Size Uses

func (m *JoinResponse) XXX_Size() int

func (*JoinResponse) XXX_Unmarshal Uses

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

type NodeHandlerClient Uses

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 Uses

func NewNodeHandlerClient(cc *grpc.ClientConn) NodeHandlerClient

type NodeHandlerServer Uses

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 Uses

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 Uses

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

func (Operation) String Uses

func (x Operation) String() string

type Order Uses

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"`
    Signature            []byte               `protobuf:"bytes,8,opt,name=signature,proto3" json:"signature,omitempty"`
    Nonce                uint32               `protobuf:"varint,9,opt,name=nonce,proto3" json:"nonce,omitempty"`
    Metadata             []byte               `protobuf:"bytes,10,opt,name=metadata,proto3" json:"metadata,omitempty"`
    XXX_NoUnkeyedLiteral struct{}             `json:"-"`
    XXX_unrecognized     []byte               `json:"-"`
    XXX_sizecache        int32                `json:"-"`
}

func (*Order) Descriptor Uses

func (*Order) Descriptor() ([]byte, []int)

func (*Order) GetAmount Uses

func (m *Order) GetAmount() uint64

func (*Order) GetAsset Uses

func (m *Order) GetAsset() string

func (*Order) GetCounterAsset Uses

func (m *Order) GetCounterAsset() string

func (*Order) GetCreated Uses

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

func (*Order) GetId Uses

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

func (*Order) GetMetadata Uses

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

func (*Order) GetNonce Uses

func (m *Order) GetNonce() uint32

func (*Order) GetPrice Uses

func (m *Order) GetPrice() float32

func (*Order) GetSignature Uses

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

func (*Order) GetState Uses

func (m *Order) GetState() State

func (*Order) ProtoMessage Uses

func (*Order) ProtoMessage()

func (*Order) Reset Uses

func (m *Order) Reset()

func (*Order) String Uses

func (m *Order) String() string

func (*Order) XXX_DiscardUnknown Uses

func (m *Order) XXX_DiscardUnknown()

func (*Order) XXX_Marshal Uses

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

func (*Order) XXX_Merge Uses

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

func (*Order) XXX_Size Uses

func (m *Order) XXX_Size() int

func (*Order) XXX_Unmarshal Uses

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

type OrderHandlerClient Uses

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 Uses

func NewOrderHandlerClient(cc *grpc.ClientConn) OrderHandlerClient

type OrderHandlerServer Uses

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 Uses

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 Uses

func (*OrderList) Descriptor() ([]byte, []int)

func (*OrderList) GetOrders Uses

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

func (*OrderList) ProtoMessage Uses

func (*OrderList) ProtoMessage()

func (*OrderList) Reset Uses

func (m *OrderList) Reset()

func (*OrderList) String Uses

func (m *OrderList) String() string

func (*OrderList) XXX_DiscardUnknown Uses

func (m *OrderList) XXX_DiscardUnknown()

func (*OrderList) XXX_Marshal Uses

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

func (*OrderList) XXX_Merge Uses

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

func (*OrderList) XXX_Size Uses

func (m *OrderList) XXX_Size() int

func (*OrderList) XXX_Unmarshal Uses

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

type OrderListResponse Uses

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 Uses

func (*OrderListResponse) Descriptor() ([]byte, []int)

func (*OrderListResponse) GetOrders Uses

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

func (*OrderListResponse) ProtoMessage Uses

func (*OrderListResponse) ProtoMessage()

func (*OrderListResponse) Reset Uses

func (m *OrderListResponse) Reset()

func (*OrderListResponse) String Uses

func (m *OrderListResponse) String() string

func (*OrderListResponse) XXX_DiscardUnknown Uses

func (m *OrderListResponse) XXX_DiscardUnknown()

func (*OrderListResponse) XXX_Marshal Uses

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

func (*OrderListResponse) XXX_Merge Uses

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

func (*OrderListResponse) XXX_Size Uses

func (m *OrderListResponse) XXX_Size() int

func (*OrderListResponse) XXX_Unmarshal Uses

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

type OrderSpecificRequest Uses

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 Uses

func (*OrderSpecificRequest) Descriptor() ([]byte, []int)

func (*OrderSpecificRequest) GetChannelID Uses

func (m *OrderSpecificRequest) GetChannelID() []byte

func (*OrderSpecificRequest) GetOrderID Uses

func (m *OrderSpecificRequest) GetOrderID() []byte

func (*OrderSpecificRequest) ProtoMessage Uses

func (*OrderSpecificRequest) ProtoMessage()

func (*OrderSpecificRequest) Reset Uses

func (m *OrderSpecificRequest) Reset()

func (*OrderSpecificRequest) String Uses

func (m *OrderSpecificRequest) String() string

func (*OrderSpecificRequest) XXX_DiscardUnknown Uses

func (m *OrderSpecificRequest) XXX_DiscardUnknown()

func (*OrderSpecificRequest) XXX_Marshal Uses

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

func (*OrderSpecificRequest) XXX_Merge Uses

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

func (*OrderSpecificRequest) XXX_Size Uses

func (m *OrderSpecificRequest) XXX_Size() int

func (*OrderSpecificRequest) XXX_Unmarshal Uses

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

type Peer Uses

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 Uses

func (*Peer) Descriptor() ([]byte, []int)

func (*Peer) GetId Uses

func (m *Peer) GetId() string

func (*Peer) ProtoMessage Uses

func (*Peer) ProtoMessage()

func (*Peer) Reset Uses

func (m *Peer) Reset()

func (*Peer) String Uses

func (m *Peer) String() string

func (*Peer) XXX_DiscardUnknown Uses

func (m *Peer) XXX_DiscardUnknown()

func (*Peer) XXX_Marshal Uses

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

func (*Peer) XXX_Merge Uses

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

func (*Peer) XXX_Size Uses

func (m *Peer) XXX_Size() int

func (*Peer) XXX_Unmarshal Uses

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

type PeerListResponse Uses

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 Uses

func (*PeerListResponse) Descriptor() ([]byte, []int)

func (*PeerListResponse) GetPeerIDs Uses

func (m *PeerListResponse) GetPeerIDs() []string

func (*PeerListResponse) ProtoMessage Uses

func (*PeerListResponse) ProtoMessage()

func (*PeerListResponse) Reset Uses

func (m *PeerListResponse) Reset()

func (*PeerListResponse) String Uses

func (m *PeerListResponse) String() string

func (*PeerListResponse) XXX_DiscardUnknown Uses

func (m *PeerListResponse) XXX_DiscardUnknown()

func (*PeerListResponse) XXX_Marshal Uses

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

func (*PeerListResponse) XXX_Merge Uses

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

func (*PeerListResponse) XXX_Size Uses

func (m *PeerListResponse) XXX_Size() int

func (*PeerListResponse) XXX_Unmarshal Uses

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

type Recipient Uses

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 Uses

func (*Recipient) Descriptor() ([]byte, []int)

func (*Recipient) GetPeerID Uses

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

func (*Recipient) ProtoMessage Uses

func (*Recipient) ProtoMessage()

func (*Recipient) Reset Uses

func (m *Recipient) Reset()

func (*Recipient) String Uses

func (m *Recipient) String() string

func (*Recipient) XXX_DiscardUnknown Uses

func (m *Recipient) XXX_DiscardUnknown()

func (*Recipient) XXX_Marshal Uses

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

func (*Recipient) XXX_Merge Uses

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

func (*Recipient) XXX_Size Uses

func (m *Recipient) XXX_Size() int

func (*Recipient) XXX_Unmarshal Uses

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

type State Uses

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

func (State) EnumDescriptor Uses

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

func (State) String Uses

func (x State) String() string

type UnimplementedChannelHandlerServer Uses

type UnimplementedChannelHandlerServer struct {
}

UnimplementedChannelHandlerServer can be embedded to have forward compatible implementations.

func (*UnimplementedChannelHandlerServer) GetAllChannels Uses

func (*UnimplementedChannelHandlerServer) GetAllChannels(ctx context.Context, req *Empty) (*ChannelList, error)

func (*UnimplementedChannelHandlerServer) GetChannel Uses

func (*UnimplementedChannelHandlerServer) GetChannel(ctx context.Context, req *ChannelSpecificRequest) (*Channel, error)

func (*UnimplementedChannelHandlerServer) Join Uses

func (*UnimplementedChannelHandlerServer) Join(ctx context.Context, req *JoinRequest) (*JoinResponse, error)

func (*UnimplementedChannelHandlerServer) Leave Uses

func (*UnimplementedChannelHandlerServer) Leave(ctx context.Context, req *ChannelSpecificRequest) (*Empty, error)

type UnimplementedNodeHandlerServer Uses

type UnimplementedNodeHandlerServer struct {
}

UnimplementedNodeHandlerServer can be embedded to have forward compatible implementations.

func (*UnimplementedNodeHandlerServer) BlacklistPeer Uses

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

func (*UnimplementedNodeHandlerServer) GetAllPeers Uses

func (*UnimplementedNodeHandlerServer) GetAllPeers(ctx context.Context, req *Empty) (*PeerListResponse, error)

type UnimplementedOrderHandlerServer Uses

type UnimplementedOrderHandlerServer struct {
}

UnimplementedOrderHandlerServer can be embedded to have forward compatible implementations.

func (*UnimplementedOrderHandlerServer) Create Uses

func (*UnimplementedOrderHandlerServer) Create(ctx context.Context, req *CreateRequest) (*CreateResponse, error)

func (*UnimplementedOrderHandlerServer) Delete Uses

func (*UnimplementedOrderHandlerServer) Delete(ctx context.Context, req *OrderSpecificRequest) (*Empty, error)

func (*UnimplementedOrderHandlerServer) GetAllOrders Uses

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

func (*UnimplementedOrderHandlerServer) GetOrder Uses

func (*UnimplementedOrderHandlerServer) GetOrder(ctx context.Context, req *OrderSpecificRequest) (*Order, error)

func (*UnimplementedOrderHandlerServer) Lock Uses

func (*UnimplementedOrderHandlerServer) Lock(ctx context.Context, req *OrderSpecificRequest) (*Empty, error)

func (*UnimplementedOrderHandlerServer) Unlock Uses

func (*UnimplementedOrderHandlerServer) Unlock(ctx context.Context, req *OrderSpecificRequest) (*Empty, error)

type WireMessage Uses

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,3,opt,name=data,proto3" json:"data,omitempty"`
    XXX_NoUnkeyedLiteral struct{}  `json:"-"`
    XXX_unrecognized     []byte    `json:"-"`
    XXX_sizecache        int32     `json:"-"`
}

func (*WireMessage) Descriptor Uses

func (*WireMessage) Descriptor() ([]byte, []int)

func (*WireMessage) GetChannelID Uses

func (m *WireMessage) GetChannelID() []byte

func (*WireMessage) GetData Uses

func (m *WireMessage) GetData() []byte

func (*WireMessage) GetOperation Uses

func (m *WireMessage) GetOperation() Operation

func (*WireMessage) ProtoMessage Uses

func (*WireMessage) ProtoMessage()

func (*WireMessage) Reset Uses

func (m *WireMessage) Reset()

func (*WireMessage) String Uses

func (m *WireMessage) String() string

func (*WireMessage) XXX_DiscardUnknown Uses

func (m *WireMessage) XXX_DiscardUnknown()

func (*WireMessage) XXX_Marshal Uses

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

func (*WireMessage) XXX_Merge Uses

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

func (*WireMessage) XXX_Size Uses

func (m *WireMessage) XXX_Size() int

func (*WireMessage) XXX_Unmarshal Uses

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

Package pb imports 27 packages (graph) and is imported by 8 packages. Updated 2020-03-19. Refresh now. Tools for package owners.