api

Documentation

Index

• func RegisterMarketDataServiceServer(s *grpc.Server, srv MarketDataServiceServer)
• type MarketDataServiceClient
  • func NewMarketDataServiceClient(cc *grpc.ClientConn) MarketDataServiceClient
• type MarketDataServiceServer
• type MarketDataService_ConnectClient
• type MarketDataService_ConnectServer
• type MdsConnectRequest
  • func (*MdsConnectRequest) Descriptor() ([]byte, []int)
  • func (m *MdsConnectRequest) GetMaxQuotePerSecond() int32
  • func (m *MdsConnectRequest) GetSubscriberId() string
  • func (*MdsConnectRequest) ProtoMessage()
  • func (m *MdsConnectRequest) Reset()
  • func (m *MdsConnectRequest) String() string
  • func (m *MdsConnectRequest) XXX_DiscardUnknown()
  • func (m *MdsConnectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *MdsConnectRequest) XXX_Merge(src proto.Message)
  • func (m *MdsConnectRequest) XXX_Size() int
  • func (m *MdsConnectRequest) XXX_Unmarshal(b []byte) error
• type MdsSubscribeRequest
  • func (*MdsSubscribeRequest) Descriptor() ([]byte, []int)
  • func (m *MdsSubscribeRequest) GetListingId() int32
  • func (m *MdsSubscribeRequest) GetSubscriberId() string
  • func (*MdsSubscribeRequest) ProtoMessage()
  • func (m *MdsSubscribeRequest) Reset()
  • func (m *MdsSubscribeRequest) String() string
  • func (m *MdsSubscribeRequest) XXX_DiscardUnknown()
  • func (m *MdsSubscribeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *MdsSubscribeRequest) XXX_Merge(src proto.Message)
  • func (m *MdsSubscribeRequest) XXX_Size() int
  • func (m *MdsSubscribeRequest) XXX_Unmarshal(b []byte) error
• type UnimplementedMarketDataServiceServer
  • func (*UnimplementedMarketDataServiceServer) Connect(req *MdsConnectRequest, srv MarketDataService_ConnectServer) error
  • func (*UnimplementedMarketDataServiceServer) Subscribe(ctx context.Context, req *MdsSubscribeRequest) (*model.Empty, error)

Functions

func RegisterMarketDataServiceServer

func RegisterMarketDataServiceServer(s *grpc.Server, srv MarketDataServiceServer)

Types

type MarketDataServiceClient

type MarketDataServiceClient interface {
	Subscribe(ctx context.Context, in *MdsSubscribeRequest, opts ...grpc.CallOption) (*model.Empty, error)
	Connect(ctx context.Context, in *MdsConnectRequest, opts ...grpc.CallOption) (MarketDataService_ConnectClient, error)
}

MarketDataServiceClient is the client API for MarketDataService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMarketDataServiceClient

func NewMarketDataServiceClient(cc *grpc.ClientConn) MarketDataServiceClient

type MarketDataServiceServer

type MarketDataServiceServer interface {
	Subscribe(context.Context, *MdsSubscribeRequest) (*model.Empty, error)
	Connect(*MdsConnectRequest, MarketDataService_ConnectServer) error
}

MarketDataServiceServer is the server API for MarketDataService service.

type MarketDataService_ConnectClient

type MarketDataService_ConnectClient interface {
	Recv() (*model.ClobQuote, error)
	grpc.ClientStream
}

type MarketDataService_ConnectServer

type MarketDataService_ConnectServer interface {
	Send(*model.ClobQuote) error
	grpc.ServerStream
}

type MdsConnectRequest

type MdsConnectRequest struct {
	SubscriberId         string   `protobuf:"bytes,1,opt,name=subscriberId,proto3" json:"subscriberId,omitempty"`
	MaxQuotePerSecond    int32    `protobuf:"varint,2,opt,name=maxQuotePerSecond,proto3" json:"maxQuotePerSecond,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MdsConnectRequest) Descriptor

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

func (*MdsConnectRequest) GetMaxQuotePerSecond

func (m *MdsConnectRequest) GetMaxQuotePerSecond() int32

func (*MdsConnectRequest) GetSubscriberId

func (m *MdsConnectRequest) GetSubscriberId() string

func (*MdsConnectRequest) ProtoMessage

func (*MdsConnectRequest) ProtoMessage()

func (*MdsConnectRequest) Reset

func (m *MdsConnectRequest) Reset()

func (*MdsConnectRequest) String

func (m *MdsConnectRequest) String() string

func (*MdsConnectRequest) XXX_DiscardUnknown

func (m *MdsConnectRequest) XXX_DiscardUnknown()

func (*MdsConnectRequest) XXX_Marshal

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

func (*MdsConnectRequest) XXX_Merge

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

func (*MdsConnectRequest) XXX_Size

func (m *MdsConnectRequest) XXX_Size() int

func (*MdsConnectRequest) XXX_Unmarshal

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

type MdsSubscribeRequest

type MdsSubscribeRequest struct {
	SubscriberId         string   `protobuf:"bytes,1,opt,name=subscriberId,proto3" json:"subscriberId,omitempty"`
	ListingId            int32    `protobuf:"varint,2,opt,name=listingId,proto3" json:"listingId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MdsSubscribeRequest) Descriptor

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

func (*MdsSubscribeRequest) GetListingId

func (m *MdsSubscribeRequest) GetListingId() int32

func (*MdsSubscribeRequest) GetSubscriberId

func (m *MdsSubscribeRequest) GetSubscriberId() string

func (*MdsSubscribeRequest) ProtoMessage

func (*MdsSubscribeRequest) ProtoMessage()

func (*MdsSubscribeRequest) Reset

func (m *MdsSubscribeRequest) Reset()

func (*MdsSubscribeRequest) String

func (m *MdsSubscribeRequest) String() string

func (*MdsSubscribeRequest) XXX_DiscardUnknown

func (m *MdsSubscribeRequest) XXX_DiscardUnknown()

func (*MdsSubscribeRequest) XXX_Marshal

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

func (*MdsSubscribeRequest) XXX_Merge

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

func (*MdsSubscribeRequest) XXX_Size

func (m *MdsSubscribeRequest) XXX_Size() int

func (*MdsSubscribeRequest) XXX_Unmarshal

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

type UnimplementedMarketDataServiceServer

type UnimplementedMarketDataServiceServer struct {
}

UnimplementedMarketDataServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMarketDataServiceServer) Connect

func (*UnimplementedMarketDataServiceServer) Connect(req *MdsConnectRequest, srv MarketDataService_ConnectServer) error

func (*UnimplementedMarketDataServiceServer) Subscribe

func (*UnimplementedMarketDataServiceServer) Subscribe(ctx context.Context, req *MdsSubscribeRequest) (*model.Empty, error)