v1beta5

package
v0.0.2-rc4 Latest Latest
Warning

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

Go to latest
Published: Nov 14, 2024 License: Apache-2.0 Imports: 41 Imported by: 3

Documentation

Overview

Package v1beta5 is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source
const (
	// ModuleName is the module name constant used in many places
	ModuleName = "market"

	// StoreKey is the store key string for market
	StoreKey = ModuleName

	// RouterKey is the message route for market
	RouterKey = ModuleName
)
View Source
const (
	GatewayVersion = "v1beta5"
)

Variables

View Source
var (
	ErrInvalidLengthBid        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBid          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupBid = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthBidmsg        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBidmsg          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupBidmsg = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	// ErrEmptyProvider is the error when provider is empty
	ErrEmptyProvider = sdkerrors.Register(ModuleName, errCodeEmptyProvider, "empty provider")
	// ErrSameAccount is the error when owner and provider are the same account
	ErrSameAccount = sdkerrors.Register(ModuleName, errCodeSameAccount, "owner and provider are the same account")
	// ErrInternal is the error for internal error
	ErrInternal = sdkerrors.Register(ModuleName, errCodeInternal, "internal error")
	// ErrBidOverOrder is the error when bid price is above max order price
	ErrBidOverOrder = sdkerrors.Register(ModuleName, errCodeOverOrder, "bid price above max order price")
	// ErrAttributeMismatch is the error for attribute mismatch
	ErrAttributeMismatch = sdkerrors.Register(ModuleName, errCodeAttributeMismatch, "attribute mismatch")
	// ErrCapabilitiesMismatch is the error for capabilities mismatch
	ErrCapabilitiesMismatch = sdkerrors.Register(ModuleName, errCodeCapabilitiesMismatch, "capabilities mismatch")
	// ErrUnknownBid is the error for unknown bid
	ErrUnknownBid = sdkerrors.Register(ModuleName, errCodeUnknownBid, "unknown bid")
	// ErrUnknownLease is the error for unknown bid
	ErrUnknownLease = sdkerrors.Register(ModuleName, errCodeUnknownLease, "unknown lease")
	// ErrUnknownLeaseForBid is the error when lease is unknown for bid
	ErrUnknownLeaseForBid = sdkerrors.Register(ModuleName, errCodeUnknownLeaseForOrder, "unknown lease for bid")
	// ErrUnknownOrderForBid is the error when order is unknown for bid
	ErrUnknownOrderForBid = sdkerrors.Register(ModuleName, errCodeUnknownOrderForBid, "unknown order for bid")
	// ErrLeaseNotActive is the error when lease is not active
	ErrLeaseNotActive = sdkerrors.Register(ModuleName, errCodeLeaseNotActive, "lease not active")
	// ErrBidNotActive is the error when bid is not matched
	ErrBidNotActive = sdkerrors.Register(ModuleName, errCodeBidNotActive, "bid not active")
	// ErrBidNotOpen is the error when bid is not matched
	ErrBidNotOpen = sdkerrors.Register(ModuleName, errCodeBidNotOpen, "bid not open")
	// ErrNoLeaseForOrder is the error when there is no lease for order
	ErrNoLeaseForOrder = sdkerrors.Register(ModuleName, errCodeNoLeaseForOrder, "no lease for order")
	// ErrOrderNotFound order not found
	ErrOrderNotFound = sdkerrors.Register(ModuleName, errCodeOrderNotFound, "invalid order: order not found")
	// ErrGroupNotFound order not found
	ErrGroupNotFound = sdkerrors.Register(ModuleName, errCodeGroupNotFound, "order not found")
	// ErrGroupNotOpen order not found
	ErrGroupNotOpen = sdkerrors.Register(ModuleName, errCodeGroupNotOpen, "order not open")
	// ErrOrderNotOpen order not found
	ErrOrderNotOpen = sdkerrors.Register(ModuleName, errCodeOrderNotOpen, "bid: order not open")
	// ErrBidNotFound bid not found
	ErrBidNotFound = sdkerrors.Register(ModuleName, errCodeBidNotFound, "invalid bid: bid not found")
	// ErrBidZeroPrice zero price
	ErrBidZeroPrice = sdkerrors.Register(ModuleName, errCodeBidZeroPrice, "invalid bid: zero price")
	// ErrLeaseNotFound lease not found
	ErrLeaseNotFound = sdkerrors.Register(ModuleName, errCodeLeaseNotFound, "invalid lease: lease not found")
	// ErrBidExists bid exists
	ErrBidExists = sdkerrors.Register(ModuleName, errCodeBidExists, "invalid bid: bid exists from provider")
	// ErrBidInvalidPrice bid invalid price
	ErrBidInvalidPrice = sdkerrors.Register(ModuleName, errCodeInvalidPrice, "bid price is invalid")
	// ErrOrderActive order active
	ErrOrderActive = sdkerrors.New(ModuleName, errCodeOrderActive, "order active")
	// ErrOrderClosed order closed
	ErrOrderClosed = sdkerrors.New(ModuleName, errCodeOrderClosed, "order closed")
	// ErrOrderExists indicates a new order was proposed overwrite the existing store key
	ErrOrderExists = sdkerrors.New(ModuleName, errCodeOrderExists, "order already exists in store")
	// ErrOrderTooEarly to match bid
	ErrOrderTooEarly = sdkerrors.New(ModuleName, errCodeOrderTooEarly, "order: chain height to low for bidding")
	// ErrOrderDurationExceeded order should be closed
	ErrOrderDurationExceeded = sdkerrors.New(ModuleName, errCodeOrderDurationExceeded, "order duration has exceeded the bidding duration")
	// ErrInvalidDeposit indicates an invalid deposit
	ErrInvalidDeposit = sdkerrors.Register(ModuleName, errInvalidDeposit, "Deposit invalid")
	// ErrInvalidParam indicates an invalid chain parameter
	ErrInvalidParam = sdkerrors.Register(ModuleName, errInvalidParam, "parameter invalid")
	// ErrUnknownProvider indicates an invalid chain parameter
	ErrUnknownProvider = sdkerrors.Register(ModuleName, errUnknownProvider, "unknown provider")
	// ErrInvalidBid indicates an invalid chain parameter
	ErrInvalidBid = sdkerrors.Register(ModuleName, errInvalidBid, "unknown provider")
)
View Source
var (
	ErrInvalidLengthFilters        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowFilters          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupFilters = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthLeasemsg        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLeasemsg          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupLeasemsg = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthOrder        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowOrder          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupOrder = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthParams        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowParams          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupParams = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthParamsmsg        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowParamsmsg          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupParamsmsg = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidPath = errors.New("query: invalid path")
	ErrOwnerValue  = errors.New("query: invalid owner value")
	ErrStateValue  = errors.New("query: invalid state value")
)
View Source
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthResourcesoffer        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowResourcesoffer          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupResourcesoffer = fmt.Errorf("proto: unexpected end of group")
)
View Source
var Bid_State_name = map[int32]string{
	0: "invalid",
	1: "open",
	2: "active",
	3: "lost",
	4: "closed",
}
View Source
var Bid_State_value = map[string]int32{
	"invalid": 0,
	"open":    1,
	"active":  2,
	"lost":    3,
	"closed":  4,
}
View Source
var (
	DefaultBidMinDeposit = sdk.NewCoin("uakt", sdk.NewInt(500000))
)
View Source
var (

	// ModuleCdc references the global x/market module codec. Note, the codec should
	// ONLY be used in certain instances of tests and for JSON encoding as Amino is
	// still used for that purpose.
	//
	// The actual codec used for serialization should be provided to x/market and
	// defined at the application level.
	//
	// Deprecated: ModuleCdc use is deprecated
	ModuleCdc = codec.NewProtoCodec(cdctypes.NewInterfaceRegistry())
)
View Source
var Order_State_name = map[int32]string{
	0: "invalid",
	1: "open",
	2: "active",
	3: "closed",
}
View Source
var Order_State_value = map[string]int32{
	"invalid": 0,
	"open":    1,
	"active":  2,
	"closed":  3,
}

Functions

func BidPrefix

func BidPrefix() []byte

func EscrowAccountForBid

func EscrowAccountForBid(id v1.BidID) etypes.AccountID

func EscrowPaymentForLease

func EscrowPaymentForLease(id v1.LeaseID) string

func LeaseIDFromEscrowAccount

func LeaseIDFromEscrowAccount(id etypes.AccountID, pid string) (v1.LeaseID, bool)

func LeasePath

func LeasePath(id v1.LeaseID) string

LeasePath return lease path of given lease id for queries

func LeasePrefix

func LeasePrefix() []byte

func OrderPath

func OrderPath(id v1.OrderID) string

OrderPath return order path of given order id for queries

func OrderPrefix

func OrderPrefix() []byte

func ParamKeyTable

func ParamKeyTable() paramtypes.KeyTable

func ParamsPrefix

func ParamsPrefix() []byte

func ParseLeasePath

func ParseLeasePath(parts []string) (v1.LeaseID, error)

