injective_oracle_rpcpb

package
v1.50.1 Latest Latest
Warning

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

 Go to latest Published: Jan 25, 2024 License: Apache-2.0 Imports: 15 Imported by: 1

Documentation

Overview

Package injective_oracle_rpcpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var File_injective_oracle_rpc_proto protoreflect.FileDescriptor
View Source 
var InjectiveOracleRPC_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "injective_oracle_rpc.InjectiveOracleRPC",
	HandlerType: (*InjectiveOracleRPCServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "OracleList",
			Handler:    _InjectiveOracleRPC_OracleList_Handler,
		},
		{
			MethodName: "Price",
			Handler:    _InjectiveOracleRPC_Price_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamPrices",
			Handler:       _InjectiveOracleRPC_StreamPrices_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamPricesByMarkets",
			Handler:       _InjectiveOracleRPC_StreamPricesByMarkets_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "injective_oracle_rpc.proto",
}

InjectiveOracleRPC_ServiceDesc is the grpc.ServiceDesc for InjectiveOracleRPC service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterInjectiveOracleRPCHandler added in v1.32.1 

func RegisterInjectiveOracleRPCHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterInjectiveOracleRPCHandler registers the http handlers for service InjectiveOracleRPC to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterInjectiveOracleRPCHandlerClient added in v1.32.1 

func RegisterInjectiveOracleRPCHandlerClient(ctx context.Context, mux *runtime.ServeMux, client InjectiveOracleRPCClient) error

RegisterInjectiveOracleRPCHandlerClient registers the http handlers for service InjectiveOracleRPC to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "InjectiveOracleRPCClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "InjectiveOracleRPCClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "InjectiveOracleRPCClient" to call the correct interceptors.

func RegisterInjectiveOracleRPCHandlerFromEndpoint added in v1.32.1 

func RegisterInjectiveOracleRPCHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterInjectiveOracleRPCHandlerFromEndpoint is same as RegisterInjectiveOracleRPCHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterInjectiveOracleRPCHandlerServer added in v1.32.1 

func RegisterInjectiveOracleRPCHandlerServer(ctx context.Context, mux *runtime.ServeMux, server InjectiveOracleRPCServer) error

RegisterInjectiveOracleRPCHandlerServer registers the http handlers for service InjectiveOracleRPC to "mux". UnaryRPC :call InjectiveOracleRPCServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterInjectiveOracleRPCHandlerFromEndpoint instead.

func RegisterInjectiveOracleRPCServer 

func RegisterInjectiveOracleRPCServer(s grpc.ServiceRegistrar, srv InjectiveOracleRPCServer)

Types

type InjectiveOracleRPCClient 

type InjectiveOracleRPCClient interface {
	// List all oracles
	OracleList(ctx context.Context, in *OracleListRequest, opts ...grpc.CallOption) (*OracleListResponse, error)
	// Gets the price of the oracle
	Price(ctx context.Context, in *PriceRequest, opts ...grpc.CallOption) (*PriceResponse, error)
	// StreamPrices streams new price changes for a specified oracle. If no oracles
	// are provided, all price changes are streamed.
	StreamPrices(ctx context.Context, in *StreamPricesRequest, opts ...grpc.CallOption) (InjectiveOracleRPC_StreamPricesClient, error)
	// StreamPrices streams new price changes markets
	StreamPricesByMarkets(ctx context.Context, in *StreamPricesByMarketsRequest, opts ...grpc.CallOption) (InjectiveOracleRPC_StreamPricesByMarketsClient, error)
}

InjectiveOracleRPCClient is the client API for InjectiveOracleRPC service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewInjectiveOracleRPCClient 

func NewInjectiveOracleRPCClient(cc grpc.ClientConnInterface) InjectiveOracleRPCClient

type InjectiveOracleRPCServer 

type InjectiveOracleRPCServer interface {
	// List all oracles
	OracleList(context.Context, *OracleListRequest) (*OracleListResponse, error)
	// Gets the price of the oracle
	Price(context.Context, *PriceRequest) (*PriceResponse, error)
	// StreamPrices streams new price changes for a specified oracle. If no oracles
	// are provided, all price changes are streamed.
	StreamPrices(*StreamPricesRequest, InjectiveOracleRPC_StreamPricesServer) error
	// StreamPrices streams new price changes markets
	StreamPricesByMarkets(*StreamPricesByMarketsRequest, InjectiveOracleRPC_StreamPricesByMarketsServer) error
	// contains filtered or unexported methods
}

InjectiveOracleRPCServer is the server API for InjectiveOracleRPC service. All implementations must embed UnimplementedInjectiveOracleRPCServer for forward compatibility

