v1beta3

package
v0.4.0-a3 Latest Latest
Warning

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

Go to latest
Published: Jun 24, 2026 License: Apache-2.0 Imports: 21 Imported by: 2

Documentation ¶

Index ¶

Constants ¶

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

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

	// RouterKey is the message route for deployment
	RouterKey = ModuleName
)
View Source
const (
	// ManifestVersionLength is the length of manifest version
	ManifestVersionLength = 32

	// DefaultOrderBiddingDuration is the default time limit for an Order being active.
	// After the duration, the Order is automatically closed.
	// ( 24(hr) * 3600(seconds per hour) ) / 7s-Block
	DefaultOrderBiddingDuration = int64(12342)

	// MaxBiddingDuration is roughly 30 days of block height
	MaxBiddingDuration = DefaultOrderBiddingDuration * int64(30)
)

Variables ¶

View Source
var (
	ErrInvalidLengthAuthz        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAuthz          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAuthz = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthDeployment        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDeployment          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDeployment = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthDeploymentmsg        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDeploymentmsg          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDeploymentmsg = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	// ErrNameDoesNotExist is the error when name does not exist
	ErrNameDoesNotExist = errors.New("Name does not exist")
	// ErrInvalidRequest is the error for invalid request
	ErrInvalidRequest = errors.New("Invalid request")
	// ErrDeploymentExists is the error when already deployment exists
	ErrDeploymentExists = errors.New("Deployment exists")
	// ErrDeploymentNotFound is the error when deployment not found
	ErrDeploymentNotFound = errors.New("Deployment not found")
	// ErrDeploymentClosed is the error when deployment is closed
	ErrDeploymentClosed = errors.New("Deployment closed")
	// ErrOwnerAcctMissing is the error for owner account missing
	ErrOwnerAcctMissing = errors.New("Owner account missing")
	// ErrInvalidGroups is the error when groups are empty
	ErrInvalidGroups = errors.New("Invalid groups")
	// ErrInvalidDeploymentID is the error for invalid deployment id
	ErrInvalidDeploymentID = errors.New("Invalid: deployment id")
	// ErrEmptyVersion is the error when version is empty
	ErrEmptyVersion = errors.New("Invalid: empty version")
	// ErrInvalidVersion is the error when version is invalid
	ErrInvalidVersion = errors.New("Invalid: deployment version")
	// ErrInternal is the error for internal error
	ErrInternal = errors.New("internal error")
	// ErrInvalidDeployment = is the error when deployment does not pass validation
	ErrInvalidDeployment = errors.New("Invalid deployment")
	// ErrInvalidGroupID is the error when already deployment exists
	ErrInvalidGroupID = errors.New("Deployment exists")
	// ErrGroupNotFound is the keeper's error for not finding a group
	ErrGroupNotFound = errors.New("Group not found")
	// ErrGroupClosed is the error when deployment is closed
	ErrGroupClosed = errors.New("Group already closed")
	// ErrGroupOpen is the error when deployment is closed
	ErrGroupOpen = errors.New("Group open")
	// ErrGroupPaused is the error when deployment is closed
	ErrGroupPaused = errors.New("Group paused")
	// ErrGroupNotOpen indicates the Group state has progressed beyond initial Open.
	ErrGroupNotOpen = errors.New("Group not open")
	// ErrGroupSpecInvalid indicates a GroupSpec has invalid configuration
	ErrGroupSpecInvalid = errors.New("GroupSpec invalid")

	// ErrInvalidDeposit indicates an invalid deposit
	ErrInvalidDeposit = errors.New("Deposit invalid")
	// ErrInvalidIDPath indicates an invalid ID path
	ErrInvalidIDPath = errors.New("ID path invalid")
	// ErrInvalidParam indicates an invalid chain parameter
	ErrInvalidParam = errors.New("parameter invalid")
	// ErrInvalidDeploymentDepositor indicates an invalid chain parameter
	ErrInvalidDeploymentDepositor = errors.New("invalid deployment depositor")
)
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 (
	ErrInvalidLengthGroup        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGroup          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthGroupid        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGroupid          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGroupid = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthGroupmsg        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGroupmsg          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGroupmsg = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthGroupspec        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGroupspec          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGroupspec = 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 (
	ErrInvalidLengthResourceunit        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowResourceunit          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupResourceunit = fmt.Errorf("proto: unexpected end of group")
)
View Source
var Deployment_State_name = map[int32]string{
	0: "invalid",
	1: "active",
	2: "closed",
}
View Source
var Deployment_State_value = map[string]int32{
	"invalid": 0,
	"active":  1,
	"closed":  2,
}
View Source
var Group_State_name = map[int32]string{
	0: "invalid",
	1: "open",
	2: "paused",
	3: "insufficient_funds",
	4: "closed",
}
View Source
var Group_State_value = map[string]int32{
	"invalid":            0,
	"open":               1,
	"paused":             2,
	"insufficient_funds": 3,
	"closed":             4,
}

Functions ¶

func DeploymentPrefix ¶

func DeploymentPrefix() []byte

func GroupPrefix ¶

func GroupPrefix() []byte

func ParamKeyTable ¶

func ParamKeyTable() paramtypes.KeyTable

Types ¶

type Deployment ¶

type Deployment struct {
	DeploymentID DeploymentID     `protobuf:"bytes,1,opt,name=deployment_id,json=deploymentId,proto3" json:"id" yaml:"id"`
	State        Deployment_State `protobuf:"varint,2,opt,name=state,proto3,enum=akash.deployment.v1beta3.Deployment_State" json:"state" yaml:"state"`
	Version      []byte           `protobuf:"bytes,3,opt,name=version,proto3" json:"version" yaml:"version"`
	CreatedAt    int64            `protobuf:"varint,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
}

Deployment stores deploymentID, state and version details

func (*Deployment) Descriptor ¶

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

func (*Deployment) GetCreatedAt ¶

func (m *Deployment) GetCreatedAt() int64

func (*Deployment) GetDeploymentID ¶

func (m *Deployment) GetDeploymentID() DeploymentID

func (*Deployment) GetState ¶

func (m *Deployment) GetState() Deployment_State

func (*Deployment) GetVersion ¶

func (m *Deployment) GetVersion() []byte

func (Deployment) ID ¶

func (obj Deployment) ID() DeploymentID

ID method returns DeploymentID details of specific deployment

func (*Deployment) Marshal ¶

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

func (*Deployment) MarshalTo ¶

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

func (*Deployment) MarshalToSizedBuffer ¶

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

func (*Deployment) ProtoMessage ¶

func (*Deployment) ProtoMessage()

func (*Deployment) Reset ¶

func (m *Deployment) Reset()

func (*Deployment) Size ¶

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

func (*Deployment) String ¶

func (m *Deployment) String() string

func (*Deployment) Unmarshal ¶

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

func (*Deployment) XXX_DiscardUnknown ¶

func (m *Deployment) XXX_DiscardUnknown()

func (*Deployment) XXX_Marshal ¶

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

func (*Deployment) XXX_Merge ¶

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

func (*Deployment) XXX_Size ¶

func (m *Deployment) XXX_Size() int

func (*Deployment) XXX_Unmarshal ¶

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

type DeploymentFilters ¶

type DeploymentFilters 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"`
	State string `protobuf:"bytes,3,opt,name=state,proto3" json:"state" yaml:"state"`
}

DeploymentFilters defines filters used to filter deployments

func (DeploymentFilters) Accept ¶

func (filters DeploymentFilters) Accept(obj Deployment, stateVal Deployment_State) bool

Accept returns whether deployment filters valid or not

func (*DeploymentFilters) Descriptor ¶

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

func (*DeploymentFilters) GetDSeq ¶

func (m *DeploymentFilters) GetDSeq() uint64

func (*DeploymentFilters) GetOwner ¶

func (m *DeploymentFilters) GetOwner() string

func (*DeploymentFilters) GetState ¶

func (m *DeploymentFilters) GetState() string

func (*DeploymentFilters) Marshal ¶

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

func (*DeploymentFilters) MarshalTo ¶

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

func (*DeploymentFilters) MarshalToSizedBuffer ¶

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

func (*DeploymentFilters) ProtoMessage ¶

func (*DeploymentFilters) ProtoMessage()

func (*DeploymentFilters) Reset ¶

func (m *DeploymentFilters) Reset()

func (*DeploymentFilters) Size ¶

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

func (*DeploymentFilters) String ¶

func (m *DeploymentFilters) String() string

func (*DeploymentFilters) Unmarshal ¶

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

func (*DeploymentFilters) XXX_DiscardUnknown ¶

func (m *DeploymentFilters) XXX_DiscardUnknown()

func (*DeploymentFilters) XXX_Marshal ¶

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

func (*DeploymentFilters) XXX_Merge ¶

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

func (*DeploymentFilters) XXX_Size ¶

func (m *DeploymentFilters) XXX_Size() int

func (*DeploymentFilters) XXX_Unmarshal ¶

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

type DeploymentID ¶

type DeploymentID 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"`
}