ParseLeasePath returns leaseID details with provided queries, and return error if occurred due to wrong query

func RegisterInterfaces

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

RegisterInterfaces registers the x/market interfaces types with the interface registry

func RegisterLegacyAminoCodec deprecated

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

RegisterLegacyAminoCodec registers the necessary x/market interfaces and concrete types on the provided Amino codec. These types are used for Amino JSON serialization.

Deprecated: RegisterLegacyAminoCodec is deprecated

func RegisterMsgServer

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler

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

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

func RegisterQueryHandlerClient

func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error

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

func RegisterQueryHandlerFromEndpoint

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

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

func RegisterQueryHandlerServer

func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error

RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer 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 RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func SecondaryLeasePrefix

func SecondaryLeasePrefix() []byte

Types

type Bid

type Bid struct {
	ID             v1.BidID       `protobuf:"bytes,1,opt,name=id,proto3" json:"id" yaml:"id"`
	State          Bid_State      `protobuf:"varint,2,opt,name=state,proto3,enum=akash.market.v1beta5.Bid_State" json:"state" yaml:"state"`
	Price          types.DecCoin  `protobuf:"bytes,3,opt,name=price,proto3" json:"price" yaml:"price"`
	CreatedAt      int64          `protobuf:"varint,4,opt,name=created_at,json=createdAt,proto3" json:"state" yaml:"created_at"`
	ResourcesOffer ResourcesOffer `` /* 144-byte string literal not displayed */
}

Bid stores BidID, state of bid and price

func (*Bid) Descriptor

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

func (*Bid) Filters

func (o *Bid) Filters(filters BidFilters, stateVal Bid_State) bool

Filters returns whether bid filters valid or not

func (*Bid) GetCreatedAt

func (m *Bid) GetCreatedAt() int64

func (*Bid) GetID

func (m *Bid) GetID() v1.BidID

func (*Bid) GetPrice

func (m *Bid) GetPrice() types.DecCoin

func (*Bid) GetResourcesOffer

func (m *Bid) GetResourcesOffer() ResourcesOffer

func (*Bid) GetState

func (m *Bid) GetState() Bid_State

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 (o *Bid) String() string

String implements the Stringer interface for a Bid object.

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 BidFilters

type BidFilters struct {
	Owner    string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner" yaml:"owner"`
	DSeq     uint64 `protobuf:"varint,2,opt,name=dseq,proto3" json:"dseq" yaml:"dseq"`
	GSeq     uint32 `protobuf:"varint,3,opt,name=gseq,proto3" json:"gseq" yaml:"gseq"`
	OSeq     uint32 `protobuf:"varint,4,opt,name=oseq,proto3" json:"oseq" yaml:"oseq"`
	Provider string `protobuf:"bytes,5,opt,name=provider,proto3" json:"provider" yaml:"provider"`
	State    string `protobuf:"bytes,6,opt,name=state,proto3" json:"state" yaml:"state"`
}

BidFilters defines flags for bid list filter

func (*BidFilters) Accept

func (filters *BidFilters) Accept(obj Bid, stateVal Bid_State) bool

Accept returns whether bid filters valid or not

func (*BidFilters) Descriptor

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

func (*BidFilters) GetDSeq

func (m *BidFilters) GetDSeq() uint64

func (*BidFilters) GetGSeq

func (m *BidFilters) GetGSeq() uint32

func (*BidFilters) GetOSeq

func (m *BidFilters) GetOSeq() uint32

func (*BidFilters) GetOwner

func (m *BidFilters) GetOwner() string

func (*BidFilters) GetProvider

func (m *BidFilters) GetProvider() string

func (*BidFilters) GetState

func (m *BidFilters) GetState() string

func (*BidFilters) Marshal

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

func (*BidFilters) MarshalTo

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

func (*BidFilters) MarshalToSizedBuffer

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

func (*BidFilters) ProtoMessage

func (*BidFilters) ProtoMessage()

func (*BidFilters) Reset

func (m *BidFilters) Reset()

func (*BidFilters) Size

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

func (*BidFilters) String

func (m *BidFilters) String() string

func (*BidFilters) Unmarshal

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

func (*BidFilters) XXX_DiscardUnknown

func (m *BidFilters) XXX_DiscardUnknown()

func (*BidFilters) XXX_Marshal

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

func (*BidFilters) XXX_Merge

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

func (*BidFilters) XXX_Size

func (m *BidFilters) XXX_Size() int

func (*BidFilters) XXX_Unmarshal

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

type Bid_State

type Bid_State int32

BidState is an enum which refers to state of bid

const (
	// Prefix should start with 0 in enum. So declaring dummy state
	BidStateInvalid Bid_State = 0
	// BidOpen denotes state for bid open
	BidOpen Bid_State = 1
	// BidMatched denotes state for bid open
	BidActive Bid_State = 2
	// BidLost denotes state for bid lost
	BidLost Bid_State = 3
	// BidClosed denotes state for bid closed
	BidClosed Bid_State = 4
)

func (Bid_State) EnumDescriptor

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

func (Bid_State) String

func (x Bid_State) String() string

type Bids

type Bids []Bid

Bids is a collection of Bid

func (Bids) String

func (b Bids) String() string

String implements the Stringer interface for a Bids object.

type GenesisState

type GenesisState struct {
	Params Params                               `protobuf:"bytes,1,opt,name=params,proto3" json:"params" yaml:"params"`
	Orders Orders                               `protobuf:"bytes,2,rep,name=orders,proto3,castrepeated=Orders" json:"orders" yaml:"orders"`
	Leases pkg_akt_dev_go_node_market_v1.Leases `protobuf:"bytes,3,rep,name=leases,proto3,castrepeated=pkg.akt.dev/go/node/market/v1.Leases" json:"leases" yaml:"leases"`
	Bids   Bids                                 `protobuf:"bytes,4,rep,name=bids,proto3,castrepeated=Bids" json:"bids" yaml:"bids"`
}

GenesisState defines the basic genesis state used by market module

func (*GenesisState) Descriptor

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

func (*GenesisState) GetBids

func (m *GenesisState) GetBids() Bids

func (*GenesisState) GetLeases

func (*GenesisState) GetOrders

func (m *GenesisState) GetOrders() Orders

func (*GenesisState) GetParams

func (m *GenesisState) GetParams() Params

func (*GenesisState) Marshal

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

func (*GenesisState) MarshalTo

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

func (*GenesisState) MarshalToSizedBuffer

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

func (*GenesisState) ProtoMessage

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset

func (m *GenesisState) Reset()

func (*GenesisState) Size

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

func (*GenesisState) String

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal

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

func (*GenesisState) XXX_DiscardUnknown

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal

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

func (*GenesisState) XXX_Merge

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

func (*GenesisState) XXX_Size

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal

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

type MsgClient

type MsgClient interface {
	// CreateBid defines a method to create a bid given proper inputs.
	CreateBid(ctx context.Context, in *MsgCreateBid, opts ...grpc.CallOption) (*MsgCreateBidResponse, error)
	// CloseBid defines a method to close a bid given proper inputs.
	CloseBid(ctx context.Context, in *MsgCloseBid, opts ...grpc.CallOption) (*MsgCloseBidResponse, error)
	// WithdrawLease withdraws accrued funds from the lease payment
	WithdrawLease(ctx context.Context, in *MsgWithdrawLease, opts ...grpc.CallOption) (*MsgWithdrawLeaseResponse, error)
	// CreateLease creates a new lease
	CreateLease(ctx context.Context, in *MsgCreateLease, opts ...grpc.CallOption) (*MsgCreateLeaseResponse, error)
	// CloseLease defines a method to close an order given proper inputs.
	CloseLease(ctx context.Context, in *MsgCloseLease, opts ...grpc.CallOption) (*MsgCloseLeaseResponse, error)
	// UpdateParams defines a governance operation for updating the x/market module
	// parameters. The authority is hard-coded to the x/gov module account.
	//
	// Since: akash v1.0.0
	UpdateParams(ctx context.Context, in *MsgUpdateParams, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, error)
}

MsgClient is the client API for Msg service.

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

func NewMsgClient

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgCloseBid

type MsgCloseBid struct {
	ID v1.BidID `protobuf:"bytes,1,opt,name=id,proto3" json:"id" yaml:"id"`
}

MsgCloseBid defines an SDK message for closing bid

func NewMsgCloseBid

func NewMsgCloseBid(id v1.BidID) *MsgCloseBid

NewMsgCloseBid creates a new MsgCloseBid instance

func (*MsgCloseBid) Descriptor

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

func (*MsgCloseBid) GetID

func (m *MsgCloseBid) GetID() v1.BidID

func (*MsgCloseBid) GetSignBytes deprecated

func (msg *MsgCloseBid) GetSignBytes() []byte

GetSignBytes encodes the message for signing

Deprecated: GetSignBytes is deprecated

func (*MsgCloseBid) GetSigners

func (msg *MsgCloseBid) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required

func (*MsgCloseBid) Marshal

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

func (*MsgCloseBid) MarshalTo

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

func (*MsgCloseBid) MarshalToSizedBuffer

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