type InjectiveOracleRPC_StreamPricesByMarketsClient added in v1.44.5 

type InjectiveOracleRPC_StreamPricesByMarketsClient interface {
	Recv() (*StreamPricesByMarketsResponse, error)
	grpc.ClientStream
}

type InjectiveOracleRPC_StreamPricesByMarketsServer added in v1.44.5 

type InjectiveOracleRPC_StreamPricesByMarketsServer interface {
	Send(*StreamPricesByMarketsResponse) error
	grpc.ServerStream
}

type InjectiveOracleRPC_StreamPricesClient 

type InjectiveOracleRPC_StreamPricesClient interface {
	Recv() (*StreamPricesResponse, error)
	grpc.ClientStream
}

type InjectiveOracleRPC_StreamPricesServer 

type InjectiveOracleRPC_StreamPricesServer interface {
	Send(*StreamPricesResponse) error
	grpc.ServerStream
}

type Oracle 

type Oracle struct {

	// The symbol of the oracle asset.
	Symbol string `protobuf:"bytes,1,opt,name=symbol,proto3" json:"symbol,omitempty"`
	// Oracle base currency
	BaseSymbol string `protobuf:"bytes,2,opt,name=base_symbol,json=baseSymbol,proto3" json:"base_symbol,omitempty"`
	// Oracle quote currency
	QuoteSymbol string `protobuf:"bytes,3,opt,name=quote_symbol,json=quoteSymbol,proto3" json:"quote_symbol,omitempty"`
	// Oracle Type
	OracleType string `protobuf:"bytes,4,opt,name=oracle_type,json=oracleType,proto3" json:"oracle_type,omitempty"`
	// The price of the oracle asset
	Price string `protobuf:"bytes,5,opt,name=price,proto3" json:"price,omitempty"`
	// contains filtered or unexported fields
}

func (*Oracle) Descriptor deprecated 

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

Deprecated: Use Oracle.ProtoReflect.Descriptor instead.

func (*Oracle) GetBaseSymbol 

func (x *Oracle) GetBaseSymbol() string

func (*Oracle) GetOracleType 

func (x *Oracle) GetOracleType() string

func (*Oracle) GetPrice 

func (x *Oracle) GetPrice() string

func (*Oracle) GetQuoteSymbol 

func (x *Oracle) GetQuoteSymbol() string

func (*Oracle) GetSymbol 

func (x *Oracle) GetSymbol() string

func (*Oracle) ProtoMessage 

func (*Oracle) ProtoMessage()

func (*Oracle) ProtoReflect 

func (x *Oracle) ProtoReflect() protoreflect.Message

func (*Oracle) Reset 

func (x *Oracle) Reset()

func (*Oracle) String 

func (x *Oracle) String() string

type OracleListRequest 

type OracleListRequest struct {
	// contains filtered or unexported fields
}

func (*OracleListRequest) Descriptor deprecated 

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

Deprecated: Use OracleListRequest.ProtoReflect.Descriptor instead.

func (*OracleListRequest) ProtoMessage 

func (*OracleListRequest) ProtoMessage()

func (*OracleListRequest) ProtoReflect 

func (x *OracleListRequest) ProtoReflect() protoreflect.Message

func (*OracleListRequest) Reset 

func (x *OracleListRequest) Reset()

func (*OracleListRequest) String 

func (x *OracleListRequest) String() string

type OracleListResponse 

type OracleListResponse struct {
	Oracles []*Oracle `protobuf:"bytes,1,rep,name=oracles,proto3" json:"oracles,omitempty"`
	// contains filtered or unexported fields
}

func (*OracleListResponse) Descriptor deprecated 

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

Deprecated: Use OracleListResponse.ProtoReflect.Descriptor instead.

func (*OracleListResponse) GetOracles 

func (x *OracleListResponse) GetOracles() []*Oracle

func (*OracleListResponse) ProtoMessage 

func (*OracleListResponse) ProtoMessage()

func (*OracleListResponse) ProtoReflect 

func (x *OracleListResponse) ProtoReflect() protoreflect.Message

func (*OracleListResponse) Reset 

func (x *OracleListResponse) Reset()

func (*OracleListResponse) String 

func (x *OracleListResponse) String() string

type PriceRequest 

