bidstore

package
v0.20.34 Latest Latest
Warning

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

 Go to latest Published: Feb 26, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthBids        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBids          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupBids = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var PriceBandFromShortName = map[string]PriceBand{
	"None": PriceBand_PRICE_BAND_UNSPECIFIED,
	"A":    PriceBand_PRICE_BAND_A,
	"B":    PriceBand_PRICE_BAND_B,
	"C":    PriceBand_PRICE_BAND_C,
	"D":    PriceBand_PRICE_BAND_D,
	"E":    PriceBand_PRICE_BAND_E,
	"F":    PriceBand_PRICE_BAND_F,
	"G":    PriceBand_PRICE_BAND_G,
	"H":    PriceBand_PRICE_BAND_H,
}
View Source 
var PriceBandToShortName = map[PriceBand]string{
	PriceBand_PRICE_BAND_UNSPECIFIED: "None",
	PriceBand_PRICE_BAND_A:           "A",
	PriceBand_PRICE_BAND_B:           "B",
	PriceBand_PRICE_BAND_C:           "C",
	PriceBand_PRICE_BAND_D:           "D",
	PriceBand_PRICE_BAND_E:           "E",
	PriceBand_PRICE_BAND_F:           "F",
	PriceBand_PRICE_BAND_G:           "G",
	PriceBand_PRICE_BAND_H:           "H",
}
View Source 
var PriceBand_name = map[int32]string{
	0: "PRICE_BAND_UNSPECIFIED",
	1: "PRICE_BAND_A",
	2: "PRICE_BAND_B",
	3: "PRICE_BAND_C",
	4: "PRICE_BAND_D",
	5: "PRICE_BAND_E",
	6: "PRICE_BAND_F",
	7: "PRICE_BAND_G",
	8: "PRICE_BAND_H",
}
View Source 
var PriceBand_value = map[string]int32{
	"PRICE_BAND_UNSPECIFIED": 0,
	"PRICE_BAND_A":           1,
	"PRICE_BAND_B":           2,
	"PRICE_BAND_C":           3,
	"PRICE_BAND_D":           4,
	"PRICE_BAND_E":           5,
	"PRICE_BAND_F":           6,
	"PRICE_BAND_G":           7,
	"PRICE_BAND_H":           8,
}
View Source 
var PricingPhase_name = map[int32]string{
	0: "PRICING_PHASE_UNSPECIFIED",
	1: "PRICING_PHASE_QUEUEING",
	2: "PRICING_PHASE_RUNNING",
}
View Source 
var PricingPhase_value = map[string]int32{
	"PRICING_PHASE_UNSPECIFIED": 0,
	"PRICING_PHASE_QUEUEING":    1,
	"PRICING_PHASE_RUNNING":     2,
}

Functions

func RegisterBidRetrieverServiceServer 

func RegisterBidRetrieverServiceServer(s *grpc.Server, srv BidRetrieverServiceServer)

Types

type Bid 

type Bid struct {
	// The bid price in beans
	Amount float64 `protobuf:"fixed64,1,opt,name=amount,proto3" json:"amount,omitempty"`
	// Timestamp when this bid was last updated
	LastUpdated *types.Timestamp `protobuf:"bytes,2,opt,name=last_updated,json=lastUpdated,proto3" json:"lastUpdated,omitempty"`
}

Bid represents the bid price for a resouce unit-hour with a timestamp.

func (*Bid) Descriptor 

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

func (*Bid) GetAmount 

func (m *Bid) GetAmount() float64

func (*Bid) GetLastUpdated 

func (m *Bid) GetLastUpdated() *types.Timestamp

func (*Bid) Marshal 

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

func (*Bid) MarshalTo 

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

func (*Bid) MarshalToSizedBuffer 

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

func (*Bid) ProtoMessage 

func (*Bid) ProtoMessage()

func (*Bid) Reset 

func (m *Bid) Reset()

func (*Bid) Size 

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

func (*Bid) String 

func (m *Bid) String() string

func (*Bid) Unmarshal 

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

func (*Bid) XXX_DiscardUnknown 

func (m *Bid) XXX_DiscardUnknown()

func (*Bid) XXX_Marshal 

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

func (*Bid) XXX_Merge 

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