func (*MsgCloseBid) ProtoMessage

func (*MsgCloseBid) ProtoMessage()

func (*MsgCloseBid) Reset

func (m *MsgCloseBid) Reset()

func (*MsgCloseBid) Route deprecated

func (msg *MsgCloseBid) Route() string

Route implements the sdk.Msg interface

Deprecated: Route is deprecated

func (*MsgCloseBid) Size

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

func (*MsgCloseBid) String

func (m *MsgCloseBid) String() string

func (*MsgCloseBid) Type

func (msg *MsgCloseBid) Type() string

Type implements the sdk.Msg interface

func (*MsgCloseBid) Unmarshal

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

func (*MsgCloseBid) ValidateBasic

func (msg *MsgCloseBid) ValidateBasic() error

ValidateBasic method for MsgCloseBid

func (*MsgCloseBid) XXX_DiscardUnknown

func (m *MsgCloseBid) XXX_DiscardUnknown()

func (*MsgCloseBid) XXX_Marshal

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

func (*MsgCloseBid) XXX_Merge

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

func (*MsgCloseBid) XXX_Size

func (m *MsgCloseBid) XXX_Size() int

func (*MsgCloseBid) XXX_Unmarshal

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

type MsgCloseBidResponse

type MsgCloseBidResponse struct {
}

MsgCloseBidResponse defines the Msg/CloseBid response type.

func (*MsgCloseBidResponse) Descriptor

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

func (*MsgCloseBidResponse) Marshal

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

func (*MsgCloseBidResponse) MarshalTo

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

func (*MsgCloseBidResponse) MarshalToSizedBuffer

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

func (*MsgCloseBidResponse) ProtoMessage

func (*MsgCloseBidResponse) ProtoMessage()

func (*MsgCloseBidResponse) Reset

func (m *MsgCloseBidResponse) Reset()

func (*MsgCloseBidResponse) Size

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

func (*MsgCloseBidResponse) String

func (m *MsgCloseBidResponse) String() string

func (*MsgCloseBidResponse) Unmarshal

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

func (*MsgCloseBidResponse) XXX_DiscardUnknown

func (m *MsgCloseBidResponse) XXX_DiscardUnknown()

func (*MsgCloseBidResponse) XXX_Marshal

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

func (*MsgCloseBidResponse) XXX_Merge

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

func (*MsgCloseBidResponse) XXX_Size

func (m *MsgCloseBidResponse) XXX_Size() int

func (*MsgCloseBidResponse) XXX_Unmarshal

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

type MsgCloseLease

type MsgCloseLease struct {
	ID v1.LeaseID `protobuf:"bytes,1,opt,name=lease_id,json=leaseId,proto3" json:"id" yaml:"id"`
}

MsgCloseLease defines an SDK message for closing order

func NewMsgCloseLease

func NewMsgCloseLease(id v1.LeaseID) *MsgCloseLease

NewMsgCloseLease creates a new MsgCloseLease instance

func (*MsgCloseLease) Descriptor

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

func (*MsgCloseLease) GetID

func (m *MsgCloseLease) GetID() v1.LeaseID

func (*MsgCloseLease) GetSignBytes deprecated

func (msg *MsgCloseLease) GetSignBytes() []byte

GetSignBytes encodes the message for signing

Deprecated: GetSignBytes is deprecated

func (*MsgCloseLease) GetSigners

func (msg *MsgCloseLease) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required

func (*MsgCloseLease) Marshal

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

func (*MsgCloseLease) MarshalTo

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

func (*MsgCloseLease) MarshalToSizedBuffer

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

func (*MsgCloseLease) ProtoMessage

func (*MsgCloseLease) ProtoMessage()

func (*MsgCloseLease) Reset

func (m *MsgCloseLease) Reset()

func (*MsgCloseLease) Route deprecated

func (msg *MsgCloseLease) Route() string

Route implements the sdk.Msg interface

Deprecated: Route is deprecated

func (*MsgCloseLease) Size

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

func (*MsgCloseLease) String

func (m *MsgCloseLease) String() string

func (*MsgCloseLease) Type

func (msg *MsgCloseLease) Type() string

Type implements the sdk.Msg interface

func (*MsgCloseLease) Unmarshal

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

func (*MsgCloseLease) ValidateBasic

func (msg *MsgCloseLease) ValidateBasic() error

ValidateBasic method for MsgCloseLease

func (*MsgCloseLease) XXX_DiscardUnknown

func (m *MsgCloseLease) XXX_DiscardUnknown()

func (*MsgCloseLease) XXX_Marshal

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

func (*MsgCloseLease) XXX_Merge

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

func (*MsgCloseLease) XXX_Size

func (m *MsgCloseLease) XXX_Size() int

func (*MsgCloseLease) XXX_Unmarshal

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

type MsgCloseLeaseResponse

type MsgCloseLeaseResponse struct {
}

MsgCloseLeaseResponse defines the Msg/CloseLease response type.

func (*MsgCloseLeaseResponse) Descriptor

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

func (*MsgCloseLeaseResponse) Marshal

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

func (*MsgCloseLeaseResponse) MarshalTo

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

func (*MsgCloseLeaseResponse) MarshalToSizedBuffer

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

func (*MsgCloseLeaseResponse) ProtoMessage

func (*MsgCloseLeaseResponse) ProtoMessage()

func (*MsgCloseLeaseResponse) Reset

func (m *MsgCloseLeaseResponse) Reset()

func (*MsgCloseLeaseResponse) Size

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

func (*MsgCloseLeaseResponse) String

func (m *MsgCloseLeaseResponse) String() string

func (*MsgCloseLeaseResponse) Unmarshal

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

func (*MsgCloseLeaseResponse) XXX_DiscardUnknown

func (m *MsgCloseLeaseResponse) XXX_DiscardUnknown()

func (*MsgCloseLeaseResponse) XXX_Marshal

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

func (*MsgCloseLeaseResponse) XXX_Merge

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

func (*MsgCloseLeaseResponse) XXX_Size

func (m *MsgCloseLeaseResponse) XXX_Size() int

func (*MsgCloseLeaseResponse) XXX_Unmarshal

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

type MsgCreateBid

type MsgCreateBid struct {
	OrderID        v1.OrderID     `protobuf:"bytes,1,opt,name=order_id,json=orderId,proto3" json:"order_id" yaml:"order_id"`
	Provider       string         `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider" yaml:"provider"`
	Price          types.DecCoin  `protobuf:"bytes,3,opt,name=price,proto3" json:"price" yaml:"price"`
	Deposit        types.Coin     `protobuf:"bytes,4,opt,name=deposit,proto3" json:"deposit" yaml:"deposit"`
	ResourcesOffer ResourcesOffer `` /* 144-byte string literal not displayed */
}

MsgCreateBid defines an SDK message for creating Bid

func NewMsgCreateBid

func NewMsgCreateBid(id v1.OrderID, provider sdk.AccAddress, price sdk.DecCoin, deposit sdk.Coin, roffer ResourcesOffer) *MsgCreateBid

NewMsgCreateBid creates a new MsgCreateBid instance

func (*MsgCreateBid) Descriptor

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

func (*MsgCreateBid) GetDeposit

func (m *MsgCreateBid) GetDeposit() types.Coin

func (*MsgCreateBid) GetOrderID

func (m *MsgCreateBid) GetOrderID() v1.OrderID

func (*MsgCreateBid) GetPrice

func (m *MsgCreateBid) GetPrice() types.DecCoin

func (*MsgCreateBid) GetProvider

func (m *MsgCreateBid) GetProvider() string

func (*MsgCreateBid) GetResourcesOffer

func (m *MsgCreateBid) GetResourcesOffer() ResourcesOffer

func (*MsgCreateBid) GetSignBytes deprecated

func (msg *MsgCreateBid) GetSignBytes() []byte

GetSignBytes encodes the message for signing

Deprecated: GetSignBytes is deprecated

func (*MsgCreateBid) GetSigners

func (msg *MsgCreateBid) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required

func (*MsgCreateBid) Marshal

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

func (*MsgCreateBid) MarshalTo

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

func (*MsgCreateBid) MarshalToSizedBuffer

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

func (*MsgCreateBid) ProtoMessage

func (*MsgCreateBid) ProtoMessage()

func (*MsgCreateBid) Reset

func (m *MsgCreateBid) Reset()

func (*MsgCreateBid) Route deprecated

func (msg *MsgCreateBid) Route() string

Route implements the sdk.Msg interface

Deprecated: Route is deprecated

func (*MsgCreateBid) Size

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

func (*MsgCreateBid) String

func (m *MsgCreateBid) String() string

func (*MsgCreateBid) Type

func (msg *MsgCreateBid) Type() string

Type implements the sdk.Msg interface

func (*MsgCreateBid) Unmarshal

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

func (*MsgCreateBid) ValidateBasic

func (msg *MsgCreateBid) ValidateBasic() error

ValidateBasic does basic validation of provider and order

func (*MsgCreateBid) XXX_DiscardUnknown

func (m *MsgCreateBid) XXX_DiscardUnknown()