DeploymentID stores owner and sequence number

func ParseDeploymentID ¶

func ParseDeploymentID(val string) (DeploymentID, error)

func ParseDeploymentPath ¶

func ParseDeploymentPath(parts []string) (DeploymentID, error)

ParseDeploymentPath returns DeploymentID details with provided queries, and return error if occurred due to wrong query

func (*DeploymentID) Descriptor ¶

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

func (DeploymentID) Equals ¶

func (id DeploymentID) Equals(other DeploymentID) bool

Equals method compares specific deployment with provided deployment

func (*DeploymentID) GetDSeq ¶

func (m *DeploymentID) GetDSeq() uint64

func (*DeploymentID) GetOwner ¶

func (m *DeploymentID) GetOwner() string

func (DeploymentID) GetOwnerAddress ¶

func (id DeploymentID) GetOwnerAddress() (sdk.Address, error)

func (*DeploymentID) Marshal ¶

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

func (*DeploymentID) MarshalTo ¶

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

func (*DeploymentID) MarshalToSizedBuffer ¶

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

func (*DeploymentID) ProtoMessage ¶

func (*DeploymentID) ProtoMessage()

func (*DeploymentID) Reset ¶

func (m *DeploymentID) Reset()

func (*DeploymentID) Size ¶

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

func (DeploymentID) String ¶

func (id DeploymentID) String() string

String method for deployment IDs

func (*DeploymentID) Unmarshal ¶

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

func (DeploymentID) Validate ¶

func (id DeploymentID) Validate() error

Validate method for DeploymentID and returns nil

func (*DeploymentID) XXX_DiscardUnknown ¶

func (m *DeploymentID) XXX_DiscardUnknown()

func (*DeploymentID) XXX_Marshal ¶

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

func (*DeploymentID) XXX_Merge ¶

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

func (*DeploymentID) XXX_Size ¶

func (m *DeploymentID) XXX_Size() int

func (*DeploymentID) XXX_Unmarshal ¶

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

type Deployment_State ¶

type Deployment_State int32

State is an enum which refers to state of deployment

const (
	// Prefix should start with 0 in enum. So declaring dummy state
	DeploymentStateInvalid Deployment_State = 0
	// DeploymentActive denotes state for deployment active
	DeploymentActive Deployment_State = 1
	// DeploymentClosed denotes state for deployment closed
	DeploymentClosed Deployment_State = 2
)

func (Deployment_State) EnumDescriptor ¶

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

func (Deployment_State) String ¶

func (x Deployment_State) String() string

type DepositDeploymentAuthorization ¶

type DepositDeploymentAuthorization struct {
	// SpendLimit is the amount the grantee is authorized to spend from the granter's account for
	// the purpose of deployment.
	SpendLimit types.Coin `protobuf:"bytes,1,opt,name=spend_limit,json=spendLimit,proto3" json:"spend_limit"`
}

DepositDeploymentAuthorization allows the grantee to deposit up to spend_limit coins from the granter's account for a deployment.

func NewDepositDeploymentAuthorization ¶

func NewDepositDeploymentAuthorization(spendLimit sdk.Coin) *DepositDeploymentAuthorization

NewDepositDeploymentAuthorization creates a new DepositDeploymentAuthorization object.

func (DepositDeploymentAuthorization) Accept ¶

Accept implements Authorization.Accept.

func (*DepositDeploymentAuthorization) Descriptor ¶

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

func (*DepositDeploymentAuthorization) GetSpendLimit ¶

func (m *DepositDeploymentAuthorization) GetSpendLimit() types.Coin

func (*DepositDeploymentAuthorization) Marshal ¶

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

func (*DepositDeploymentAuthorization) MarshalTo ¶

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

func (*DepositDeploymentAuthorization) MarshalToSizedBuffer ¶

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

func (DepositDeploymentAuthorization) MsgTypeURL ¶

func (m DepositDeploymentAuthorization) MsgTypeURL() string

MsgTypeURL implements Authorization.MsgTypeURL.

func (*DepositDeploymentAuthorization) ProtoMessage ¶

func (*DepositDeploymentAuthorization) ProtoMessage()

func (*DepositDeploymentAuthorization) Reset ¶

func (m *DepositDeploymentAuthorization) Reset()

func (*DepositDeploymentAuthorization) Size ¶

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

func (*DepositDeploymentAuthorization) String ¶

func (*DepositDeploymentAuthorization) Unmarshal ¶

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

func (DepositDeploymentAuthorization) ValidateBasic ¶

func (m DepositDeploymentAuthorization) ValidateBasic() error

ValidateBasic implements Authorization.ValidateBasic.

func (*DepositDeploymentAuthorization) XXX_DiscardUnknown ¶

func (m *DepositDeploymentAuthorization) XXX_DiscardUnknown()

func (*DepositDeploymentAuthorization) XXX_Marshal ¶

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

func (*DepositDeploymentAuthorization) XXX_Merge ¶

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

func (*DepositDeploymentAuthorization) XXX_Size ¶

func (m *DepositDeploymentAuthorization) XXX_Size() int

func (*DepositDeploymentAuthorization) XXX_Unmarshal ¶

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

type GenesisDeployment ¶

type GenesisDeployment struct {
	Deployment Deployment `protobuf:"bytes,1,opt,name=deployment,proto3" json:"deployment" yaml:"deployment"`
	Groups     []Group    `protobuf:"bytes,2,rep,name=groups,proto3" json:"groups" yaml:"groups"`
}

GenesisDeployment defines the basic genesis state used by deployment module

func (*GenesisDeployment) Descriptor ¶

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

func (*GenesisDeployment) GetDeployment ¶

func (m *GenesisDeployment) GetDeployment() Deployment

func (*GenesisDeployment) GetGroups ¶

func (m *GenesisDeployment) GetGroups() []Group

func (*GenesisDeployment) Marshal ¶

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

func (*GenesisDeployment) MarshalTo ¶

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

func (*GenesisDeployment) MarshalToSizedBuffer ¶

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

func (*GenesisDeployment) ProtoMessage ¶

func (*GenesisDeployment) ProtoMessage()

func (*GenesisDeployment) Reset ¶

func (m *GenesisDeployment) Reset()

func (*GenesisDeployment) Size ¶

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

func (*GenesisDeployment) String ¶

func (m *GenesisDeployment) String() string

func (*GenesisDeployment) Unmarshal ¶

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

func (*GenesisDeployment) XXX_DiscardUnknown ¶

func (m *GenesisDeployment) XXX_DiscardUnknown()

func (*GenesisDeployment) XXX_Marshal ¶

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

func (*GenesisDeployment) XXX_Merge ¶

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

func (*GenesisDeployment) XXX_Size ¶

func (m *GenesisDeployment) XXX_Size() int

func (*GenesisDeployment) XXX_Unmarshal ¶

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

type GenesisState ¶

type GenesisState struct {
	Deployments []GenesisDeployment `protobuf:"bytes,1,rep,name=deployments,proto3" json:"deployments" yaml:"deployments"`
	Params      Params              `protobuf:"bytes,2,opt,name=params,proto3" json:"params" yaml:"params"`
}

GenesisState stores slice of genesis deployment instance

func (*GenesisState) Descriptor ¶

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

func (*GenesisState) GetDeployments ¶

func (m *GenesisState) GetDeployments() []GenesisDeployment

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 Group ¶

type Group struct {
	GroupID   GroupID     `protobuf:"bytes,1,opt,name=group_id,json=groupId,proto3" json:"id" yaml:"id"`
	State     Group_State `protobuf:"varint,2,opt,name=state,proto3,enum=akash.deployment.v1beta3.Group_State" json:"state" yaml:"state"`
	GroupSpec GroupSpec   `protobuf:"bytes,3,opt,name=group_spec,json=groupSpec,proto3" json:"spec" yaml:"spec"`
	CreatedAt int64       `protobuf:"varint,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
}

Group stores group id, state and specifications of group

func (*Group) Descriptor ¶

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

func (*Group) GetCreatedAt ¶

func (m *Group) GetCreatedAt() int64

func (*Group) GetGroupID ¶

func (m *Group) GetGroupID() GroupID

func (*Group) GetGroupSpec ¶

func (m *Group) GetGroupSpec() GroupSpec

func (Group) GetName ¶

func (g Group) GetName() string

GetName method returns group name

func (Group) GetResourceUnits ¶

func (g Group) GetResourceUnits() ResourceUnits

GetResourceUnits method returns resources list in group

func (*Group) GetState ¶

func (m *Group) GetState() Group_State

func (Group) ID ¶

func (g Group) ID() GroupID

ID method returns GroupID details of specific group

func (*Group) Marshal ¶

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

func (*Group) MarshalTo ¶

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

func (*Group) MarshalToSizedBuffer ¶

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

func (*Group) ProtoMessage ¶

func (*Group) ProtoMessage()

func (*Group) Reset ¶

func (m *Group) Reset()

func (*Group) Size ¶

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

func (*Group) String ¶

func (m *Group) String() string

func (*Group) Unmarshal ¶

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

func (Group) ValidateClosable ¶

func (g Group) ValidateClosable() error

ValidateClosable provides error response if group is already closed, and thus should not be closed again, else nil.

func (Group) ValidatePausable ¶

func (g Group) ValidatePausable() error

ValidatePausable provides error response if group is not pausable

func (Group) ValidateStartable ¶

func (g Group) ValidateStartable() error

ValidatePausable provides error response if group is not pausable

func (*Group) XXX_DiscardUnknown ¶

func (m *Group) XXX_DiscardUnknown()

func (*Group) XXX_Marshal ¶

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

func (*Group) XXX_Merge ¶

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

func (*Group) XXX_Size ¶

func (m *Group) XXX_Size() int

func (*Group) XXX_Unmarshal ¶

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

type GroupID ¶

type GroupID 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"`
}

GroupID stores owner, deployment sequence number and group sequence number

func MakeGroupID ¶

func MakeGroupID(id DeploymentID, gseq uint32) GroupID

MakeGroupID returns GroupID instance with provided deployment details and group sequence number.

func (GroupID) DeploymentID ¶