func (*Bid) XXX_Size 

func (m *Bid) XXX_Size() int

func (*Bid) XXX_Unmarshal 

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

type BidRetrieverServiceClient 

type BidRetrieverServiceClient interface {
	// RetrieveBids retrieves the current bids for the specified queues across all
	// relevant resource pools, price bands, and pricing phases.
	RetrieveBids(ctx context.Context, in *RetrieveBidsRequest, opts ...grpc.CallOption) (*RetrieveBidsResponse, error)
}

BidRetrieverServiceClient is the client API for BidRetrieverService service.

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

func NewBidRetrieverServiceClient 

func NewBidRetrieverServiceClient(cc *grpc.ClientConn) BidRetrieverServiceClient

type BidRetrieverServiceServer 

type BidRetrieverServiceServer interface {
	// RetrieveBids retrieves the current bids for the specified queues across all
	// relevant resource pools, price bands, and pricing phases.
	RetrieveBids(context.Context, *RetrieveBidsRequest) (*RetrieveBidsResponse, error)
}

BidRetrieverServiceServer is the server API for BidRetrieverService service.

type PoolBids 

type PoolBids struct {
	// List of bids for different price bands - a list instead of a map because we
	// cannot use an enum value as a map key
	PriceBandBids []*PriceBandBid `protobuf:"bytes,1,rep,name=price_band_bids,json=priceBandBids,proto3" json:"priceBandBids,omitempty"`
	// Fallback bid for the pool for the queue when a job is not labelled with a
	// valid price band
	FallbackBids *PriceBandBids `protobuf:"bytes,2,opt,name=fallback_bids,json=fallbackBids,proto3" json:"fallbackBids,omitempty"`
}

PoolBids contains all a queue's bids for different price bands within a resource pool.

func (*PoolBids) Descriptor 

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

func (*PoolBids) GetBidsForBand 

func (q *PoolBids) GetBidsForBand(band PriceBand) (*PriceBandBid, bool)

func (*PoolBids) GetFallbackBids added in v0.19.11 

func (m *PoolBids) GetFallbackBids() *PriceBandBids

func (*PoolBids) GetPriceBandBids 

func (m *PoolBids) GetPriceBandBids() []*PriceBandBid

func (*PoolBids) Marshal 

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

func (*PoolBids) MarshalTo 

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

func (*PoolBids) MarshalToSizedBuffer 

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

func (*PoolBids) ProtoMessage 

func (*PoolBids) ProtoMessage()

func (*PoolBids) Reset 

func (m *PoolBids) Reset()

func (*PoolBids) Size 

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

func (*PoolBids) String 

func (m *PoolBids) String() string

func (*PoolBids) Unmarshal 

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

func (*PoolBids) XXX_DiscardUnknown 

func (m *PoolBids) XXX_DiscardUnknown()

func (*PoolBids) XXX_Marshal 

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

func (*PoolBids) XXX_Merge 

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

func (*PoolBids) XXX_Size 

func (m *PoolBids) XXX_Size() int

func (*PoolBids) XXX_Unmarshal 

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

type PriceBand 

type PriceBand int32

PriceBand represents different pricing tiers to which users label their jobs and set bid prices. 

const (
	// Default value when price band is not specified
	PriceBand_PRICE_BAND_UNSPECIFIED PriceBand = 0
	// Standard price bands (not necessarily ordered)
	PriceBand_PRICE_BAND_A PriceBand = 1
	PriceBand_PRICE_BAND_B PriceBand = 2
	PriceBand_PRICE_BAND_C PriceBand = 3
	PriceBand_PRICE_BAND_D PriceBand = 4
	PriceBand_PRICE_BAND_E PriceBand = 5
	PriceBand_PRICE_BAND_F PriceBand = 6
	PriceBand_PRICE_BAND_G PriceBand = 7
	PriceBand_PRICE_BAND_H PriceBand = 8
)

func (PriceBand) EnumDescriptor 

func (PriceBand) EnumDescriptor() ([]byte, []int)

func (PriceBand) String 

func (x PriceBand) String() string

type PriceBandBid 

type PriceBandBid struct {
	// The price band these bids apply to
	PriceBand PriceBand `protobuf:"varint,1,opt,name=price_band,json=priceBand,proto3,enum=api.PriceBand" json:"priceBand,omitempty"`
	// The bids for this price band
	PriceBandBids *PriceBandBids `protobuf:"bytes,2,opt,name=price_band_bids,json=priceBandBids,proto3" json:"priceBandBids,omitempty"`
}

PriceBandBid associates bids with a specific price band.

func (*PriceBandBid) Descriptor 

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

func (*PriceBandBid) GetPriceBand 

func (m *PriceBandBid) GetPriceBand() PriceBand

func (*PriceBandBid) GetPriceBandBids 

func (m *PriceBandBid) GetPriceBandBids() *PriceBandBids

func (*PriceBandBid) Marshal 

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

func (*PriceBandBid) MarshalTo 

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

func (*PriceBandBid) MarshalToSizedBuffer 

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

func (*PriceBandBid) ProtoMessage 

func (*PriceBandBid) ProtoMessage()

func (*PriceBandBid) Reset 

func (m *PriceBandBid) Reset()

func (*PriceBandBid) Size 

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

func (*PriceBandBid) String 

func (m *PriceBandBid) String() string

func (*PriceBandBid) Unmarshal 

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

func (*PriceBandBid) XXX_DiscardUnknown 

func (m *PriceBandBid) XXX_DiscardUnknown()

func (*PriceBandBid) XXX_Marshal 

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

func (*PriceBandBid) XXX_Merge 

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

func (*PriceBandBid) XXX_Size 

func (m *PriceBandBid) XXX_Size() int

func (*PriceBandBid) XXX_Unmarshal 

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

type PriceBandBids 

type PriceBandBids struct {
	// List of bids for different pricing phases - a list instead of a map because
	// we cannot use an enum value as a map key
	PricingPhaseBids []*PricingPhaseBid `protobuf:"bytes,1,rep,name=pricing_phase_bids,json=pricingPhaseBids,proto3" json:"pricingPhaseBids,omitempty"`
}

PriceBandBids contains all a queue's bids for a pool, for different pricing phases within a price band.

func (*PriceBandBids) Descriptor 

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

func (*PriceBandBids) GetBidForPhase 

func (p *PriceBandBids) GetBidForPhase(phase PricingPhase) (*Bid, bool)

func (*PriceBandBids) GetPricingPhaseBids 

func (m *PriceBandBids) GetPricingPhaseBids() []*PricingPhaseBid

func (*PriceBandBids) Marshal 

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

func (*PriceBandBids) MarshalTo 

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

func (*PriceBandBids) MarshalToSizedBuffer 

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

func (*PriceBandBids) ProtoMessage 

func (*PriceBandBids) ProtoMessage()

func (*PriceBandBids) Reset 

func (m *PriceBandBids) Reset()

func (*PriceBandBids) Size 

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

func (*PriceBandBids) String 

func (m *PriceBandBids) String() string

func (*PriceBandBids) Unmarshal 

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

func (*PriceBandBids) XXX_DiscardUnknown 

func (m *PriceBandBids) XXX_DiscardUnknown()

func (*PriceBandBids) XXX_Marshal 

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

func (*PriceBandBids) XXX_Merge 

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

func (*PriceBandBids) XXX_Size 

func (m *PriceBandBids) XXX_Size() int

func (*PriceBandBids) XXX_Unmarshal 

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

type PricingPhase 

type PricingPhase int32

PricingPhase represents different phases of the job's lifecycle which have different bids. 

const (
	// Default value when phase is not specified
	PricingPhase_PRICING_PHASE_UNSPECIFIED PricingPhase = 0
	// Resource is waiting to be scheduled
	PricingPhase_PRICING_PHASE_QUEUEING PricingPhase = 1
	// Resource has been scheduled and so is running
	PricingPhase_PRICING_PHASE_RUNNING PricingPhase = 2
)

func (PricingPhase) EnumDescriptor 

func (PricingPhase) EnumDescriptor() ([]byte, []int)

func (PricingPhase) String 

func (x PricingPhase) String() string

type PricingPhaseBid 