func (*MsgCreateBid) XXX_Marshal

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

func (*MsgCreateBid) XXX_Merge

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

func (*MsgCreateBid) XXX_Size

func (m *MsgCreateBid) XXX_Size() int

func (*MsgCreateBid) XXX_Unmarshal

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

type MsgCreateBidResponse

type MsgCreateBidResponse struct {
}

MsgCreateBidResponse defines the Msg/CreateBid response type.

func (*MsgCreateBidResponse) Descriptor

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

func (*MsgCreateBidResponse) Marshal

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

func (*MsgCreateBidResponse) MarshalTo

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

func (*MsgCreateBidResponse) MarshalToSizedBuffer

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

func (*MsgCreateBidResponse) ProtoMessage

func (*MsgCreateBidResponse) ProtoMessage()

func (*MsgCreateBidResponse) Reset

func (m *MsgCreateBidResponse) Reset()

func (*MsgCreateBidResponse) Size

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

func (*MsgCreateBidResponse) String

func (m *MsgCreateBidResponse) String() string

func (*MsgCreateBidResponse) Unmarshal

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

func (*MsgCreateBidResponse) XXX_DiscardUnknown

func (m *MsgCreateBidResponse) XXX_DiscardUnknown()

func (*MsgCreateBidResponse) XXX_Marshal

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

func (*MsgCreateBidResponse) XXX_Merge

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

func (*MsgCreateBidResponse) XXX_Size

func (m *MsgCreateBidResponse) XXX_Size() int

func (*MsgCreateBidResponse) XXX_Unmarshal

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

type MsgCreateLease

type MsgCreateLease struct {
	BidID v1.BidID `protobuf:"bytes,1,opt,name=bid_id,json=bidId,proto3" json:"id" yaml:"id"`
}

MsgCreateLease is sent to create a lease

func NewMsgCreateLease

func NewMsgCreateLease(id v1.BidID) *MsgCreateLease

NewMsgCreateLease creates a new MsgCreateLease instance

func (*MsgCreateLease) Descriptor

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

func (*MsgCreateLease) GetBidID

func (m *MsgCreateLease) GetBidID() v1.BidID

func (*MsgCreateLease) GetSignBytes

func (msg *MsgCreateLease) GetSignBytes() []byte

GetSignBytes encodes the message for signing

func (*MsgCreateLease) GetSigners

func (msg *MsgCreateLease) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required

func (*MsgCreateLease) Marshal

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

func (*MsgCreateLease) MarshalTo

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

func (*MsgCreateLease) MarshalToSizedBuffer

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

func (*MsgCreateLease) ProtoMessage

func (*MsgCreateLease) ProtoMessage()

func (*MsgCreateLease) Reset

func (m *MsgCreateLease) Reset()

func (*MsgCreateLease) Route deprecated

func (msg *MsgCreateLease) Route() string

Route implements the sdk.Msg interface

Deprecated: Route is deprecated

func (*MsgCreateLease) Size

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

func (*MsgCreateLease) String

func (m *MsgCreateLease) String() string

func (*MsgCreateLease) Type

func (msg *MsgCreateLease) Type() string

Type implements the sdk.Msg interface

func (*MsgCreateLease) Unmarshal

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

func (*MsgCreateLease) ValidateBasic

func (msg *MsgCreateLease) ValidateBasic() error

ValidateBasic method for MsgCreateLease

func (*MsgCreateLease) XXX_DiscardUnknown

func (m *MsgCreateLease) XXX_DiscardUnknown()

func (*MsgCreateLease) XXX_Marshal

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

func (*MsgCreateLease) XXX_Merge

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

func (*MsgCreateLease) XXX_Size

func (m *MsgCreateLease) XXX_Size() int

func (*MsgCreateLease) XXX_Unmarshal

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

type MsgCreateLeaseResponse

type MsgCreateLeaseResponse struct {
}

MsgCreateLeaseResponse is the response from creating a lease

func (*MsgCreateLeaseResponse) Descriptor

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

func (*MsgCreateLeaseResponse) Marshal

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

func (*MsgCreateLeaseResponse) MarshalTo

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

func (*MsgCreateLeaseResponse) MarshalToSizedBuffer

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

func (*MsgCreateLeaseResponse) ProtoMessage

func (*MsgCreateLeaseResponse) ProtoMessage()

func (*MsgCreateLeaseResponse) Reset

func (m *MsgCreateLeaseResponse) Reset()

func (*MsgCreateLeaseResponse) Size

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

func (*MsgCreateLeaseResponse) String

func (m *MsgCreateLeaseResponse) String() string

func (*MsgCreateLeaseResponse) Unmarshal

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

func (*MsgCreateLeaseResponse) XXX_DiscardUnknown

func (m *MsgCreateLeaseResponse) XXX_DiscardUnknown()

func (*MsgCreateLeaseResponse) XXX_Marshal

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

func (*MsgCreateLeaseResponse) XXX_Merge

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

func (*MsgCreateLeaseResponse) XXX_Size

func (m *MsgCreateLeaseResponse) XXX_Size() int

func (*MsgCreateLeaseResponse) XXX_Unmarshal

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

type MsgServer

type MsgServer interface {
	// CreateBid defines a method to create a bid given proper inputs.
	CreateBid(context.Context, *MsgCreateBid) (*MsgCreateBidResponse, error)
	// CloseBid defines a method to close a bid given proper inputs.
	CloseBid(context.Context, *MsgCloseBid) (*MsgCloseBidResponse, error)
	// WithdrawLease withdraws accrued funds from the lease payment
	WithdrawLease(context.Context, *MsgWithdrawLease) (*MsgWithdrawLeaseResponse, error)
	// CreateLease creates a new lease
	CreateLease(context.Context, *MsgCreateLease) (*MsgCreateLeaseResponse, error)
	// CloseLease defines a method to close an order given proper inputs.
	CloseLease(context.Context, *MsgCloseLease) (*MsgCloseLeaseResponse, error)
	// UpdateParams defines a governance operation for updating the x/market module
	// parameters. The authority is hard-coded to the x/gov module account.
	//
	// Since: akash v1.0.0
	UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
}

MsgServer is the server API for Msg service.

type MsgUpdateParams