func (id GroupID) DeploymentID() DeploymentID

DeploymentID method returns DeploymentID details with specific group details

func (*GroupID) Descriptor ¶

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

func (GroupID) Equals ¶

func (id GroupID) Equals(other GroupID) bool

Equals method compares specific group with provided group

func (*GroupID) GetDSeq ¶

func (m *GroupID) GetDSeq() uint64

func (*GroupID) GetGSeq ¶

func (m *GroupID) GetGSeq() uint32

func (*GroupID) GetOwner ¶

func (m *GroupID) GetOwner() string

func (*GroupID) Marshal ¶

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

func (*GroupID) MarshalTo ¶

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

func (*GroupID) MarshalToSizedBuffer ¶

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

func (*GroupID) ProtoMessage ¶

func (*GroupID) ProtoMessage()

func (*GroupID) Reset ¶

func (m *GroupID) Reset()

func (*GroupID) Size ¶

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

func (GroupID) String ¶

func (id GroupID) String() string

String method provides human readable representation of GroupID.

func (*GroupID) Unmarshal ¶

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

func (GroupID) Validate ¶

func (id GroupID) Validate() error

Validate method for GroupID and returns nil

func (*GroupID) XXX_DiscardUnknown ¶

func (m *GroupID) XXX_DiscardUnknown()

func (*GroupID) XXX_Marshal ¶

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

func (*GroupID) XXX_Merge ¶

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

func (*GroupID) XXX_Size ¶

func (m *GroupID) XXX_Size() int

func (*GroupID) XXX_Unmarshal ¶

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

type GroupLimit ¶

type GroupLimit struct {
	Limits
	Units uint32
}

type GroupLimits ¶

type GroupLimits struct {
	Max GroupLimit
}

type GroupSpec ¶

type GroupSpec struct {
	Name         string                        `protobuf:"bytes,1,opt,name=name,proto3" json:"name" yaml:"name"`
	Requirements v1beta3.PlacementRequirements `protobuf:"bytes,2,opt,name=requirements,proto3" json:"requirements" yaml:"requirements"`
	Resources    ResourceUnits                 `protobuf:"bytes,3,rep,name=resources,proto3,castrepeated=ResourceUnits" json:"resources" yaml:"resources"`
}

GroupSpec stores group specifications

func (*GroupSpec) Descriptor ¶

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

func (GroupSpec) Dup ¶

func (g GroupSpec) Dup() GroupSpec

func (GroupSpec) GetName ¶

func (g GroupSpec) GetName() string

GetName method returns group name

func (GroupSpec) GetResourceUnits ¶

func (g GroupSpec) GetResourceUnits() ResourceUnits

GetResourceUnits method returns resources list in group

func (*GroupSpec) Marshal ¶

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

func (*GroupSpec) MarshalTo ¶

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

func (*GroupSpec) MarshalToSizedBuffer ¶

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

func (*GroupSpec) MatchAttributes ¶

func (g *GroupSpec) MatchAttributes(attr types.Attributes) bool

MatchAttributes method compares provided attributes with specific group attributes

func (GroupSpec) MatchRequirements ¶

func (g GroupSpec) MatchRequirements(provider []atypes.Provider) bool

MatchRequirements method compares provided attributes with specific group attributes. Argument provider is a bit cumbersome. First element is attributes from x/provider store in case tenant does not need signed attributes at all rest of elements (if any) are attributes signed by various auditors

func (GroupSpec) MatchResourcesRequirements ¶

func (g GroupSpec) MatchResourcesRequirements(pattr types.Attributes) bool

MatchResourcesRequirements check if resources attributes match provider's capabilities

func (GroupSpec) Price ¶

func (g GroupSpec) Price() sdk.DecCoin

Price method returns price of group

func (*GroupSpec) ProtoMessage ¶

func (*GroupSpec) ProtoMessage()

func (*GroupSpec) Reset ¶

func (m *GroupSpec) Reset()

func (*GroupSpec) Size ¶

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

func (*GroupSpec) String ¶

func (m *GroupSpec) String() string

func (*GroupSpec) Unmarshal ¶

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

func (GroupSpec) ValidateBasic ¶

func (g GroupSpec) ValidateBasic() error

ValidateBasic asserts non-zero values

func (*GroupSpec) XXX_DiscardUnknown ¶

func (m *GroupSpec) XXX_DiscardUnknown()

func (*GroupSpec) XXX_Marshal ¶

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

func (*GroupSpec) XXX_Merge ¶

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

func (*GroupSpec) XXX_Size ¶

func (m *GroupSpec) XXX_Size() int

func (*GroupSpec) XXX_Unmarshal ¶

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

type GroupSpecs ¶

type GroupSpecs []*GroupSpec

func (GroupSpecs) Dup ¶

func (gspecs GroupSpecs) Dup() GroupSpecs

type Group_State ¶

type Group_State int32

State is an enum which refers to state of group

const (
	// Prefix should start with 0 in enum. So declaring dummy state
	GroupStateInvalid Group_State = 0
	// GroupOpen denotes state for group open
	GroupOpen Group_State = 1
	// GroupOrdered denotes state for group ordered
	GroupPaused Group_State = 2
	// GroupInsufficientFunds denotes state for group insufficient_funds
	GroupInsufficientFunds Group_State = 3
	// GroupClosed denotes state for group closed
	GroupClosed Group_State = 4
)

func (Group_State) EnumDescriptor ¶

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

func (Group_State) String ¶

func (x Group_State) String() string

type Limits ¶

type Limits struct {
	Memory  uint64
	Storage uint64
	Price   uint64
	CPU     uint
	GPU     uint
	Count   uint
}

type MsgCloseDeployment ¶

type MsgCloseDeployment struct {
	ID DeploymentID `protobuf:"bytes,1,opt,name=id,proto3" json:"id" yaml:"id"`
}

MsgCloseDeployment defines an SDK message for closing deployment

func (*MsgCloseDeployment) Descriptor ¶

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

func (*MsgCloseDeployment) GetID ¶

func (m *MsgCloseDeployment) GetID() DeploymentID

func (*MsgCloseDeployment) Marshal ¶

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

func (*MsgCloseDeployment) MarshalTo ¶

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

func (*MsgCloseDeployment) MarshalToSizedBuffer ¶

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

func (*MsgCloseDeployment) ProtoMessage ¶

func (*MsgCloseDeployment) ProtoMessage()

func (*MsgCloseDeployment) Reset ¶

func (m *MsgCloseDeployment) Reset()

func (*MsgCloseDeployment) Size ¶

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

func (*MsgCloseDeployment) String ¶

func (m *MsgCloseDeployment) String() string

func (*MsgCloseDeployment) Unmarshal ¶

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

func (*MsgCloseDeployment) XXX_DiscardUnknown ¶

func (m *MsgCloseDeployment) XXX_DiscardUnknown()

func (*MsgCloseDeployment) XXX_Marshal ¶

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

func (*MsgCloseDeployment) XXX_Merge ¶

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

func (*MsgCloseDeployment) XXX_Size ¶

func (m *MsgCloseDeployment) XXX_Size() int

func (*MsgCloseDeployment) XXX_Unmarshal ¶

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

type MsgCloseDeploymentResponse ¶

type MsgCloseDeploymentResponse struct {
}

MsgCloseDeploymentResponse defines the Msg/CloseDeployment response type.

func (*MsgCloseDeploymentResponse) Descriptor ¶

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

func (*MsgCloseDeploymentResponse) Marshal ¶

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

func (*MsgCloseDeploymentResponse) MarshalTo ¶

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

func (*MsgCloseDeploymentResponse) MarshalToSizedBuffer ¶

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

func (*MsgCloseDeploymentResponse) ProtoMessage ¶

func (*MsgCloseDeploymentResponse) ProtoMessage()

func (*MsgCloseDeploymentResponse) Reset ¶

func (m *MsgCloseDeploymentResponse) Reset()

func (*MsgCloseDeploymentResponse) Size ¶

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

func (*MsgCloseDeploymentResponse) String ¶

func (m *MsgCloseDeploymentResponse) String() string

func (*MsgCloseDeploymentResponse) Unmarshal ¶

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

func (*MsgCloseDeploymentResponse) XXX_DiscardUnknown ¶

func (m *MsgCloseDeploymentResponse) XXX_DiscardUnknown()

func (*MsgCloseDeploymentResponse) XXX_Marshal ¶

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

func (*MsgCloseDeploymentResponse) XXX_Merge ¶

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

func (*MsgCloseDeploymentResponse) XXX_Size ¶

func (m *MsgCloseDeploymentResponse) XXX_Size() int

func (*MsgCloseDeploymentResponse) XXX_Unmarshal ¶

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

type MsgCloseGroup ¶

type MsgCloseGroup struct {
	ID GroupID `protobuf:"bytes,1,opt,name=id,proto3" json:"id" yaml:"id"`
}

MsgCloseGroup defines SDK message to close a single Group within a Deployment.

func (*MsgCloseGroup) Descriptor ¶

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

func (*MsgCloseGroup) GetID ¶

func (m *MsgCloseGroup) GetID() GroupID

func (*MsgCloseGroup) Marshal ¶

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

func (*MsgCloseGroup) MarshalTo ¶

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

func (*MsgCloseGroup) MarshalToSizedBuffer ¶

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

func (*MsgCloseGroup) ProtoMessage ¶

func (*MsgCloseGroup) ProtoMessage()

func (*MsgCloseGroup) Reset ¶

func (m *MsgCloseGroup) Reset()

func (*MsgCloseGroup) Size ¶

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

func (*MsgCloseGroup) String ¶

func (m *MsgCloseGroup) String() string

func (*MsgCloseGroup) Unmarshal ¶

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

func (*MsgCloseGroup) XXX_DiscardUnknown ¶

func (m *MsgCloseGroup) XXX_DiscardUnknown()

func (*MsgCloseGroup) XXX_Marshal ¶

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

func (*MsgCloseGroup) XXX_Merge ¶

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

func (*MsgCloseGroup) XXX_Size ¶

func (m *MsgCloseGroup) XXX_Size() int

func (*MsgCloseGroup) XXX_Unmarshal ¶

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

type MsgCloseGroupResponse ¶

type MsgCloseGroupResponse struct {
}

MsgCloseGroupResponse defines the Msg/CloseGroup response type.

func (*MsgCloseGroupResponse) Descriptor ¶

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

func (*MsgCloseGroupResponse) Marshal ¶

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

func (*MsgCloseGroupResponse) MarshalTo ¶

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

func (*MsgCloseGroupResponse) MarshalToSizedBuffer ¶

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

func (*MsgCloseGroupResponse) ProtoMessage ¶

func (*MsgCloseGroupResponse) ProtoMessage()

func (*MsgCloseGroupResponse) Reset ¶

func (m *MsgCloseGroupResponse) Reset()

func (*MsgCloseGroupResponse) Size ¶

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

func (*MsgCloseGroupResponse) String ¶

func (m *MsgCloseGroupResponse) String() string

func (*MsgCloseGroupResponse) Unmarshal ¶

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

func (*MsgCloseGroupResponse) XXX_DiscardUnknown ¶

func (m *MsgCloseGroupResponse) XXX_DiscardUnknown()

func (*MsgCloseGroupResponse) XXX_Marshal ¶

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

func (*MsgCloseGroupResponse) XXX_Merge ¶

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

func (*MsgCloseGroupResponse) XXX_Size ¶

func (m *MsgCloseGroupResponse) XXX_Size() int

func (*MsgCloseGroupResponse) XXX_Unmarshal ¶

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

type MsgCreateDeployment ¶

type MsgCreateDeployment struct {
	ID      DeploymentID `protobuf:"bytes,1,opt,name=id,proto3" json:"id" yaml:"id"`
	Groups  []GroupSpec  `protobuf:"bytes,2,rep,name=groups,proto3" json:"groups" yaml:"groups"`
	Version []byte       `protobuf:"bytes,3,opt,name=version,proto3" json:"version" yaml:"version"`
	Deposit types.Coin   `protobuf:"bytes,4,opt,name=deposit,proto3" json:"deposit" yaml:"deposit"`
	// Depositor pays for the deposit
	Depositor string `protobuf:"bytes,5,opt,name=depositor,proto3" json:"depositor" yaml:"depositor"`
}

MsgCreateDeployment defines an SDK message for creating deployment

func (*MsgCreateDeployment) Descriptor ¶

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

func (*MsgCreateDeployment) GetDeposit ¶

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

func (*MsgCreateDeployment) GetDepositor ¶

func (m *MsgCreateDeployment) GetDepositor() string

func (*MsgCreateDeployment) GetGroups ¶

func (m *MsgCreateDeployment) GetGroups() []GroupSpec

func (*MsgCreateDeployment) GetID ¶

func (m *MsgCreateDeployment) GetID() DeploymentID

func (*MsgCreateDeployment) GetVersion ¶

func (m *MsgCreateDeployment) GetVersion() []byte

func (*MsgCreateDeployment) Marshal ¶

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

func (*MsgCreateDeployment) MarshalTo ¶

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

func (*MsgCreateDeployment) MarshalToSizedBuffer ¶

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

func (*MsgCreateDeployment) ProtoMessage ¶

func (*MsgCreateDeployment) ProtoMessage()

func (*MsgCreateDeployment) Reset ¶

func (m *MsgCreateDeployment) Reset()

func (*MsgCreateDeployment) Size ¶

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

func (*MsgCreateDeployment) String ¶

func (m *MsgCreateDeployment) String() string

func (*MsgCreateDeployment) Unmarshal ¶

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

func (*MsgCreateDeployment) XXX_DiscardUnknown ¶

func (m *MsgCreateDeployment) XXX_DiscardUnknown()

func (*MsgCreateDeployment) XXX_Marshal ¶

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

func (*MsgCreateDeployment) XXX_Merge ¶

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

func (*MsgCreateDeployment) XXX_Size ¶

func (m *MsgCreateDeployment) XXX_Size() int

func (*MsgCreateDeployment) XXX_Unmarshal ¶

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

type MsgCreateDeploymentResponse ¶

type MsgCreateDeploymentResponse struct {
}

MsgCreateDeploymentResponse defines the Msg/CreateDeployment response type.

func (*MsgCreateDeploymentResponse) Descriptor ¶

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

func (*MsgCreateDeploymentResponse) Marshal ¶

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

func (*MsgCreateDeploymentResponse) MarshalTo ¶

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

func (*MsgCreateDeploymentResponse) MarshalToSizedBuffer ¶

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

func (*MsgCreateDeploymentResponse) ProtoMessage ¶

func (*MsgCreateDeploymentResponse) ProtoMessage()

func (*MsgCreateDeploymentResponse) Reset ¶

func (m *MsgCreateDeploymentResponse) Reset()

func (*MsgCreateDeploymentResponse) Size ¶

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

func (*MsgCreateDeploymentResponse) String ¶

func (m *MsgCreateDeploymentResponse) String() string

func (*MsgCreateDeploymentResponse) Unmarshal ¶

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

func (*MsgCreateDeploymentResponse) XXX_DiscardUnknown ¶

func (m *MsgCreateDeploymentResponse) XXX_DiscardUnknown()

func (*MsgCreateDeploymentResponse) XXX_Marshal ¶

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

func (*MsgCreateDeploymentResponse) XXX_Merge ¶

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

func (*MsgCreateDeploymentResponse) XXX_Size ¶

func (m *MsgCreateDeploymentResponse) XXX_Size() int

func (*MsgCreateDeploymentResponse) XXX_Unmarshal ¶

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

type MsgDepositDeployment ¶

type MsgDepositDeployment struct {
	ID     DeploymentID `protobuf:"bytes,1,opt,name=id,proto3" json:"id" yaml:"id"`
	Amount types.Coin   `protobuf:"bytes,2,opt,name=amount,proto3" json:"amount" yaml:"amount"`
	// Depositor pays for the deposit
	Depositor string `protobuf:"bytes,3,opt,name=depositor,proto3" json:"depositor" yaml:"depositor"`
}

MsgDepositDeployment deposits more funds into the deposit account

func (*MsgDepositDeployment) Descriptor ¶

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

func (*MsgDepositDeployment) GetAmount ¶

func (m *MsgDepositDeployment) GetAmount() types.Coin

func (*MsgDepositDeployment) GetDepositor ¶

func (m *MsgDepositDeployment) GetDepositor() string

func (*MsgDepositDeployment) GetID ¶

func (*MsgDepositDeployment) Marshal ¶

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

func (*MsgDepositDeployment) MarshalTo ¶

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

func (*MsgDepositDeployment) MarshalToSizedBuffer ¶

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

func (*MsgDepositDeployment) ProtoMessage ¶

func (*MsgDepositDeployment) ProtoMessage()

func (*MsgDepositDeployment) Reset ¶

func (m *MsgDepositDeployment) Reset()

func (*MsgDepositDeployment) Size ¶

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

func (*MsgDepositDeployment) String ¶

func (m *MsgDepositDeployment) String() string

func (*MsgDepositDeployment) Unmarshal ¶

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

func (*MsgDepositDeployment) XXX_DiscardUnknown ¶

func (m *MsgDepositDeployment) XXX_DiscardUnknown()

func (*MsgDepositDeployment) XXX_Marshal ¶

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

func (*MsgDepositDeployment) XXX_Merge ¶

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

func (*MsgDepositDeployment) XXX_Size ¶

func (m *MsgDepositDeployment) XXX_Size() int

func (*MsgDepositDeployment) XXX_Unmarshal ¶

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

type MsgDepositDeploymentResponse ¶

type MsgDepositDeploymentResponse struct {
}

MsgCreateDeploymentResponse defines the Msg/CreateDeployment response type.

func (*MsgDepositDeploymentResponse) Descriptor ¶

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

func (*MsgDepositDeploymentResponse) Marshal ¶

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

func (*MsgDepositDeploymentResponse) MarshalTo ¶

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

func (*MsgDepositDeploymentResponse) MarshalToSizedBuffer ¶

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

func (*MsgDepositDeploymentResponse) ProtoMessage ¶

func (*MsgDepositDeploymentResponse) ProtoMessage()

func (*MsgDepositDeploymentResponse) Reset ¶

func (m *MsgDepositDeploymentResponse) Reset()

func (*MsgDepositDeploymentResponse) Size ¶

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

func (*MsgDepositDeploymentResponse) String ¶

func (*MsgDepositDeploymentResponse) Unmarshal ¶

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

func (*MsgDepositDeploymentResponse) XXX_DiscardUnknown ¶

func (m *MsgDepositDeploymentResponse) XXX_DiscardUnknown()

func (*MsgDepositDeploymentResponse) XXX_Marshal ¶

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

func (*MsgDepositDeploymentResponse) XXX_Merge ¶

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

func (*MsgDepositDeploymentResponse) XXX_Size ¶

func (m *MsgDepositDeploymentResponse) XXX_Size() int

func (*MsgDepositDeploymentResponse) XXX_Unmarshal ¶

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

type MsgPauseGroup ¶

type MsgPauseGroup struct {
	ID GroupID `protobuf:"bytes,1,opt,name=id,proto3" json:"id" yaml:"id"`
}

MsgPauseGroup defines SDK message to close a single Group within a Deployment.

func (*MsgPauseGroup) Descriptor ¶

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

func (*MsgPauseGroup) GetID ¶

func (m *MsgPauseGroup) GetID() GroupID

func (*MsgPauseGroup) Marshal ¶

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

func (*MsgPauseGroup) MarshalTo ¶

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

func (*MsgPauseGroup) MarshalToSizedBuffer ¶

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

func (*MsgPauseGroup) ProtoMessage ¶

func (*MsgPauseGroup) ProtoMessage()

func (*MsgPauseGroup) Reset ¶

func (m *MsgPauseGroup) Reset()

func (*MsgPauseGroup) Size ¶

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

func (*MsgPauseGroup) String ¶

func (m *MsgPauseGroup) String() string

func (*MsgPauseGroup) Unmarshal ¶

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

func (*MsgPauseGroup) XXX_DiscardUnknown ¶

func (m *MsgPauseGroup) XXX_DiscardUnknown()

func (*MsgPauseGroup) XXX_Marshal ¶

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

func (*MsgPauseGroup) XXX_Merge ¶

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

func (*MsgPauseGroup) XXX_Size ¶

func (m *MsgPauseGroup) XXX_Size() int

func (*MsgPauseGroup) XXX_Unmarshal ¶

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

type MsgPauseGroupResponse ¶

type MsgPauseGroupResponse struct {
}

MsgPauseGroupResponse defines the Msg/PauseGroup response type.

func (*MsgPauseGroupResponse) Descriptor ¶

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

func (*MsgPauseGroupResponse) Marshal ¶

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

func (*MsgPauseGroupResponse) MarshalTo ¶

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

func (*MsgPauseGroupResponse) MarshalToSizedBuffer ¶

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

func (*MsgPauseGroupResponse) ProtoMessage ¶

func (*MsgPauseGroupResponse) ProtoMessage()

func (*MsgPauseGroupResponse) Reset ¶

func (m *MsgPauseGroupResponse) Reset()

func (*MsgPauseGroupResponse) Size ¶

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

func (*MsgPauseGroupResponse) String ¶

func (m *MsgPauseGroupResponse) String() string

func (*MsgPauseGroupResponse) Unmarshal ¶

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

func (*MsgPauseGroupResponse) XXX_DiscardUnknown ¶

func (m *MsgPauseGroupResponse) XXX_DiscardUnknown()

func (*MsgPauseGroupResponse) XXX_Marshal ¶

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

func (*MsgPauseGroupResponse) XXX_Merge ¶

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

func (*MsgPauseGroupResponse) XXX_Size ¶

func (m *MsgPauseGroupResponse) XXX_Size() int

func (*MsgPauseGroupResponse) XXX_Unmarshal ¶

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

type MsgStartGroup ¶

type MsgStartGroup struct {
	ID GroupID `protobuf:"bytes,1,opt,name=id,proto3" json:"id" yaml:"id"`
}

MsgStartGroup defines SDK message to close a single Group within a Deployment.

func (*MsgStartGroup) Descriptor ¶

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

func (*MsgStartGroup) GetID ¶

func (m *MsgStartGroup) GetID() GroupID

func (*MsgStartGroup) Marshal ¶

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

func (*MsgStartGroup) MarshalTo ¶

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

func (*MsgStartGroup) MarshalToSizedBuffer ¶

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

func (*MsgStartGroup) ProtoMessage ¶

func (*MsgStartGroup) ProtoMessage()

func (*MsgStartGroup) Reset ¶

func (m *MsgStartGroup) Reset()

func (*MsgStartGroup) Size ¶

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

func (*MsgStartGroup) String ¶

func (m *MsgStartGroup) String() string

func (*MsgStartGroup) Unmarshal ¶

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

func (*MsgStartGroup) XXX_DiscardUnknown ¶

func (m *MsgStartGroup) XXX_DiscardUnknown()

func (*MsgStartGroup) XXX_Marshal ¶

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

func (*MsgStartGroup) XXX_Merge ¶

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

func (*MsgStartGroup) XXX_Size ¶

func (m *MsgStartGroup) XXX_Size() int

func (*MsgStartGroup) XXX_Unmarshal ¶

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

type MsgStartGroupResponse ¶

type MsgStartGroupResponse struct {
}

MsgStartGroupResponse defines the Msg/StartGroup response type.

func (*MsgStartGroupResponse) Descriptor ¶

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

func (*MsgStartGroupResponse) Marshal ¶

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

func (*MsgStartGroupResponse) MarshalTo ¶

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

func (*MsgStartGroupResponse) MarshalToSizedBuffer ¶

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

func (*MsgStartGroupResponse) ProtoMessage ¶

func (*MsgStartGroupResponse) ProtoMessage()

func (*MsgStartGroupResponse) Reset ¶

func (m *MsgStartGroupResponse) Reset()

func (*MsgStartGroupResponse) Size ¶

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

func (*MsgStartGroupResponse) String ¶

func (m *MsgStartGroupResponse) String() string

func (*MsgStartGroupResponse) Unmarshal ¶

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

func (*MsgStartGroupResponse) XXX_DiscardUnknown ¶

func (m *MsgStartGroupResponse) XXX_DiscardUnknown()

func (*MsgStartGroupResponse) XXX_Marshal ¶

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

func (*MsgStartGroupResponse) XXX_Merge ¶

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

func (*MsgStartGroupResponse) XXX_Size ¶

func (m *MsgStartGroupResponse) XXX_Size() int

func (*MsgStartGroupResponse) XXX_Unmarshal ¶

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

type MsgUpdateDeployment ¶

type MsgUpdateDeployment struct {
	ID      DeploymentID `protobuf:"bytes,1,opt,name=id,proto3" json:"id" yaml:"id"`
	Version []byte       `protobuf:"bytes,3,opt,name=version,proto3" json:"version" yaml:"version"`
}

MsgUpdateDeployment defines an SDK message for updating deployment

func (*MsgUpdateDeployment) Descriptor ¶

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

func (*MsgUpdateDeployment) GetID ¶

func (m *MsgUpdateDeployment) GetID() DeploymentID

func (*MsgUpdateDeployment) GetVersion ¶

func (m *MsgUpdateDeployment) GetVersion() []byte

func (*MsgUpdateDeployment) Marshal ¶

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

func (*MsgUpdateDeployment) MarshalTo ¶

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

func (*MsgUpdateDeployment) MarshalToSizedBuffer ¶

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

func (*MsgUpdateDeployment) ProtoMessage ¶

func (*MsgUpdateDeployment) ProtoMessage()

func (*MsgUpdateDeployment) Reset ¶

func (m *MsgUpdateDeployment) Reset()

func (*MsgUpdateDeployment) Size ¶

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

func (*MsgUpdateDeployment) String ¶

func (m *MsgUpdateDeployment) String() string

func (*MsgUpdateDeployment) Unmarshal ¶

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

func (*MsgUpdateDeployment) XXX_DiscardUnknown ¶

func (m *MsgUpdateDeployment) XXX_DiscardUnknown()

func (*MsgUpdateDeployment) XXX_Marshal ¶

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

func (*MsgUpdateDeployment) XXX_Merge ¶

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

func (*MsgUpdateDeployment) XXX_Size ¶

func (m *MsgUpdateDeployment) XXX_Size() int

func (*MsgUpdateDeployment) XXX_Unmarshal ¶

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

type MsgUpdateDeploymentResponse ¶

type MsgUpdateDeploymentResponse struct {
}

MsgUpdateDeploymentResponse defines the Msg/UpdateDeployment response type.

func (*MsgUpdateDeploymentResponse) Descriptor ¶

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

func (*MsgUpdateDeploymentResponse) Marshal ¶

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

func (*MsgUpdateDeploymentResponse) MarshalTo ¶

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

func (*MsgUpdateDeploymentResponse) MarshalToSizedBuffer ¶

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

func (*MsgUpdateDeploymentResponse) ProtoMessage ¶

func (*MsgUpdateDeploymentResponse) ProtoMessage()

func (*MsgUpdateDeploymentResponse) Reset ¶

func (m *MsgUpdateDeploymentResponse) Reset()

func (*MsgUpdateDeploymentResponse) Size ¶

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

func (*MsgUpdateDeploymentResponse) String ¶

func (m *MsgUpdateDeploymentResponse) String() string

func (*MsgUpdateDeploymentResponse) Unmarshal ¶

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

func (*MsgUpdateDeploymentResponse) XXX_DiscardUnknown ¶

func (m *MsgUpdateDeploymentResponse) XXX_DiscardUnknown()

func (*MsgUpdateDeploymentResponse) XXX_Marshal ¶

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

func (*MsgUpdateDeploymentResponse) XXX_Merge ¶

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

func (*MsgUpdateDeploymentResponse) XXX_Size ¶

func (m *MsgUpdateDeploymentResponse) XXX_Size() int

func (*MsgUpdateDeploymentResponse) XXX_Unmarshal ¶

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

type Params ¶

type Params struct {
	MinDeposits github_com_cosmos_cosmos_sdk_types.Coins `` /* 158-byte string literal not displayed */
}

Params defines the parameters for the x/deployment package

func DefaultParams ¶

func DefaultParams() Params

func (*Params) Descriptor ¶

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

func (*Params) GetMinDeposits ¶

func (m *Params) GetMinDeposits() github_com_cosmos_cosmos_sdk_types.Coins

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) MinDepositFor ¶

func (p Params) MinDepositFor(denom string) (sdk.Coin, 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) ValidateDeposit ¶

func (p Params) ValidateDeposit(amt sdk.Coin) 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 ResourceGroup ¶

type ResourceGroup interface {
	GetName() string
	GetResourceUnits() ResourceUnits
}

type ResourceUnit ¶

type ResourceUnit struct {
	v1beta3.Resources `protobuf:"bytes,1,opt,name=resource,proto3,embedded=resource" json:"resource" yaml:"resource"`
	Count             uint32        `protobuf:"varint,2,opt,name=count,proto3" json:"count" yaml:"count"`
	Price             types.DecCoin `protobuf:"bytes,3,opt,name=price,proto3" json:"price" yaml:"price"`
}

ResourceUnit extends Resources and adds Count along with the Price

func (*ResourceUnit) Descriptor ¶

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

func (*ResourceUnit) Dup ¶

func (r *ResourceUnit) Dup() ResourceUnit

func (*ResourceUnit) Equal ¶

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

func (*ResourceUnit) FullPrice ¶

func (r *ResourceUnit) FullPrice() sdk.DecCoin

FullPrice method returns full price of resource

func (*ResourceUnit) GetCount ¶

func (m *ResourceUnit) GetCount() uint32

func (*ResourceUnit) GetPrice ¶

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

func (*ResourceUnit) Marshal ¶

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

func (*ResourceUnit) MarshalTo ¶

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

func (*ResourceUnit) MarshalToSizedBuffer ¶

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

func (*ResourceUnit) ProtoMessage ¶

func (*ResourceUnit) ProtoMessage()

func (*ResourceUnit) Reset ¶

func (m *ResourceUnit) Reset()

func (*ResourceUnit) Size ¶

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

func (*ResourceUnit) String ¶

func (m *ResourceUnit) String() string

func (*ResourceUnit) Unmarshal ¶

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

func (*ResourceUnit) XXX_DiscardUnknown ¶

func (m *ResourceUnit) XXX_DiscardUnknown()

func (*ResourceUnit) XXX_Marshal ¶

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

func (*ResourceUnit) XXX_Merge ¶

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

func (*ResourceUnit) XXX_Size ¶

func (m *ResourceUnit) XXX_Size() int

func (*ResourceUnit) XXX_Unmarshal ¶

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

type ResourceUnits ¶

type ResourceUnits []ResourceUnit

func (ResourceUnits) Dup ¶

func (s ResourceUnits) Dup() ResourceUnits

func (ResourceUnits) Len ¶

func (s ResourceUnits) Len() int

func (ResourceUnits) Less ¶

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

func (ResourceUnits) Swap ¶

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

func (ResourceUnits) Validate ¶

func (s ResourceUnits) Validate() error

type UnitLimits ¶

type UnitLimits struct {
	Max Limits
	Min Limits
}

type ValidationConfig ¶

type ValidationConfig struct {
	Unit  UnitLimits
	Group GroupLimits
}

func GetValidationConfig ¶

func GetValidationConfig() ValidationConfig

Jump to

Keyboard shortcuts

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