type PricingPhaseBid struct {
	// The pricing phase this bid applies to
	PricingPhase PricingPhase `protobuf:"varint,1,opt,name=pricing_phase,json=pricingPhase,proto3,enum=api.PricingPhase" json:"pricingPhase,omitempty"`
	// The bid
	Bid *Bid `protobuf:"bytes,2,opt,name=bid,proto3" json:"bid,omitempty"`
}

PricingPhaseBid associates a bid with a specific pricing phase.

func (*PricingPhaseBid) Descriptor 

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

func (*PricingPhaseBid) GetBid 

func (m *PricingPhaseBid) GetBid() *Bid

func (*PricingPhaseBid) GetPricingPhase 

func (m *PricingPhaseBid) GetPricingPhase() PricingPhase

func (*PricingPhaseBid) Marshal 

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

func (*PricingPhaseBid) MarshalTo 

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

func (*PricingPhaseBid) MarshalToSizedBuffer 

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

func (*PricingPhaseBid) ProtoMessage 

func (*PricingPhaseBid) ProtoMessage()

func (*PricingPhaseBid) Reset 

func (m *PricingPhaseBid) Reset()

func (*PricingPhaseBid) Size 

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

func (*PricingPhaseBid) String 

func (m *PricingPhaseBid) String() string

func (*PricingPhaseBid) Unmarshal 

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

func (*PricingPhaseBid) XXX_DiscardUnknown 

func (m *PricingPhaseBid) XXX_DiscardUnknown()

func (*PricingPhaseBid) XXX_Marshal 

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

func (*PricingPhaseBid) XXX_Merge 

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

func (*PricingPhaseBid) XXX_Size 

func (m *PricingPhaseBid) XXX_Size() int

func (*PricingPhaseBid) XXX_Unmarshal 

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

type QueueBids 

type QueueBids struct {
	// Mapping of bids for each resource pool
	PoolBids map[string]*PoolBids `` /* 172-byte string literal not displayed */
}

QueueBids contains all bids for different resource pools within a queue.

func (*QueueBids) Descriptor 

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

func (*QueueBids) GetPoolBids 

func (m *QueueBids) GetPoolBids() map[string]*PoolBids

func (*QueueBids) Marshal 

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

func (*QueueBids) MarshalTo 

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

func (*QueueBids) MarshalToSizedBuffer 

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

func (*QueueBids) ProtoMessage 

func (*QueueBids) ProtoMessage()

func (*QueueBids) Reset 

func (m *QueueBids) Reset()

func (*QueueBids) Size 

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

func (*QueueBids) String 

func (m *QueueBids) String() string

func (*QueueBids) Unmarshal 

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

func (*QueueBids) XXX_DiscardUnknown 

func (m *QueueBids) XXX_DiscardUnknown()

func (*QueueBids) XXX_Marshal 

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

func (*QueueBids) XXX_Merge 

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

func (*QueueBids) XXX_Size 

func (m *QueueBids) XXX_Size() int

func (*QueueBids) XXX_Unmarshal 

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

type ResourceShape added in v0.19.11 

type ResourceShape struct {
	// Map of resource type (k8s.io.core.v1.ResourceName and "nvidia.com/gpu") to
	// quantity
	Resources map[string]*resource.Quantity `` /* 159-byte string literal not displayed */
}

ResourceShape is a map of Kubernetes resource type to quantity

func (*ResourceShape) Descriptor added in v0.19.11 

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

func (*ResourceShape) GetResources added in v0.19.11 

func (m *ResourceShape) GetResources() map[string]*resource.Quantity

func (*ResourceShape) Marshal added in v0.19.11 

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

func (*ResourceShape) MarshalTo added in v0.19.11 

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

func (*ResourceShape) MarshalToSizedBuffer added in v0.19.11 

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

func (*ResourceShape) ProtoMessage added in v0.19.11 

func (*ResourceShape) ProtoMessage()

func (*ResourceShape) Reset added in v0.19.11 

func (m *ResourceShape) Reset()

func (*ResourceShape) Size added in v0.19.11 

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

func (*ResourceShape) String added in v0.19.11 

func (m *ResourceShape) String() string

func (*ResourceShape) Unmarshal added in v0.19.11 

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

func (*ResourceShape) XXX_DiscardUnknown added in v0.19.11 

func (m *ResourceShape) XXX_DiscardUnknown()

func (*ResourceShape) XXX_Marshal added in v0.19.11 

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

