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 Operation_name = map[int32]string{
    0:  "CREATE",
    1:  "DELETE",
    2:  "LOCK",
    3:  "UNLOCK",
}
var Operation_value = map[string]int32{
    "CREATE": 0,
    "DELETE": 1,
    "LOCK":   2,
    "UNLOCK": 3,
}
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 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) (*GenericResponse, error)
    GetChannel(ctx context.Context, in *ChannelSpecificRequest, opts ...grpc.CallOption) (*Channel, error)
    GetAllChannels(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ChannelListResponse, 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) (*GenericResponse, error)
    GetChannel(context.Context, *ChannelSpecificRequest) (*Channel, error)
    GetAllChannels(context.Context, *Empty) (*ChannelListResponse, error)
}

ChannelHandlerServer is the server API for ChannelHandler service.

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"`
    Error                *Error   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,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) GetError Uses

func (m *CreateResponse) GetError() *Error

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 Error Uses

type Error struct {
    Code                 string   `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
    Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*Error) Descriptor Uses

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

func (*Error) GetCode Uses

func (m *Error) GetCode() string

func (*Error) GetMessage Uses

func (m *Error) GetMessage() string

func (*Error) ProtoMessage Uses

func (*Error) ProtoMessage()

func (*Error) Reset Uses

func (m *Error) Reset()

func (*Error) String Uses

func (m *Error) String() string

func (*Error) XXX_DiscardUnknown Uses

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal Uses

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

func (*Error) XXX_Merge Uses

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

func (*Error) XXX_Size Uses

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal Uses

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

type GenericResponse Uses

type GenericResponse struct {
    Error                *Error   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*GenericResponse) Descriptor Uses

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

func (*GenericResponse) GetError Uses

func (m *GenericResponse) GetError() *Error

func (*GenericResponse) ProtoMessage Uses

func (*GenericResponse) ProtoMessage()

func (*GenericResponse) Reset Uses

func (m *GenericResponse) Reset()

func (*GenericResponse) String Uses

func (m *GenericResponse) String() string

func (*GenericResponse) XXX_DiscardUnknown Uses

func (m *GenericResponse) XXX_DiscardUnknown()

func (*GenericResponse) XXX_Marshal Uses

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

func (*GenericResponse) XXX_Merge Uses

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

func (*GenericResponse) XXX_Size Uses

func (m *GenericResponse) XXX_Size() int

func (*GenericResponse) XXX_Unmarshal Uses

func (m *GenericResponse) 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"`
    Error                *Error   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

func (*JoinResponse) Descriptor Uses

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

func (*JoinResponse) GetError Uses

func (m *JoinResponse) GetError() *Error

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 Operation Uses

type Operation int32
const (
    Operation_CREATE Operation = 0
    Operation_DELETE Operation = 1
    Operation_LOCK   Operation = 2
    Operation_UNLOCK Operation = 3
)

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"`
    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) GetPrice Uses

func (m *Order) GetPrice() float32

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) (*GenericResponse, error)
    Lock(ctx context.Context, in *OrderSpecificRequest, opts ...grpc.CallOption) (*GenericResponse, error)
    Unlock(ctx context.Context, in *OrderSpecificRequest, opts ...grpc.CallOption) (*GenericResponse, error)
    GetOrder(ctx context.Context, in *OrderSpecificRequest, opts ...grpc.CallOption) (*Order, error)
    GetAllOrders(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*OrderListResponse, 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) (*GenericResponse, error)
    Lock(context.Context, *OrderSpecificRequest) (*GenericResponse, error)
    Unlock(context.Context, *OrderSpecificRequest) (*GenericResponse, error)
    GetOrder(context.Context, *OrderSpecificRequest) (*Order, error)
    GetAllOrders(context.Context, *Empty) (*OrderListResponse, error)
}

OrderHandlerServer is the server API for OrderHandler service.

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 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) (*ChannelListResponse, 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) (*GenericResponse, 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) (*GenericResponse, error)

func (*UnimplementedOrderHandlerServer) GetAllOrders Uses

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

func (*UnimplementedOrderHandlerServer) Unlock Uses

func (*UnimplementedOrderHandlerServer) Unlock(ctx context.Context, req *OrderSpecificRequest) (*GenericResponse, 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 1 packages. Updated 2019-10-10. Refresh now. Tools for package owners.