injective_auction_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_auction_rpcpb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var File_injective_auction_rpc_proto protoreflect.FileDescriptor
View Source 
var InjectiveAuctionRPC_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "injective_auction_rpc.InjectiveAuctionRPC",
	HandlerType: (*InjectiveAuctionRPCServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AuctionEndpoint",
			Handler:    _InjectiveAuctionRPC_AuctionEndpoint_Handler,
		},
		{
			MethodName: "Auctions",
			Handler:    _InjectiveAuctionRPC_Auctions_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamBids",
			Handler:       _InjectiveAuctionRPC_StreamBids_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "injective_auction_rpc.proto",
}

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

Functions

func RegisterInjectiveAuctionRPCHandler added in v1.32.1 

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

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

func RegisterInjectiveAuctionRPCHandlerClient added in v1.32.1 

func RegisterInjectiveAuctionRPCHandlerClient(ctx context.Context, mux *runtime.ServeMux, client InjectiveAuctionRPCClient) error

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

func RegisterInjectiveAuctionRPCHandlerFromEndpoint added in v1.32.1 

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

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

func RegisterInjectiveAuctionRPCHandlerServer added in v1.32.1 

func RegisterInjectiveAuctionRPCHandlerServer(ctx context.Context, mux *runtime.ServeMux, server InjectiveAuctionRPCServer) error

RegisterInjectiveAuctionRPCHandlerServer registers the http handlers for service InjectiveAuctionRPC to "mux". UnaryRPC :call InjectiveAuctionRPCServer 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 RegisterInjectiveAuctionRPCHandlerFromEndpoint instead.

func RegisterInjectiveAuctionRPCServer 

func RegisterInjectiveAuctionRPCServer(s grpc.ServiceRegistrar, srv InjectiveAuctionRPCServer)

Types

type Auction 