type PriceRequest struct {

	// Oracle base currency
	BaseSymbol string `protobuf:"bytes,1,opt,name=base_symbol,json=baseSymbol,proto3" json:"base_symbol,omitempty"`
	// Oracle quote currency
	QuoteSymbol string `protobuf:"bytes,2,opt,name=quote_symbol,json=quoteSymbol,proto3" json:"quote_symbol,omitempty"`
	// Oracle Type
	OracleType string `protobuf:"bytes,3,opt,name=oracle_type,json=oracleType,proto3" json:"oracle_type,omitempty"`
	// OracleScaleFactor
	OracleScaleFactor uint32 `protobuf:"varint,4,opt,name=oracle_scale_factor,json=oracleScaleFactor,proto3" json:"oracle_scale_factor,omitempty"`
	// contains filtered or unexported fields
}

func (*PriceRequest) Descriptor deprecated 

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

Deprecated: Use PriceRequest.ProtoReflect.Descriptor instead.

func (*PriceRequest) GetBaseSymbol 

func (x *PriceRequest) GetBaseSymbol() string

func (*PriceRequest) GetOracleScaleFactor 

func (x *PriceRequest) GetOracleScaleFactor() uint32

func (*PriceRequest) GetOracleType 

func (x *PriceRequest) GetOracleType() string

func (*PriceRequest) GetQuoteSymbol 

func (x *PriceRequest) GetQuoteSymbol() string

func (*PriceRequest) ProtoMessage 

func (*PriceRequest) ProtoMessage()

func (*PriceRequest) ProtoReflect 

func (x *PriceRequest) ProtoReflect() protoreflect.Message

func (*PriceRequest) Reset 

func (x *PriceRequest) Reset()

func (*PriceRequest) String 

func (x *PriceRequest) String() string

type PriceResponse 

type PriceResponse struct {

	// The price of the oracle asset
	Price string `protobuf:"bytes,1,opt,name=price,proto3" json:"price,omitempty"`
	// contains filtered or unexported fields
}

func (*PriceResponse) Descriptor deprecated 

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

Deprecated: Use PriceResponse.ProtoReflect.Descriptor instead.

func (*PriceResponse) GetPrice 

func (x *PriceResponse) GetPrice() string

func (*PriceResponse) ProtoMessage 

func (*PriceResponse) ProtoMessage()

func (*PriceResponse) ProtoReflect 

func (x *PriceResponse) ProtoReflect() protoreflect.Message

func (*PriceResponse) Reset 

func (x *PriceResponse) Reset()

func (*PriceResponse) String 

func (x *PriceResponse) String() string

type StreamPricesByMarketsRequest added in v1.44.5 

type StreamPricesByMarketsRequest struct {

	// marketIDs to stream price for, empty to listen for all prices
	MarketIds []string `protobuf:"bytes,1,rep,name=market_ids,json=marketIds,proto3" json:"market_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamPricesByMarketsRequest) Descriptor deprecated added in v1.44.5 

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

Deprecated: Use StreamPricesByMarketsRequest.ProtoReflect.Descriptor instead.

func (*StreamPricesByMarketsRequest) GetMarketIds added in v1.44.5 

func (x *StreamPricesByMarketsRequest) GetMarketIds() []string

func (*StreamPricesByMarketsRequest) ProtoMessage added in v1.44.5 

func (*StreamPricesByMarketsRequest) ProtoMessage()

func (*StreamPricesByMarketsRequest) ProtoReflect added in v1.44.5 

func (x *StreamPricesByMarketsRequest) ProtoReflect() protoreflect.Message

func (*StreamPricesByMarketsRequest) Reset added in v1.44.5 

func (x *StreamPricesByMarketsRequest) Reset()

func (*StreamPricesByMarketsRequest) String added in v1.44.5 

func (x *StreamPricesByMarketsRequest) String() string

type StreamPricesByMarketsResponse added in v1.44.5 

type StreamPricesByMarketsResponse struct {

	// The price of the oracle asset
	Price string `protobuf:"bytes,1,opt,name=price,proto3" json:"price,omitempty"`
	// Operation timestamp in UNIX millis.
	Timestamp int64 `protobuf:"zigzag64,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// marketID that the price has been updated
	MarketId string `protobuf:"bytes,3,opt,name=market_id,json=marketId,proto3" json:"market_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamPricesByMarketsResponse) Descriptor deprecated added in v1.44.5 

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

Deprecated: Use StreamPricesByMarketsResponse.ProtoReflect.Descriptor instead.

func (*StreamPricesByMarketsResponse) GetMarketId added in v1.44.5 

func (x *StreamPricesByMarketsResponse) GetMarketId() string

func (*StreamPricesByMarketsResponse) GetPrice added in v1.44.5 

func (x *StreamPricesByMarketsResponse) GetPrice() string

func (*StreamPricesByMarketsResponse) GetTimestamp added in v1.44.5 

func (x *StreamPricesByMarketsResponse) GetTimestamp() int64

func (*StreamPricesByMarketsResponse) ProtoMessage added in v1.44.5 

func (*StreamPricesByMarketsResponse) ProtoMessage()

func (*StreamPricesByMarketsResponse) ProtoReflect added in v1.44.5 

func (x *StreamPricesByMarketsResponse) ProtoReflect() protoreflect.Message

func (*StreamPricesByMarketsResponse) Reset added in v1.44.5 

func (x *StreamPricesByMarketsResponse) Reset()

func (*StreamPricesByMarketsResponse) String added in v1.44.5 

func (x *StreamPricesByMarketsResponse) String() string

type StreamPricesRequest 

type StreamPricesRequest struct {

	// Oracle base currency
	BaseSymbol string `protobuf:"bytes,1,opt,name=base_symbol,json=baseSymbol,proto3" json:"base_symbol,omitempty"`
	// Oracle quote currency
	QuoteSymbol string `protobuf:"bytes,2,opt,name=quote_symbol,json=quoteSymbol,proto3" json:"quote_symbol,omitempty"`
	// Oracle Type
	OracleType string `protobuf:"bytes,3,opt,name=oracle_type,json=oracleType,proto3" json:"oracle_type,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamPricesRequest) Descriptor deprecated 

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

Deprecated: Use StreamPricesRequest.ProtoReflect.Descriptor instead.

func (*StreamPricesRequest) GetBaseSymbol 

func (x *StreamPricesRequest) GetBaseSymbol() string

func (*StreamPricesRequest) GetOracleType 

func (x *StreamPricesRequest) GetOracleType() string

func (*StreamPricesRequest) GetQuoteSymbol 

func (x *StreamPricesRequest) GetQuoteSymbol() string

func (*StreamPricesRequest) ProtoMessage 

func (*StreamPricesRequest) ProtoMessage()

func (*StreamPricesRequest) ProtoReflect 

func (x *StreamPricesRequest) ProtoReflect() protoreflect.Message

func (*StreamPricesRequest) Reset 

func (x *StreamPricesRequest) Reset()

func (*StreamPricesRequest) String 

func (x *StreamPricesRequest) String() string

type StreamPricesResponse 

type StreamPricesResponse struct {

	// The price of the oracle asset
	Price string `protobuf:"bytes,1,opt,name=price,proto3" json:"price,omitempty"`
	// Operation timestamp in UNIX millis.
	Timestamp int64 `protobuf:"zigzag64,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamPricesResponse) Descriptor deprecated 

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

Deprecated: Use StreamPricesResponse.ProtoReflect.Descriptor instead.

func (*StreamPricesResponse) GetPrice 

func (x *StreamPricesResponse) GetPrice() string

func (*StreamPricesResponse) GetTimestamp 

func (x *StreamPricesResponse) GetTimestamp() int64

func (*StreamPricesResponse) ProtoMessage 

func (*StreamPricesResponse) ProtoMessage()

func (*StreamPricesResponse) ProtoReflect 

func (x *StreamPricesResponse) ProtoReflect() protoreflect.Message

func (*StreamPricesResponse) Reset 

func (x *StreamPricesResponse) Reset()

func (*StreamPricesResponse) String 

func (x *StreamPricesResponse) String() string

type UnimplementedInjectiveOracleRPCServer 

type UnimplementedInjectiveOracleRPCServer struct {
}

UnimplementedInjectiveOracleRPCServer must be embedded to have forward compatible implementations.

func (UnimplementedInjectiveOracleRPCServer) OracleList 

func (UnimplementedInjectiveOracleRPCServer) OracleList(context.Context, *OracleListRequest) (*OracleListResponse, error)

func (UnimplementedInjectiveOracleRPCServer) Price 

func (UnimplementedInjectiveOracleRPCServer) Price(context.Context, *PriceRequest) (*PriceResponse, error)

func (UnimplementedInjectiveOracleRPCServer) StreamPrices 

func (UnimplementedInjectiveOracleRPCServer) StreamPrices(*StreamPricesRequest, InjectiveOracleRPC_StreamPricesServer) error

func (UnimplementedInjectiveOracleRPCServer) StreamPricesByMarkets added in v1.44.5 

func (UnimplementedInjectiveOracleRPCServer) StreamPricesByMarkets(*StreamPricesByMarketsRequest, InjectiveOracleRPC_StreamPricesByMarketsServer) error

type UnsafeInjectiveOracleRPCServer 

type UnsafeInjectiveOracleRPCServer interface {
	// contains filtered or unexported methods
}

UnsafeInjectiveOracleRPCServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to InjectiveOracleRPCServer will result in compilation errors.

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.