v1beta5

package
v0.0.1-rc5 Latest Latest
Warning

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

Go to latest
Published: Aug 8, 2024 License: Apache-2.0 Imports: 40 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 (
	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 LeasePrefix

func LeasePrefix() []byte

func OrderPrefix

func OrderPrefix() []byte

func ParamKeyTable

func ParamKeyTable() paramtypes.KeyTable

func ParamsPrefix

func ParamsPrefix() []byte

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