api

package
v0.2.2 Latest Latest
Warning

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

 Go to latest Published: Sep 14, 2023 License: AGPL-3.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthPriceFeed        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPriceFeed          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPriceFeed = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterPriceFeedServiceServer 

func RegisterPriceFeedServiceServer(s grpc1.Server, srv PriceFeedServiceServer)

Types

type ExchangePrice 

type ExchangePrice struct {
	ExchangeId     string     `protobuf:"bytes,1,opt,name=exchange_id,json=exchangeId,proto3" json:"exchange_id,omitempty"`
	Price          uint64     `protobuf:"varint,2,opt,name=price,proto3" json:"price,omitempty"`
	LastUpdateTime *time.Time `protobuf:"bytes,3,opt,name=last_update_time,json=lastUpdateTime,proto3,stdtime" json:"last_update_time,omitempty"`
}

ExchangePrice represents a specific exchange's market price

func (*ExchangePrice) Descriptor 

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

func (*ExchangePrice) GetExchangeId 

func (m *ExchangePrice) GetExchangeId() string

func (*ExchangePrice) GetLastUpdateTime 

func (m *ExchangePrice) GetLastUpdateTime() *time.Time

func (*ExchangePrice) GetPrice 

func (m *ExchangePrice) GetPrice() uint64

func (*ExchangePrice) Marshal 

func (m *ExchangePrice) Marshal() (dAtA []byte, err error)

func (*ExchangePrice) MarshalTo 

func (m *ExchangePrice) MarshalTo(dAtA []byte) (int, error)

func (*ExchangePrice) MarshalToSizedBuffer 

func (m *ExchangePrice) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ExchangePrice) ProtoMessage 

func (*ExchangePrice) ProtoMessage()

func (*ExchangePrice) Reset 

func (m *ExchangePrice) Reset()

func (*ExchangePrice) Size 

func (m *ExchangePrice) Size() (n int)

func (*ExchangePrice) String 

func (m *ExchangePrice) String() string

func (*ExchangePrice) Unmarshal 

func (m *ExchangePrice) Unmarshal(dAtA []byte) error

func (*ExchangePrice) XXX_DiscardUnknown 

func (m *ExchangePrice) XXX_DiscardUnknown()

func (*ExchangePrice) XXX_Marshal 

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

func (*ExchangePrice) XXX_Merge 

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

func (*ExchangePrice) XXX_Size 

func (m *ExchangePrice) XXX_Size() int

func (*ExchangePrice) XXX_Unmarshal 

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

type MarketPriceUpdate 

type MarketPriceUpdate struct {
	MarketId       uint32           `protobuf:"varint,1,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	ExchangePrices []*ExchangePrice `protobuf:"bytes,2,rep,name=exchange_prices,json=exchangePrices,proto3" json:"exchange_prices,omitempty"`
}

MarketPriceUpdate represents an update to a single market

func (*MarketPriceUpdate) Descriptor 

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

func (*MarketPriceUpdate) GetExchangePrices 

func (m *MarketPriceUpdate) GetExchangePrices() []*ExchangePrice

func (*MarketPriceUpdate) GetMarketId 

func (m *MarketPriceUpdate) GetMarketId() uint32

func (*MarketPriceUpdate) Marshal 

func (m *MarketPriceUpdate) Marshal() (dAtA []byte, err error)

func (*MarketPriceUpdate) MarshalTo 

func (m *MarketPriceUpdate) MarshalTo(dAtA []byte) (int, error)

func (*MarketPriceUpdate) MarshalToSizedBuffer 

func (m *MarketPriceUpdate) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MarketPriceUpdate) ProtoMessage 

func (*MarketPriceUpdate) ProtoMessage()

func (*MarketPriceUpdate) Reset 

func (m *MarketPriceUpdate) Reset()

func (*MarketPriceUpdate) Size 

func (m *MarketPriceUpdate) Size() (n int)

func (*MarketPriceUpdate) String 

func (m *MarketPriceUpdate) String() string

func (*MarketPriceUpdate) Unmarshal 

func (m *MarketPriceUpdate) Unmarshal(dAtA []byte) error

func (*MarketPriceUpdate) XXX_DiscardUnknown 

func (m *MarketPriceUpdate) XXX_DiscardUnknown()

func (*MarketPriceUpdate) XXX_Marshal 

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

func (*MarketPriceUpdate) XXX_Merge 

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

func (*MarketPriceUpdate) XXX_Size 

func (m *MarketPriceUpdate) XXX_Size() int

func (*MarketPriceUpdate) XXX_Unmarshal 

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

type PriceFeedServiceClient 

type PriceFeedServiceClient interface {
	// Updates market prices.
	UpdateMarketPrices(ctx context.Context, in *UpdateMarketPricesRequest, opts ...grpc.CallOption) (*UpdateMarketPricesResponse, error)
}

PriceFeedServiceClient is the client API for PriceFeedService service.

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

func NewPriceFeedServiceClient 

func NewPriceFeedServiceClient(cc grpc1.ClientConn) PriceFeedServiceClient

type PriceFeedServiceServer 

type PriceFeedServiceServer interface {
	// Updates market prices.
	UpdateMarketPrices(context.Context, *UpdateMarketPricesRequest) (*UpdateMarketPricesResponse, error)
}

PriceFeedServiceServer is the server API for PriceFeedService service.

type UnimplementedPriceFeedServiceServer 

type UnimplementedPriceFeedServiceServer struct {
}

UnimplementedPriceFeedServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedPriceFeedServiceServer) UpdateMarketPrices 

func (*UnimplementedPriceFeedServiceServer) UpdateMarketPrices(ctx context.Context, req *UpdateMarketPricesRequest) (*UpdateMarketPricesResponse, error)

type UpdateMarketPricesRequest 

type UpdateMarketPricesRequest struct {
	MarketPriceUpdates []*MarketPriceUpdate `protobuf:"bytes,1,rep,name=market_price_updates,json=marketPriceUpdates,proto3" json:"market_price_updates,omitempty"`
}

UpdateMarketPriceRequest is a request message updating market prices.

func (*UpdateMarketPricesRequest) Descriptor 

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

func (*UpdateMarketPricesRequest) GetMarketPriceUpdates 

func (m *UpdateMarketPricesRequest) GetMarketPriceUpdates() []*MarketPriceUpdate

func (*UpdateMarketPricesRequest) Marshal 

func (m *UpdateMarketPricesRequest) Marshal() (dAtA []byte, err error)

func (*UpdateMarketPricesRequest) MarshalTo 

func (m *UpdateMarketPricesRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpdateMarketPricesRequest) MarshalToSizedBuffer 

func (m *UpdateMarketPricesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateMarketPricesRequest) ProtoMessage 

func (*UpdateMarketPricesRequest) ProtoMessage()

func (*UpdateMarketPricesRequest) Reset 

func (m *UpdateMarketPricesRequest) Reset()

func (*UpdateMarketPricesRequest) Size 

func (m *UpdateMarketPricesRequest) Size() (n int)

func (*UpdateMarketPricesRequest) String 

func (m *UpdateMarketPricesRequest) String() string

func (*UpdateMarketPricesRequest) Unmarshal 

func (m *UpdateMarketPricesRequest) Unmarshal(dAtA []byte) error

func (*UpdateMarketPricesRequest) XXX_DiscardUnknown 

func (m *UpdateMarketPricesRequest) XXX_DiscardUnknown()

func (*UpdateMarketPricesRequest) XXX_Marshal 

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

func (*UpdateMarketPricesRequest) XXX_Merge 

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

func (*UpdateMarketPricesRequest) XXX_Size 

func (m *UpdateMarketPricesRequest) XXX_Size() int

func (*UpdateMarketPricesRequest) XXX_Unmarshal 

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

type UpdateMarketPricesResponse 

type UpdateMarketPricesResponse struct {
}

UpdateMarketPricesResponse is a response message for updating market prices.

func (*UpdateMarketPricesResponse) Descriptor 

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

func (*UpdateMarketPricesResponse) Marshal 

func (m *UpdateMarketPricesResponse) Marshal() (dAtA []byte, err error)

func (*UpdateMarketPricesResponse) MarshalTo 

func (m *UpdateMarketPricesResponse) MarshalTo(dAtA []byte) (int, error)

func (*UpdateMarketPricesResponse) MarshalToSizedBuffer 

func (m *UpdateMarketPricesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateMarketPricesResponse) ProtoMessage 

func (*UpdateMarketPricesResponse) ProtoMessage()

func (*UpdateMarketPricesResponse) Reset 

func (m *UpdateMarketPricesResponse) Reset()

func (*UpdateMarketPricesResponse) Size 

func (m *UpdateMarketPricesResponse) Size() (n int)

func (*UpdateMarketPricesResponse) String 

func (m *UpdateMarketPricesResponse) String() string

func (*UpdateMarketPricesResponse) Unmarshal 

func (m *UpdateMarketPricesResponse) Unmarshal(dAtA []byte) error

func (*UpdateMarketPricesResponse) XXX_DiscardUnknown 

func (m *UpdateMarketPricesResponse) XXX_DiscardUnknown()

func (*UpdateMarketPricesResponse) XXX_Marshal 

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

func (*UpdateMarketPricesResponse) XXX_Merge 

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

func (*UpdateMarketPricesResponse) XXX_Size 

func (m *UpdateMarketPricesResponse) XXX_Size() int

func (*UpdateMarketPricesResponse) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.