type Auction struct {

	// Account address of the auction winner
	Winner string `protobuf:"bytes,1,opt,name=winner,proto3" json:"winner,omitempty"`
	// Coins in the basket
	Basket           []*Coin `protobuf:"bytes,2,rep,name=basket,proto3" json:"basket,omitempty"`
	WinningBidAmount string  `protobuf:"bytes,3,opt,name=winning_bid_amount,json=winningBidAmount,proto3" json:"winning_bid_amount,omitempty"`
	Round            uint64  `protobuf:"varint,4,opt,name=round,proto3" json:"round,omitempty"`
	// Auction end timestamp in UNIX millis.
	EndTimestamp int64 `protobuf:"zigzag64,5,opt,name=end_timestamp,json=endTimestamp,proto3" json:"end_timestamp,omitempty"`
	// UpdatedAt timestamp in UNIX millis.
	UpdatedAt int64 `protobuf:"zigzag64,6,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Auction) Descriptor deprecated 

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

Deprecated: Use Auction.ProtoReflect.Descriptor instead.

func (*Auction) GetBasket 

func (x *Auction) GetBasket() []*Coin

func (*Auction) GetEndTimestamp 

func (x *Auction) GetEndTimestamp() int64

func (*Auction) GetRound 

func (x *Auction) GetRound() uint64

func (*Auction) GetUpdatedAt 

func (x *Auction) GetUpdatedAt() int64

func (*Auction) GetWinner 

func (x *Auction) GetWinner() string

func (*Auction) GetWinningBidAmount 

func (x *Auction) GetWinningBidAmount() string

func (*Auction) ProtoMessage 

func (*Auction) ProtoMessage()

func (*Auction) ProtoReflect 

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

func (*Auction) Reset 

func (x *Auction) Reset()

func (*Auction) String 

func (x *Auction) String() string

type AuctionEndpointRequest added in v1.45.2 

type AuctionEndpointRequest struct {

	// The auction round number. -1 for latest.
	Round int64 `protobuf:"zigzag64,1,opt,name=round,proto3" json:"round,omitempty"`
	// contains filtered or unexported fields
}

func (*AuctionEndpointRequest) Descriptor deprecated added in v1.45.2 

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

Deprecated: Use AuctionEndpointRequest.ProtoReflect.Descriptor instead.

func (*AuctionEndpointRequest) GetRound added in v1.45.2 

func (x *AuctionEndpointRequest) GetRound() int64

func (*AuctionEndpointRequest) ProtoMessage added in v1.45.2 

func (*AuctionEndpointRequest) ProtoMessage()

func (*AuctionEndpointRequest) ProtoReflect added in v1.45.2 

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

func (*AuctionEndpointRequest) Reset added in v1.45.2 

func (x *AuctionEndpointRequest) Reset()

func (*AuctionEndpointRequest) String added in v1.45.2 

func (x *AuctionEndpointRequest) String() string

type AuctionEndpointResponse added in v1.45.2 

type AuctionEndpointResponse struct {

	// The auction
	Auction *Auction `protobuf:"bytes,1,opt,name=auction,proto3" json:"auction,omitempty"`
	// Bids of the auction
	Bids []*Bid `protobuf:"bytes,2,rep,name=bids,proto3" json:"bids,omitempty"`
	// contains filtered or unexported fields
}

func (*AuctionEndpointResponse) Descriptor deprecated added in v1.45.2 

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

Deprecated: Use AuctionEndpointResponse.ProtoReflect.Descriptor instead.

func (*AuctionEndpointResponse) GetAuction added in v1.45.2 

func (x *AuctionEndpointResponse) GetAuction() *Auction

func (*AuctionEndpointResponse) GetBids added in v1.45.2 

func (x *AuctionEndpointResponse) GetBids() []*Bid

func (*AuctionEndpointResponse) ProtoMessage added in v1.45.2 

func (*AuctionEndpointResponse) ProtoMessage()

func (*AuctionEndpointResponse) ProtoReflect added in v1.45.2 

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

func (*AuctionEndpointResponse) Reset added in v1.45.2 

func (x *AuctionEndpointResponse) Reset()

func (*AuctionEndpointResponse) String added in v1.45.2 

func (x *AuctionEndpointResponse) String() string

type AuctionsRequest 

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

func (*AuctionsRequest) Descriptor deprecated 

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

Deprecated: Use AuctionsRequest.ProtoReflect.Descriptor instead.

func (*AuctionsRequest) ProtoMessage 

func (*AuctionsRequest) ProtoMessage()

func (*AuctionsRequest) ProtoReflect 

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

func (*AuctionsRequest) Reset 

func (x *AuctionsRequest) Reset()

func (*AuctionsRequest) String 

func (x *AuctionsRequest) String() string

type AuctionsResponse 

type AuctionsResponse struct {

	// The historical auctions
	Auctions []*Auction `protobuf:"bytes,1,rep,name=auctions,proto3" json:"auctions,omitempty"`
	// contains filtered or unexported fields
}

func (*AuctionsResponse) Descriptor deprecated 

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

Deprecated: Use AuctionsResponse.ProtoReflect.Descriptor instead.

func (*AuctionsResponse) GetAuctions 

func (x *AuctionsResponse) GetAuctions() []*Auction

func (*AuctionsResponse) ProtoMessage 

func (*AuctionsResponse) ProtoMessage()

func (*AuctionsResponse) ProtoReflect 

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

func (*AuctionsResponse) Reset 

func (x *AuctionsResponse) Reset()

func (*AuctionsResponse) String 

func (x *AuctionsResponse) String() string

type Bid 

type Bid struct {

	// Account address of the bidder
	Bidder string `protobuf:"bytes,1,opt,name=bidder,proto3" json:"bidder,omitempty"`
	Amount string `protobuf:"bytes,2,opt,name=amount,proto3" json:"amount,omitempty"`
	// Bid timestamp in UNIX millis.
	Timestamp int64 `protobuf:"zigzag64,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*Bid) Descriptor deprecated 

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

Deprecated: Use Bid.ProtoReflect.Descriptor instead.

func (*Bid) GetAmount 

func (x *Bid) GetAmount() string

func (*Bid) GetBidder 

func (x *Bid) GetBidder() string

func (*Bid) GetTimestamp 

func (x *Bid) GetTimestamp() int64

func (*Bid) ProtoMessage 

func (*Bid) ProtoMessage()

func (*Bid) ProtoReflect 

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

func (*Bid) Reset 

func (x *Bid) Reset()

func (*Bid) String 

func (x *Bid) String() string

type Coin 

type Coin struct {

	// Denom of the coin
	Denom  string `protobuf:"bytes,1,opt,name=denom,proto3" json:"denom,omitempty"`
	Amount string `protobuf:"bytes,2,opt,name=amount,proto3" json:"amount,omitempty"`
	// contains filtered or unexported fields
}

func (*Coin) Descriptor deprecated 

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

Deprecated: Use Coin.ProtoReflect.Descriptor instead.

func (*Coin) GetAmount 

func (x *Coin) GetAmount() string

func (*Coin) GetDenom 

func (x *Coin) GetDenom() string

func (*Coin) ProtoMessage 

func (*Coin) ProtoMessage()

func (*Coin) ProtoReflect 

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

func (*Coin) Reset 

func (x *Coin) Reset()

func (*Coin) String 

func (x *Coin) String() string

type InjectiveAuctionRPCClient 

type InjectiveAuctionRPCClient interface {
	// Provide historical auction info for a given auction
	AuctionEndpoint(ctx context.Context, in *AuctionEndpointRequest, opts ...grpc.CallOption) (*AuctionEndpointResponse, error)
	// Provide the historical auctions info
	Auctions(ctx context.Context, in *AuctionsRequest, opts ...grpc.CallOption) (*AuctionsResponse, error)
	// StreamBids streams new bids of an auction.
	StreamBids(ctx context.Context, in *StreamBidsRequest, opts ...grpc.CallOption) (InjectiveAuctionRPC_StreamBidsClient, error)
}

InjectiveAuctionRPCClient is the client API for InjectiveAuctionRPC 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 NewInjectiveAuctionRPCClient 

func NewInjectiveAuctionRPCClient(cc grpc.ClientConnInterface) InjectiveAuctionRPCClient

type InjectiveAuctionRPCServer 

type InjectiveAuctionRPCServer interface {
	// Provide historical auction info for a given auction
	AuctionEndpoint(context.Context, *AuctionEndpointRequest) (*AuctionEndpointResponse, error)
	// Provide the historical auctions info
	Auctions(context.Context, *AuctionsRequest) (*AuctionsResponse, error)
	// StreamBids streams new bids of an auction.
	StreamBids(*StreamBidsRequest, InjectiveAuctionRPC_StreamBidsServer) error
	// contains filtered or unexported methods
}

InjectiveAuctionRPCServer is the server API for InjectiveAuctionRPC service. All implementations must embed UnimplementedInjectiveAuctionRPCServer for forward compatibility

type InjectiveAuctionRPC_StreamBidsClient 

type InjectiveAuctionRPC_StreamBidsClient interface {
	Recv() (*StreamBidsResponse, error)
	grpc.ClientStream
}

type InjectiveAuctionRPC_StreamBidsServer 

type InjectiveAuctionRPC_StreamBidsServer interface {
	Send(*StreamBidsResponse) error
	grpc.ServerStream
}

type StreamBidsRequest 

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

func (*StreamBidsRequest) Descriptor deprecated 

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

Deprecated: Use StreamBidsRequest.ProtoReflect.Descriptor instead.

func (*StreamBidsRequest) ProtoMessage 

func (*StreamBidsRequest) ProtoMessage()

func (*StreamBidsRequest) ProtoReflect 

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

func (*StreamBidsRequest) Reset 

func (x *StreamBidsRequest) Reset()

func (*StreamBidsRequest) String 

func (x *StreamBidsRequest) String() string

type StreamBidsResponse 

type StreamBidsResponse struct {

	// Account address of the bidder
	Bidder    string `protobuf:"bytes,1,opt,name=bidder,proto3" json:"bidder,omitempty"`
	BidAmount string `protobuf:"bytes,2,opt,name=bid_amount,json=bidAmount,proto3" json:"bid_amount,omitempty"`
	Round     uint64 `protobuf:"varint,3,opt,name=round,proto3" json:"round,omitempty"`
	// Operation timestamp in UNIX millis.
	Timestamp int64 `protobuf:"zigzag64,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamBidsResponse) Descriptor deprecated 

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

Deprecated: Use StreamBidsResponse.ProtoReflect.Descriptor instead.

func (*StreamBidsResponse) GetBidAmount 

func (x *StreamBidsResponse) GetBidAmount() string

func (*StreamBidsResponse) GetBidder 

func (x *StreamBidsResponse) GetBidder() string

func (*StreamBidsResponse) GetRound 

func (x *StreamBidsResponse) GetRound() uint64

func (*StreamBidsResponse) GetTimestamp 

func (x *StreamBidsResponse) GetTimestamp() int64

func (*StreamBidsResponse) ProtoMessage 

func (*StreamBidsResponse) ProtoMessage()

func (*StreamBidsResponse) ProtoReflect 

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

func (*StreamBidsResponse) Reset 

func (x *StreamBidsResponse) Reset()

func (*StreamBidsResponse) String 

func (x *StreamBidsResponse) String() string

type UnimplementedInjectiveAuctionRPCServer 

type UnimplementedInjectiveAuctionRPCServer struct {
}

UnimplementedInjectiveAuctionRPCServer must be embedded to have forward compatible implementations.

func (UnimplementedInjectiveAuctionRPCServer) AuctionEndpoint 

func (UnimplementedInjectiveAuctionRPCServer) AuctionEndpoint(context.Context, *AuctionEndpointRequest) (*AuctionEndpointResponse, error)

func (UnimplementedInjectiveAuctionRPCServer) Auctions 

func (UnimplementedInjectiveAuctionRPCServer) Auctions(context.Context, *AuctionsRequest) (*AuctionsResponse, error)

func (UnimplementedInjectiveAuctionRPCServer) StreamBids 

func (UnimplementedInjectiveAuctionRPCServer) StreamBids(*StreamBidsRequest, InjectiveAuctionRPC_StreamBidsServer) error

type UnsafeInjectiveAuctionRPCServer 

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

UnsafeInjectiveAuctionRPCServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to InjectiveAuctionRPCServer 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.