func (*ResourceShape) XXX_Merge added in v0.19.11 

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

func (*ResourceShape) XXX_Size added in v0.19.11 

func (m *ResourceShape) XXX_Size() int

func (*ResourceShape) XXX_Unmarshal added in v0.19.11 

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

type RetrieveBidsRequest 

type RetrieveBidsRequest struct {
	// List of queue names to retrieve bids for
	Queues []string `protobuf:"bytes,1,rep,name=queues,proto3" json:"queues,omitempty"`
}

RetrieveBidsRequest specifies which queues to retrieve bids for.

func (*RetrieveBidsRequest) Descriptor 

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

func (*RetrieveBidsRequest) GetQueues 

func (m *RetrieveBidsRequest) GetQueues() []string

func (*RetrieveBidsRequest) Marshal 

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

func (*RetrieveBidsRequest) MarshalTo 

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

func (*RetrieveBidsRequest) MarshalToSizedBuffer 

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

func (*RetrieveBidsRequest) ProtoMessage 

func (*RetrieveBidsRequest) ProtoMessage()

func (*RetrieveBidsRequest) Reset 

func (m *RetrieveBidsRequest) Reset()

func (*RetrieveBidsRequest) Size 

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

func (*RetrieveBidsRequest) String 

func (m *RetrieveBidsRequest) String() string

func (*RetrieveBidsRequest) Unmarshal 

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

func (*RetrieveBidsRequest) XXX_DiscardUnknown 

func (m *RetrieveBidsRequest) XXX_DiscardUnknown()

func (*RetrieveBidsRequest) XXX_Marshal 

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

func (*RetrieveBidsRequest) XXX_Merge 

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

func (*RetrieveBidsRequest) XXX_Size 

func (m *RetrieveBidsRequest) XXX_Size() int

func (*RetrieveBidsRequest) XXX_Unmarshal 

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

type RetrieveBidsResponse 

type RetrieveBidsResponse struct {
	// Map of queue names to their respective bids
	QueueBids map[string]*QueueBids `` /* 175-byte string literal not displayed */
	// Map of pool name to resource unit shape for that pool
	PoolResourceUnits map[string]*ResourceShape `` /* 200-byte string literal not displayed */
}

RetrieveBidsResponse contains the retrieved bids for all requested queues, as well as resource unit shapes for each pool.

func (*RetrieveBidsResponse) Descriptor 

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

func (*RetrieveBidsResponse) GetPoolResourceUnits added in v0.19.11 

func (m *RetrieveBidsResponse) GetPoolResourceUnits() map[string]*ResourceShape

func (*RetrieveBidsResponse) GetQueueBids 

func (m *RetrieveBidsResponse) GetQueueBids() map[string]*QueueBids

func (*RetrieveBidsResponse) Marshal 

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

func (*RetrieveBidsResponse) MarshalTo 

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

func (*RetrieveBidsResponse) MarshalToSizedBuffer 

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

func (*RetrieveBidsResponse) ProtoMessage 

func (*RetrieveBidsResponse) ProtoMessage()

func (*RetrieveBidsResponse) Reset 

func (m *RetrieveBidsResponse) Reset()

func (*RetrieveBidsResponse) Size 

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

func (*RetrieveBidsResponse) String 

func (m *RetrieveBidsResponse) String() string

func (*RetrieveBidsResponse) Unmarshal 

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

func (*RetrieveBidsResponse) XXX_DiscardUnknown 

func (m *RetrieveBidsResponse) XXX_DiscardUnknown()

func (*RetrieveBidsResponse) XXX_Marshal 

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

func (*RetrieveBidsResponse) XXX_Merge 

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

func (*RetrieveBidsResponse) XXX_Size 

func (m *RetrieveBidsResponse) XXX_Size() int

func (*RetrieveBidsResponse) XXX_Unmarshal 

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

type UnimplementedBidRetrieverServiceServer 

type UnimplementedBidRetrieverServiceServer struct {
}

UnimplementedBidRetrieverServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedBidRetrieverServiceServer) RetrieveBids 

func (*UnimplementedBidRetrieverServiceServer) RetrieveBids(ctx context.Context, req *RetrieveBidsRequest) (*RetrieveBidsResponse, 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.