type MsgUpdateParams struct {
	// authority is the address of the governance account.
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// params defines the x/deployment parameters to update.
	//
	// NOTE: All parameters must be supplied.
	Params Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

MsgUpdateParams is the Msg/UpdateParams request type.

Since: akash v1.0.0

func (*MsgUpdateParams) Descriptor

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

func (*MsgUpdateParams) GetAuthority

func (m *MsgUpdateParams) GetAuthority() string

func (*MsgUpdateParams) GetParams

func (m *MsgUpdateParams) GetParams() Params

func (*MsgUpdateParams) GetSignBytes deprecated

func (msg *MsgUpdateParams) GetSignBytes() []byte

GetSignBytes encodes the message for signing

Deprecated: GetSignBytes is deprecated

func (*MsgUpdateParams) GetSigners

func (msg *MsgUpdateParams) GetSigners() []sdk.AccAddress

GetSigners returns the expected signers for a MsgUpdateParams message.

func (*MsgUpdateParams) Marshal

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

func (*MsgUpdateParams) MarshalTo

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

func (*MsgUpdateParams) MarshalToSizedBuffer

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

func (*MsgUpdateParams) ProtoMessage

func (*MsgUpdateParams) ProtoMessage()

func (*MsgUpdateParams) Reset

func (m *MsgUpdateParams) Reset()

func (*MsgUpdateParams) Route deprecated

func (msg *MsgUpdateParams) Route() string

Route implements the sdk.Msg interface

Deprecated: Route is deprecated

func (*MsgUpdateParams) Size

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

func (*MsgUpdateParams) String

func (m *MsgUpdateParams) String() string

func (*MsgUpdateParams) Type

func (msg *MsgUpdateParams) Type() string

Type implements the sdk.Msg interface

func (*MsgUpdateParams) Unmarshal

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

func (*MsgUpdateParams) ValidateBasic

func (msg *MsgUpdateParams) ValidateBasic() error

ValidateBasic does a sanity check on the provided data.

func (*MsgUpdateParams) XXX_DiscardUnknown

func (m *MsgUpdateParams) XXX_DiscardUnknown()

func (*MsgUpdateParams) XXX_Marshal

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

func (*MsgUpdateParams) XXX_Merge

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

func (*MsgUpdateParams) XXX_Size

func (m *MsgUpdateParams) XXX_Size() int

func (*MsgUpdateParams) XXX_Unmarshal

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

type MsgUpdateParamsResponse

type MsgUpdateParamsResponse struct {
}

MsgUpdateParamsResponse defines the response structure for executing a MsgUpdateParams message.

Since: akash v1.0.0

func (*MsgUpdateParamsResponse) Descriptor

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

func (*MsgUpdateParamsResponse) Marshal

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

func (*MsgUpdateParamsResponse) MarshalTo

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

func (*MsgUpdateParamsResponse) MarshalToSizedBuffer

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

func (*MsgUpdateParamsResponse) ProtoMessage

func (*MsgUpdateParamsResponse) ProtoMessage()

func (*MsgUpdateParamsResponse) Reset

func (m *MsgUpdateParamsResponse) Reset()

func (*MsgUpdateParamsResponse) Size

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

func (*MsgUpdateParamsResponse) String

func (m *MsgUpdateParamsResponse) String() string

func (*MsgUpdateParamsResponse) Unmarshal

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

func (*MsgUpdateParamsResponse) XXX_DiscardUnknown

func (m *MsgUpdateParamsResponse) XXX_DiscardUnknown()

func (*MsgUpdateParamsResponse) XXX_Marshal

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

func (*MsgUpdateParamsResponse) XXX_Merge

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

func (*MsgUpdateParamsResponse) XXX_Size

func (m *MsgUpdateParamsResponse) XXX_Size() int

func (*MsgUpdateParamsResponse) XXX_Unmarshal

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

type MsgWithdrawLease

type MsgWithdrawLease struct {
	ID v1.LeaseID `protobuf:"bytes,1,opt,name=bid_id,json=bidId,proto3" json:"id" yaml:"id"`
}

MsgWithdrawLease defines an SDK message for withdrawing lease funds

func NewMsgWithdrawLease

func NewMsgWithdrawLease(id v1.LeaseID) *MsgWithdrawLease

NewMsgWithdrawLease creates a new MsgWithdrawLease instance

func (*MsgWithdrawLease) Descriptor

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

func (*MsgWithdrawLease) GetID

func (m *MsgWithdrawLease) GetID() v1.LeaseID

func (*MsgWithdrawLease) GetSignBytes deprecated

func (msg *MsgWithdrawLease) GetSignBytes() []byte

GetSignBytes encodes the message for signing

Deprecated: GetSignBytes is deprecated

func (*MsgWithdrawLease) GetSigners

func (msg *MsgWithdrawLease) GetSigners() []sdk.AccAddress

GetSigners defines whose signature is required

func (*MsgWithdrawLease) Marshal

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

func (*MsgWithdrawLease) MarshalTo

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

func (*MsgWithdrawLease) MarshalToSizedBuffer

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

func (*MsgWithdrawLease) ProtoMessage

func (*MsgWithdrawLease) ProtoMessage()

func (*MsgWithdrawLease) Reset

func (m *MsgWithdrawLease) Reset()

func (*MsgWithdrawLease) Route deprecated

func (msg *MsgWithdrawLease) Route() string

Route implements the sdk.Msg interface

Deprecated: Route is deprecated

func (*MsgWithdrawLease) Size

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

func (*MsgWithdrawLease) String

func (m *MsgWithdrawLease) String() string

func (*MsgWithdrawLease) Type

func (msg *MsgWithdrawLease) Type() string

Type implements the sdk.Msg interface

func (*MsgWithdrawLease) Unmarshal

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

func (*MsgWithdrawLease) ValidateBasic

func (msg *MsgWithdrawLease) ValidateBasic() error

ValidateBasic does basic validation of provider and order

func (*MsgWithdrawLease) XXX_DiscardUnknown

func (m *MsgWithdrawLease) XXX_DiscardUnknown()

func (*MsgWithdrawLease) XXX_Marshal

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

func (*MsgWithdrawLease) XXX_Merge

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

func (*MsgWithdrawLease) XXX_Size

func (m *MsgWithdrawLease) XXX_Size() int

func (*MsgWithdrawLease) XXX_Unmarshal

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

type MsgWithdrawLeaseResponse

type MsgWithdrawLeaseResponse struct {
}

MsgWithdrawLeaseResponse defines the Msg/WithdrawLease response type.

func (*MsgWithdrawLeaseResponse) Descriptor

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

func (*MsgWithdrawLeaseResponse) Marshal

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

func (*MsgWithdrawLeaseResponse) MarshalTo

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

func (*MsgWithdrawLeaseResponse) MarshalToSizedBuffer

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

func (*MsgWithdrawLeaseResponse) ProtoMessage

func (*MsgWithdrawLeaseResponse) ProtoMessage()

func (*MsgWithdrawLeaseResponse) Reset

func (m *MsgWithdrawLeaseResponse) Reset()

func (*MsgWithdrawLeaseResponse) Size

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

func (*MsgWithdrawLeaseResponse) String

func (m *MsgWithdrawLeaseResponse) String() string

func (*MsgWithdrawLeaseResponse) Unmarshal

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

func (*MsgWithdrawLeaseResponse) XXX_DiscardUnknown

func (m *MsgWithdrawLeaseResponse) XXX_DiscardUnknown()

func (*MsgWithdrawLeaseResponse) XXX_Marshal

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

func (*MsgWithdrawLeaseResponse) XXX_Merge

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

func (*MsgWithdrawLeaseResponse) XXX_Size

func (m *MsgWithdrawLeaseResponse) XXX_Size() int

func (*MsgWithdrawLeaseResponse) XXX_Unmarshal

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

type Order

type Order struct {
	ID        v1.OrderID        `protobuf:"bytes,1,opt,name=id,proto3" json:"id" yaml:"id"`
	State     Order_State       `protobuf:"varint,2,opt,name=state,proto3,enum=akash.market.v1beta5.Order_State" json:"state" yaml:"state"`
	Spec      v1beta4.GroupSpec `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec" yaml:"spec"`
	CreatedAt int64             `protobuf:"varint,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
}

Order stores orderID, state of order and other details

func (*Order) Descriptor

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

func (*Order) Filters

func (o *Order) Filters(filters OrderFilters, stateVal Order_State) bool

Filters returns whether order filters valid or not

func (*Order) GetCreatedAt

func (m *Order) GetCreatedAt() int64

func (*Order) GetID

func (m *Order) GetID() v1.OrderID

func (*Order) GetSpec

func (m *Order) GetSpec() v1beta4.GroupSpec

func (*Order) GetState

func (m *Order) GetState() Order_State

func (*Order) Marshal

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

func (*Order) MarshalTo

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

func (*Order) MarshalToSizedBuffer

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

func (*Order) MatchAttributes

func (o *Order) MatchAttributes(attrs attr.Attributes) bool

MatchAttributes method compares provided attributes with specific order attributes

func (*Order) MatchRequirements

func (o *Order) MatchRequirements(prov []atypes.AuditedProvider) bool

MatchRequirements method compares provided attributes with specific order attributes

func (*Order) MatchResourcesRequirements

func (o *Order) MatchResourcesRequirements(attr attr.Attributes) bool

MatchResourcesRequirements method compares provider capabilities with specific order resources attributes

func (*Order) Price

func (o *Order) Price() sdk.DecCoin

Price method returns price of specific order

func (*Order) ProtoMessage

func (*Order) ProtoMessage()

func (*Order) Reset

func (m *Order) Reset()

func (*Order) Size

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

func (*Order) String

func (o *Order) String() string

String implements the Stringer interface for a Order object.

func (*Order) Unmarshal

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

func (*Order) ValidateCanBid

func (o *Order) ValidateCanBid() error

ValidateCanBid method validates whether order is open or not and returns error if not

func (*Order) ValidateInactive

func (o *Order) ValidateInactive() error

ValidateInactive method validates whether order is open or not and returns error if not

func (*Order) XXX_DiscardUnknown

func (m *Order) XXX_DiscardUnknown()

func (*Order) XXX_Marshal

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

func (*Order) XXX_Merge

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

func (*Order) XXX_Size

func (m *Order) XXX_Size() int

func (*Order) XXX_Unmarshal

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

type OrderFilters

type OrderFilters struct {
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner" yaml:"owner"`
	DSeq  uint64 `protobuf:"varint,2,opt,name=dseq,proto3" json:"dseq" yaml:"dseq"`
	GSeq  uint32 `protobuf:"varint,3,opt,name=gseq,proto3" json:"gseq" yaml:"gseq"`
	OSeq  uint32 `protobuf:"varint,4,opt,name=oseq,proto3" json:"oseq" yaml:"oseq"`
	State string `protobuf:"bytes,5,opt,name=state,proto3" json:"state" yaml:"state"`
}

OrderFilters defines flags for order list filter

func (*OrderFilters) Accept

func (filters *OrderFilters) Accept(obj Order, stateVal Order_State) bool

Accept returns whether order filters valid or not

func (*OrderFilters) Descriptor

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

func (*OrderFilters) GetDSeq

func (m *OrderFilters) GetDSeq() uint64

func (*OrderFilters) GetGSeq

func (m *OrderFilters) GetGSeq() uint32

func (*OrderFilters) GetOSeq

func (m *OrderFilters) GetOSeq() uint32

func (*OrderFilters) GetOwner

func (m *OrderFilters) GetOwner() string

func (*OrderFilters) GetState

func (m *OrderFilters) GetState() string

func (*OrderFilters) Marshal

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

func (*OrderFilters) MarshalTo

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

func (*OrderFilters) MarshalToSizedBuffer

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

func (*OrderFilters) ProtoMessage

func (*OrderFilters) ProtoMessage()

func (*OrderFilters) Reset

func (m *OrderFilters) Reset()

func (*OrderFilters) Size

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

func (*OrderFilters) String

func (m *OrderFilters) String() string

func (*OrderFilters) Unmarshal

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

func (*OrderFilters) XXX_DiscardUnknown

func (m *OrderFilters) XXX_DiscardUnknown()

func (*OrderFilters) XXX_Marshal

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

func (*OrderFilters) XXX_Merge

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

func (*OrderFilters) XXX_Size

func (m *OrderFilters) XXX_Size() int

func (*OrderFilters) XXX_Unmarshal

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

type Order_State

type Order_State int32

State is an enum which refers to state of order

const (
	// Prefix should start with 0 in enum. So declaring dummy state
	OrderStateInvalid Order_State = 0
	// OrderOpen denotes state for order open
	OrderOpen Order_State = 1
	// OrderMatched denotes state for order matched
	OrderActive Order_State = 2
	// OrderClosed denotes state for order lost
	OrderClosed Order_State = 3
)

func (Order_State) EnumDescriptor

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

func (Order_State) String

func (x Order_State) String() string

type Orders

type Orders []Order

Orders is a collection of Order

func (Orders) String

func (o Orders) String() string

String implements the Stringer interface for a Orders object.

type Params

type Params struct {
	BidMinDeposit types.Coin `protobuf:"bytes,1,opt,name=bid_min_deposit,json=bidMinDeposit,proto3" json:"bid_min_deposit" yaml:"bid_min_deposit"`
	OrderMaxBids  uint32     `protobuf:"varint,2,opt,name=order_max_bids,json=orderMaxBids,proto3" json:"order_max_bids" yaml:"order_max_bids"`
}

Params is the params for the x/market module

func DefaultParams

func DefaultParams() Params

func (*Params) Descriptor

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

func (*Params) GetBidMinDeposit

func (m *Params) GetBidMinDeposit() types.Coin

func (*Params) GetOrderMaxBids

func (m *Params) GetOrderMaxBids() uint32

func (*Params) Marshal

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

func (*Params) MarshalTo

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

func (*Params) MarshalToSizedBuffer

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

func (*Params) ParamSetPairs

func (p *Params) ParamSetPairs() paramtypes.ParamSetPairs

func (*Params) ProtoMessage

func (*Params) ProtoMessage()

func (*Params) Reset

func (m *Params) Reset()

func (*Params) Size

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

func (*Params) String

func (m *Params) String() string

func (*Params) Unmarshal

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

func (Params) Validate

func (p Params) Validate() error

func (*Params) XXX_DiscardUnknown

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal

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

func (*Params) XXX_Merge

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

func (*Params) XXX_Size

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal

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

type QueryBidRequest

type QueryBidRequest struct {
	ID v1.BidID `protobuf:"bytes,1,opt,name=id,proto3" json:"id"`
}

QueryBidRequest is request type for the Query/Bid RPC method

func (*QueryBidRequest) Descriptor

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

func (*QueryBidRequest) GetID

func (m *QueryBidRequest) GetID() v1.BidID

func (*QueryBidRequest) Marshal

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

func (*QueryBidRequest) MarshalTo

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

func (*QueryBidRequest) MarshalToSizedBuffer

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

func (*QueryBidRequest) ProtoMessage

func (*QueryBidRequest) ProtoMessage()

func (*QueryBidRequest) Reset

func (m *QueryBidRequest) Reset()

func (*QueryBidRequest) Size

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

func (*QueryBidRequest) String

func (m *QueryBidRequest) String() string

func (*QueryBidRequest) Unmarshal

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

func (*QueryBidRequest) XXX_DiscardUnknown

func (m *QueryBidRequest) XXX_DiscardUnknown()

func (*QueryBidRequest) XXX_Marshal

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

func (*QueryBidRequest) XXX_Merge

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

func (*QueryBidRequest) XXX_Size

func (m *QueryBidRequest) XXX_Size() int

func (*QueryBidRequest) XXX_Unmarshal

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

type QueryBidResponse

type QueryBidResponse struct {
	Bid           Bid         `protobuf:"bytes,1,opt,name=bid,proto3" json:"bid"`
	EscrowAccount v11.Account `protobuf:"bytes,2,opt,name=escrow_account,json=escrowAccount,proto3" json:"escrow_account"`
}

QueryBidResponse is response type for the Query/Bid RPC method

func (*QueryBidResponse) Descriptor

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

func (*QueryBidResponse) GetBid

func (m *QueryBidResponse) GetBid() Bid

func (*QueryBidResponse) GetEscrowAccount

func (m *QueryBidResponse) GetEscrowAccount() v11.Account

func (*QueryBidResponse) Marshal

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

func (*QueryBidResponse) MarshalTo

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

func (*QueryBidResponse) MarshalToSizedBuffer

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

func (*QueryBidResponse) ProtoMessage

func (*QueryBidResponse) ProtoMessage()

func (*QueryBidResponse) Reset

func (m *QueryBidResponse) Reset()

func (*QueryBidResponse) Size

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

func (*QueryBidResponse) String

func (m *QueryBidResponse) String() string

func (*QueryBidResponse) Unmarshal

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

func (*QueryBidResponse) XXX_DiscardUnknown

func (m *QueryBidResponse) XXX_DiscardUnknown()

func (*QueryBidResponse) XXX_Marshal

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

func (*QueryBidResponse) XXX_Merge

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

func (*QueryBidResponse) XXX_Size

func (m *QueryBidResponse) XXX_Size() int

func (*QueryBidResponse) XXX_Unmarshal

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

type QueryBidsRequest

type QueryBidsRequest struct {
	Filters    BidFilters         `protobuf:"bytes,1,opt,name=filters,proto3" json:"filters"`
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryBidsRequest is request type for the Query/Bids RPC method

func (*QueryBidsRequest) Descriptor

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

func (*QueryBidsRequest) GetFilters

func (m *QueryBidsRequest) GetFilters() BidFilters

func (*QueryBidsRequest) GetPagination

func (m *QueryBidsRequest) GetPagination() *query.PageRequest

func (*QueryBidsRequest) Marshal

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

func (*QueryBidsRequest) MarshalTo

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

func (*QueryBidsRequest) MarshalToSizedBuffer

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

func (*QueryBidsRequest) ProtoMessage

func (*QueryBidsRequest) ProtoMessage()

func (*QueryBidsRequest) Reset

func (m *QueryBidsRequest) Reset()

func (*QueryBidsRequest) Size

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

func (*QueryBidsRequest) String

func (m *QueryBidsRequest) String() string

func (*QueryBidsRequest) Unmarshal

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

func (*QueryBidsRequest) XXX_DiscardUnknown

func (m *QueryBidsRequest) XXX_DiscardUnknown()

func (*QueryBidsRequest) XXX_Marshal

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

func (*QueryBidsRequest) XXX_Merge

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

func (*QueryBidsRequest) XXX_Size

func (m *QueryBidsRequest) XXX_Size() int

func (*QueryBidsRequest) XXX_Unmarshal

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

type QueryBidsResponse

type QueryBidsResponse struct {
	Bids       []QueryBidResponse  `protobuf:"bytes,1,rep,name=bids,proto3" json:"bids"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryBidsResponse is response type for the Query/Bids RPC method

func (*QueryBidsResponse) Descriptor

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

func (*QueryBidsResponse) GetBids

func (m *QueryBidsResponse) GetBids() []QueryBidResponse

func (*QueryBidsResponse) GetPagination

func (m *QueryBidsResponse) GetPagination() *query.PageResponse

func (*QueryBidsResponse) Marshal

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

func (*QueryBidsResponse) MarshalTo

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

func (*QueryBidsResponse) MarshalToSizedBuffer

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

func (*QueryBidsResponse) ProtoMessage

func (*QueryBidsResponse) ProtoMessage()

func (*QueryBidsResponse) Reset

func (m *QueryBidsResponse) Reset()

func (*QueryBidsResponse) Size

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

func (*QueryBidsResponse) String

func (m *QueryBidsResponse) String() string

func (*QueryBidsResponse) Unmarshal

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

func (*QueryBidsResponse) XXX_DiscardUnknown

func (m *QueryBidsResponse) XXX_DiscardUnknown()

func (*QueryBidsResponse) XXX_Marshal

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

func (*QueryBidsResponse) XXX_Merge

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

func (*QueryBidsResponse) XXX_Size

func (m *QueryBidsResponse) XXX_Size() int

func (*QueryBidsResponse) XXX_Unmarshal

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

type QueryClient

type QueryClient interface {
	// Orders queries orders with filters
	Orders(ctx context.Context, in *QueryOrdersRequest, opts ...grpc.CallOption) (*QueryOrdersResponse, error)
	// Order queries order details
	Order(ctx context.Context, in *QueryOrderRequest, opts ...grpc.CallOption) (*QueryOrderResponse, error)
	// Bids queries bids with filters
	Bids(ctx context.Context, in *QueryBidsRequest, opts ...grpc.CallOption) (*QueryBidsResponse, error)
	// Bid queries bid details
	Bid(ctx context.Context, in *QueryBidRequest, opts ...grpc.CallOption) (*QueryBidResponse, error)
	// Leases queries leases with filters
	Leases(ctx context.Context, in *QueryLeasesRequest, opts ...grpc.CallOption) (*QueryLeasesResponse, error)
	// Lease queries lease details
	Lease(ctx context.Context, in *QueryLeaseRequest, opts ...grpc.CallOption) (*QueryLeaseResponse, error)
	// Params returns the total set of minting parameters.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
}

QueryClient is the client API for Query service.

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

func NewQueryClient

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryLeaseRequest

type QueryLeaseRequest struct {
	ID v1.LeaseID `protobuf:"bytes,1,opt,name=id,proto3" json:"id"`
}

QueryLeaseRequest is request type for the Query/Lease RPC method

func (*QueryLeaseRequest) Descriptor

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

func (*QueryLeaseRequest) GetID

func (m *QueryLeaseRequest) GetID() v1.LeaseID

func (*QueryLeaseRequest) Marshal

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

func (*QueryLeaseRequest) MarshalTo

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

func (*QueryLeaseRequest) MarshalToSizedBuffer

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

func (*QueryLeaseRequest) ProtoMessage

func (*QueryLeaseRequest) ProtoMessage()

func (*QueryLeaseRequest) Reset

func (m *QueryLeaseRequest) Reset()

func (*QueryLeaseRequest) Size

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

func (*QueryLeaseRequest) String

func (m *QueryLeaseRequest) String() string

func (*QueryLeaseRequest) Unmarshal

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

func (*QueryLeaseRequest) XXX_DiscardUnknown

func (m *QueryLeaseRequest) XXX_DiscardUnknown()

func (*QueryLeaseRequest) XXX_Marshal

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

func (*QueryLeaseRequest) XXX_Merge

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

func (*QueryLeaseRequest) XXX_Size

func (m *QueryLeaseRequest) XXX_Size() int

func (*QueryLeaseRequest) XXX_Unmarshal

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

type QueryLeaseResponse

type QueryLeaseResponse struct {
	Lease         v1.Lease              `protobuf:"bytes,1,opt,name=lease,proto3" json:"lease"`
	EscrowPayment v11.FractionalPayment `protobuf:"bytes,2,opt,name=escrow_payment,json=escrowPayment,proto3" json:"escrow_payment"`
}

QueryLeaseResponse is response type for the Query/Lease RPC method

func (*QueryLeaseResponse) Descriptor

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

func (*QueryLeaseResponse) GetEscrowPayment

func (m *QueryLeaseResponse) GetEscrowPayment() v11.FractionalPayment

func (*QueryLeaseResponse) GetLease

func (m *QueryLeaseResponse) GetLease() v1.Lease

func (*QueryLeaseResponse) Marshal

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

func (*QueryLeaseResponse) MarshalTo

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

func (*QueryLeaseResponse) MarshalToSizedBuffer

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

func (*QueryLeaseResponse) ProtoMessage

func (*QueryLeaseResponse) ProtoMessage()

func (*QueryLeaseResponse) Reset

func (m *QueryLeaseResponse) Reset()

func (*QueryLeaseResponse) Size

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

func (*QueryLeaseResponse) String

func (m *QueryLeaseResponse) String() string

func (*QueryLeaseResponse) Unmarshal

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

func (*QueryLeaseResponse) XXX_DiscardUnknown

func (m *QueryLeaseResponse) XXX_DiscardUnknown()

func (*QueryLeaseResponse) XXX_Marshal

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

func (*QueryLeaseResponse) XXX_Merge

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

func (*QueryLeaseResponse) XXX_Size

func (m *QueryLeaseResponse) XXX_Size() int

func (*QueryLeaseResponse) XXX_Unmarshal

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

type QueryLeasesRequest

type QueryLeasesRequest struct {
	Filters    v1.LeaseFilters    `protobuf:"bytes,1,opt,name=filters,proto3" json:"filters"`
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryLeasesRequest is request type for the Query/Leases RPC method

func (*QueryLeasesRequest) Descriptor

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

func (*QueryLeasesRequest) GetFilters

func (m *QueryLeasesRequest) GetFilters() v1.LeaseFilters

func (*QueryLeasesRequest) GetPagination

func (m *QueryLeasesRequest) GetPagination() *query.PageRequest

func (*QueryLeasesRequest) Marshal

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

func (*QueryLeasesRequest) MarshalTo

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

func (*QueryLeasesRequest) MarshalToSizedBuffer

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

func (*QueryLeasesRequest) ProtoMessage

func (*QueryLeasesRequest) ProtoMessage()

func (*QueryLeasesRequest) Reset

func (m *QueryLeasesRequest) Reset()

func (*QueryLeasesRequest) Size

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

func (*QueryLeasesRequest) String

func (m *QueryLeasesRequest) String() string

func (*QueryLeasesRequest) Unmarshal

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

func (*QueryLeasesRequest) XXX_DiscardUnknown

func (m *QueryLeasesRequest) XXX_DiscardUnknown()

func (*QueryLeasesRequest) XXX_Marshal

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

func (*QueryLeasesRequest) XXX_Merge

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

func (*QueryLeasesRequest) XXX_Size

func (m *QueryLeasesRequest) XXX_Size() int

func (*QueryLeasesRequest) XXX_Unmarshal

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

type QueryLeasesResponse

type QueryLeasesResponse struct {
	Leases     []QueryLeaseResponse `protobuf:"bytes,1,rep,name=leases,proto3" json:"leases"`
	Pagination *query.PageResponse  `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryLeasesResponse is response type for the Query/Leases RPC method

func (*QueryLeasesResponse) Descriptor

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

func (*QueryLeasesResponse) GetLeases

func (m *QueryLeasesResponse) GetLeases() []QueryLeaseResponse

func (*QueryLeasesResponse) GetPagination

func (m *QueryLeasesResponse) GetPagination() *query.PageResponse

func (*QueryLeasesResponse) Marshal

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

func (*QueryLeasesResponse) MarshalTo

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

func (*QueryLeasesResponse) MarshalToSizedBuffer

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

func (*QueryLeasesResponse) ProtoMessage

func (*QueryLeasesResponse) ProtoMessage()

func (*QueryLeasesResponse) Reset

func (m *QueryLeasesResponse) Reset()

func (*QueryLeasesResponse) Size

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

func (*QueryLeasesResponse) String

func (m *QueryLeasesResponse) String() string

func (QueryLeasesResponse) TotalPriceAmount

func (m QueryLeasesResponse) TotalPriceAmount() sdk.Dec

func (*QueryLeasesResponse) Unmarshal

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

func (*QueryLeasesResponse) XXX_DiscardUnknown

func (m *QueryLeasesResponse) XXX_DiscardUnknown()

func (*QueryLeasesResponse) XXX_Marshal

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

func (*QueryLeasesResponse) XXX_Merge

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

func (*QueryLeasesResponse) XXX_Size

func (m *QueryLeasesResponse) XXX_Size() int

func (*QueryLeasesResponse) XXX_Unmarshal

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

type QueryOrderRequest

type QueryOrderRequest struct {
	ID v1.OrderID `protobuf:"bytes,1,opt,name=id,proto3" json:"id"`
}

QueryOrderRequest is request type for the Query/Order RPC method

func (*QueryOrderRequest) Descriptor

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

func (*QueryOrderRequest) GetID

func (m *QueryOrderRequest) GetID() v1.OrderID

func (*QueryOrderRequest) Marshal

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

func (*QueryOrderRequest) MarshalTo

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

func (*QueryOrderRequest) MarshalToSizedBuffer

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

func (*QueryOrderRequest) ProtoMessage

func (*QueryOrderRequest) ProtoMessage()

func (*QueryOrderRequest) Reset

func (m *QueryOrderRequest) Reset()

func (*QueryOrderRequest) Size

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

func (*QueryOrderRequest) String

func (m *QueryOrderRequest) String() string

func (*QueryOrderRequest) Unmarshal

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

func (*QueryOrderRequest) XXX_DiscardUnknown

func (m *QueryOrderRequest) XXX_DiscardUnknown()

func (*QueryOrderRequest) XXX_Marshal

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

func (*QueryOrderRequest) XXX_Merge

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

func (*QueryOrderRequest) XXX_Size

func (m *QueryOrderRequest) XXX_Size() int

func (*QueryOrderRequest) XXX_Unmarshal

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

type QueryOrderResponse

type QueryOrderResponse struct {
	Order Order `protobuf:"bytes,1,opt,name=order,proto3" json:"order"`
}

QueryOrderResponse is response type for the Query/Order RPC method

func (*QueryOrderResponse) Descriptor

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

func (*QueryOrderResponse) GetOrder

func (m *QueryOrderResponse) GetOrder() Order

func (*QueryOrderResponse) Marshal

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

func (*QueryOrderResponse) MarshalTo

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

func (*QueryOrderResponse) MarshalToSizedBuffer

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

func (*QueryOrderResponse) ProtoMessage

func (*QueryOrderResponse) ProtoMessage()

func (*QueryOrderResponse) Reset

func (m *QueryOrderResponse) Reset()

func (*QueryOrderResponse) Size

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

func (*QueryOrderResponse) String

func (m *QueryOrderResponse) String() string

func (*QueryOrderResponse) Unmarshal

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

func (*QueryOrderResponse) XXX_DiscardUnknown

func (m *QueryOrderResponse) XXX_DiscardUnknown()

func (*QueryOrderResponse) XXX_Marshal

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

func (*QueryOrderResponse) XXX_Merge

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

func (*QueryOrderResponse) XXX_Size

func (m *QueryOrderResponse) XXX_Size() int

func (*QueryOrderResponse) XXX_Unmarshal

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

type QueryOrdersRequest

type QueryOrdersRequest struct {
	Filters    OrderFilters       `protobuf:"bytes,1,opt,name=filters,proto3" json:"filters"`
	Pagination *query.PageRequest `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryOrdersRequest is request type for the Query/Orders RPC method

func (*QueryOrdersRequest) Descriptor

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

func (*QueryOrdersRequest) GetFilters

func (m *QueryOrdersRequest) GetFilters() OrderFilters

func (*QueryOrdersRequest) GetPagination

func (m *QueryOrdersRequest) GetPagination() *query.PageRequest

func (*QueryOrdersRequest) Marshal

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

func (*QueryOrdersRequest) MarshalTo

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

func (*QueryOrdersRequest) MarshalToSizedBuffer

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

func (*QueryOrdersRequest) ProtoMessage

func (*QueryOrdersRequest) ProtoMessage()

func (*QueryOrdersRequest) Reset

func (m *QueryOrdersRequest) Reset()

func (*QueryOrdersRequest) Size

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

func (*QueryOrdersRequest) String

func (m *QueryOrdersRequest) String() string

func (*QueryOrdersRequest) Unmarshal

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

func (*QueryOrdersRequest) XXX_DiscardUnknown

func (m *QueryOrdersRequest) XXX_DiscardUnknown()

func (*QueryOrdersRequest) XXX_Marshal

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

func (*QueryOrdersRequest) XXX_Merge

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

func (*QueryOrdersRequest) XXX_Size

func (m *QueryOrdersRequest) XXX_Size() int

func (*QueryOrdersRequest) XXX_Unmarshal

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

type QueryOrdersResponse

type QueryOrdersResponse struct {
	Orders     Orders              `protobuf:"bytes,1,rep,name=orders,proto3,castrepeated=Orders" json:"orders"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryOrdersResponse is response type for the Query/Orders RPC method

func (*QueryOrdersResponse) Descriptor

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

func (*QueryOrdersResponse) GetOrders

func (m *QueryOrdersResponse) GetOrders() Orders

func (*QueryOrdersResponse) GetPagination

func (m *QueryOrdersResponse) GetPagination() *query.PageResponse

func (*QueryOrdersResponse) Marshal

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

func (*QueryOrdersResponse) MarshalTo

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

func (*QueryOrdersResponse) MarshalToSizedBuffer

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

func (*QueryOrdersResponse) ProtoMessage

func (*QueryOrdersResponse) ProtoMessage()

func (*QueryOrdersResponse) Reset

func (m *QueryOrdersResponse) Reset()

func (*QueryOrdersResponse) Size

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

func (*QueryOrdersResponse) String

func (m *QueryOrdersResponse) String() string

func (*QueryOrdersResponse) Unmarshal

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

func (*QueryOrdersResponse) XXX_DiscardUnknown

func (m *QueryOrdersResponse) XXX_DiscardUnknown()

func (*QueryOrdersResponse) XXX_Marshal

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

func (*QueryOrdersResponse) XXX_Merge

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

func (*QueryOrdersResponse) XXX_Size

func (m *QueryOrdersResponse) XXX_Size() int

func (*QueryOrdersResponse) XXX_Unmarshal

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

type QueryParamsRequest

type QueryParamsRequest struct {
}

QueryParamsRequest is the request type for the Query/Params RPC method.

func (*QueryParamsRequest) Descriptor

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

func (*QueryParamsRequest) Marshal

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

func (*QueryParamsRequest) MarshalTo

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

func (*QueryParamsRequest) MarshalToSizedBuffer

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

func (*QueryParamsRequest) ProtoMessage

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size

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

func (*QueryParamsRequest) String

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal

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

func (*QueryParamsRequest) XXX_DiscardUnknown

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal

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

func (*QueryParamsRequest) XXX_Merge

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

func (*QueryParamsRequest) XXX_Size

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal

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

type QueryParamsResponse

type QueryParamsResponse struct {
	// params defines the parameters of the module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

QueryParamsResponse is the response type for the Query/Params RPC method.

func (*QueryParamsResponse) Descriptor

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

func (*QueryParamsResponse) GetParams

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal

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

func (*QueryParamsResponse) MarshalTo

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

func (*QueryParamsResponse) MarshalToSizedBuffer

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

func (*QueryParamsResponse) ProtoMessage

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size

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

func (*QueryParamsResponse) String

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal

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

func (*QueryParamsResponse) XXX_DiscardUnknown

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal

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

func (*QueryParamsResponse) XXX_Merge

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

func (*QueryParamsResponse) XXX_Size

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal

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

type QueryServer

type QueryServer interface {
	// Orders queries orders with filters
	Orders(context.Context, *QueryOrdersRequest) (*QueryOrdersResponse, error)
	// Order queries order details
	Order(context.Context, *QueryOrderRequest) (*QueryOrderResponse, error)
	// Bids queries bids with filters
	Bids(context.Context, *QueryBidsRequest) (*QueryBidsResponse, error)
	// Bid queries bid details
	Bid(context.Context, *QueryBidRequest) (*QueryBidResponse, error)
	// Leases queries leases with filters
	Leases(context.Context, *QueryLeasesRequest) (*QueryLeasesResponse, error)
	// Lease queries lease details
	Lease(context.Context, *QueryLeaseRequest) (*QueryLeaseResponse, error)
	// Params returns the total set of minting parameters.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
}

QueryServer is the server API for Query service.

type ResourceOffer

type ResourceOffer struct {
	Resources v1beta4.Resources `protobuf:"bytes,1,opt,name=resources,proto3" json:"resources" yaml:"resources"`
	Count     uint32            `protobuf:"varint,2,opt,name=count,proto3" json:"count" yaml:"count"`
}

ResourceOffer describes resources that provider is offering for deployment

func (*ResourceOffer) Descriptor

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

func (*ResourceOffer) Dup

func (r *ResourceOffer) Dup() ResourceOffer

func (*ResourceOffer) Equal

func (this *ResourceOffer) Equal(that interface{}) bool

func (*ResourceOffer) GetCount

func (m *ResourceOffer) GetCount() uint32

func (*ResourceOffer) GetResources

func (m *ResourceOffer) GetResources() v1beta4.Resources

func (*ResourceOffer) Marshal

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

func (*ResourceOffer) MarshalTo

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

func (*ResourceOffer) MarshalToSizedBuffer

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

func (*ResourceOffer) ProtoMessage

func (*ResourceOffer) ProtoMessage()

func (*ResourceOffer) Reset

func (m *ResourceOffer) Reset()

func (*ResourceOffer) Size

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

func (*ResourceOffer) String

func (m *ResourceOffer) String() string

func (*ResourceOffer) Unmarshal

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

func (*ResourceOffer) XXX_DiscardUnknown

func (m *ResourceOffer) XXX_DiscardUnknown()

func (*ResourceOffer) XXX_Marshal

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

func (*ResourceOffer) XXX_Merge

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

func (*ResourceOffer) XXX_Size

func (m *ResourceOffer) XXX_Size() int

func (*ResourceOffer) XXX_Unmarshal

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

type ResourcesOffer

type ResourcesOffer []ResourceOffer

func ResourceOfferFromRU

func ResourceOfferFromRU(ru dtypes.ResourceUnits) ResourcesOffer

func (ResourcesOffer) Dup

func (ResourcesOffer) Len

func (s ResourcesOffer) Len() int

func (ResourcesOffer) Less

func (s ResourcesOffer) Less(i, j int) bool

func (ResourcesOffer) MatchGSpec

func (s ResourcesOffer) MatchGSpec(gspec dtypes.GroupSpec) bool

func (ResourcesOffer) Swap

func (s ResourcesOffer) Swap(i, j int)

type UnimplementedMsgServer

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) CloseBid

func (*UnimplementedMsgServer) CloseLease

func (*UnimplementedMsgServer) CreateBid

func (*UnimplementedMsgServer) CreateLease

func (*UnimplementedMsgServer) UpdateParams

func (*UnimplementedMsgServer) WithdrawLease

type UnimplementedQueryServer

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Bid

func (*UnimplementedQueryServer) Bids

func (*UnimplementedQueryServer) Lease

func (*UnimplementedQueryServer) Leases

func (*UnimplementedQueryServer) Order

func (*UnimplementedQueryServer) Orders

func (*UnimplementedQueryServer) Params

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL