v1

package
v0.0.1-rc3 Latest Latest
Warning

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

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

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 (
	HashLength = 32
)

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 (
	// ErrNameDoesNotExist is the error when name does not exist
	ErrNameDoesNotExist = cerrors.Register(ModuleName, errNameDoesNotExist, "Name does not exist")
	// ErrInvalidRequest is the error for invalid request
	ErrInvalidRequest = cerrors.Register(ModuleName, errInvalidRequest, "Invalid request")
	// ErrDeploymentExists is the error when already deployment exists
	ErrDeploymentExists = cerrors.Register(ModuleName, errDeploymentExists, "Deployment exists")
	// ErrDeploymentNotFound is the error when deployment not found
	ErrDeploymentNotFound = cerrors.Register(ModuleName, errDeploymentNotFound, "Deployment not found")
	// ErrDeploymentClosed is the error when deployment is closed
	ErrDeploymentClosed = cerrors.Register(ModuleName, errDeploymentClosed, "Deployment closed")
	// ErrOwnerAcctMissing is the error for owner account missing
	ErrOwnerAcctMissing = cerrors.Register(ModuleName, errOwnerAcctMissing, "Owner account missing")
	// ErrInvalidGroups is the error when groups are empty
	ErrInvalidGroups = cerrors.Register(ModuleName, errInvalidGroups, "Invalid groups")
	// ErrInvalidDeploymentID is the error for invalid deployment id
	ErrInvalidDeploymentID = cerrors.Register(ModuleName, errInvalidDeploymentID, "Invalid: deployment id")
	// ErrEmptyHash is the error when version is empty
	ErrEmptyHash = cerrors.Register(ModuleName, errEmptyHash, "Invalid: empty hash")
	// ErrInvalidHash is the error when version is invalid
	ErrInvalidHash = cerrors.Register(ModuleName, errInvalidHash, "Invalid: deployment hash")
	// ErrInternal is the error for internal error
	ErrInternal = cerrors.Register(ModuleName, errInternal, "internal error")
	// ErrInvalidDeployment = is the error when deployment does not pass validation
	ErrInvalidDeployment = cerrors.Register(ModuleName, errInvalidDeployment, "Invalid deployment")
	// ErrInvalidGroupID is the error when already deployment exists
	ErrInvalidGroupID = cerrors.Register(ModuleName, errInvalidGroupID, "Deployment exists")
	// ErrGroupNotFound is the keeper's error for not finding a group
	ErrGroupNotFound = cerrors.Register(ModuleName, errGroupNotFound, "Group not found")
	// ErrGroupClosed is the error when deployment is closed
	ErrGroupClosed = cerrors.Register(ModuleName, errGroupClosed, "Group already closed")
	// ErrGroupOpen is the error when deployment is closed
	ErrGroupOpen = cerrors.Register(ModuleName, errGroupOpen, "Group open")
	// ErrGroupPaused is the error when deployment is closed
	ErrGroupPaused = cerrors.Register(ModuleName, errGroupPaused, "Group paused")
	// ErrGroupNotOpen indicates the Group state has progressed beyond initial Open.
	ErrGroupNotOpen = cerrors.Register(ModuleName, errGroupNotOpen, "Group not open")
	// ErrGroupSpecInvalid indicates a GroupSpec has invalid configuration
	ErrGroupSpecInvalid = cerrors.Register(ModuleName, errGroupSpec, "GroupSpec invalid")
	// ErrInvalidDeposit indicates an invalid deposit
	ErrInvalidDeposit = cerrors.Register(ModuleName, errInvalidDeposit, "Deposit invalid")
	// ErrInvalidIDPath indicates an invalid ID path
	ErrInvalidIDPath = cerrors.Register(ModuleName, errInvalidIDPath, "ID path invalid")
	// ErrInvalidParam indicates an invalid chain parameter
	ErrInvalidParam = cerrors.Register(ModuleName, errInvalidParam, "parameter invalid")
	// ErrInvalidDeploymentDepositor indicates an invalid chain parameter
	ErrInvalidDeploymentDepositor = cerrors.Register(ModuleName, errInvalidDeploymentDepositor, "invalid deployment depositor")
)
View Source 
var (
	ErrInvalidLengthEvent        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvent          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvent = 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 (
	ErrInvalidLengthMsg        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMsg          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMsg = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var DeploymentState_name = map[int32]string{
	0: "invalid",
	1: "active",
	2: "closed",
}
View Source 
var DeploymentState_value = map[string]int32{
	"invalid": 0,
	"active":  1,
	"closed":  2,
}
View Source 
var (
	MsgTypeDepositDeployment = ""
)

Functions

func DeploymentPrefix 

func DeploymentPrefix() []byte

func GroupPrefix 

func GroupPrefix() []byte

func ParamsPrefix 

func ParamsPrefix() []byte

Types

type Deployment 

type Deployment struct {
	ID        DeploymentID    `protobuf:"bytes,1,opt,name=id,proto3" json:"id" yaml:"id"`
	State     DeploymentState `protobuf:"varint,2,opt,name=state,proto3,enum=akash.deployment.v1.DeploymentState" json:"state" yaml:"state"`
	Hash      []byte          `protobuf:"bytes,3,opt,name=hash,proto3" json:"hash" yaml:"hash"`
	CreatedAt int64           `protobuf:"varint,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
}

Deployment stores deploymentID, state and checksum details

func (*Deployment) Descriptor 

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

func (*Deployment) GetCreatedAt 

func (m *Deployment) GetCreatedAt() int64

func (*Deployment) GetHash 

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

func (*Deployment) GetID 

func (m *Deployment) GetID() DeploymentID

func (*Deployment) GetState 

func (m *Deployment) GetState() DeploymentState

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 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 DeploymentState 

type DeploymentState int32

DeploymentState is an enum which refers to state of deployment 

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

func (DeploymentState) EnumDescriptor 

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

func (DeploymentState) String 

func (x DeploymentState) String() string

type DepositAuthorization 

type DepositAuthorization 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 NewDepositAuthorization 

func NewDepositAuthorization(spendLimit sdk.Coin) *DepositAuthorization

NewDepositAuthorization creates a new DepositAuthorization object.

func (*DepositAuthorization) Accept 

func (m *DepositAuthorization) Accept(_ sdk.Context, msg sdk.Msg) (authz.AcceptResponse, error)

Accept implements Authorization.Accept.

func (*DepositAuthorization) Descriptor 

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

func (*DepositAuthorization) GetSpendLimit 

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

func (*DepositAuthorization) Marshal 

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

func (*DepositAuthorization) MarshalTo 

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

func (*DepositAuthorization) MarshalToSizedBuffer 

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

func (*DepositAuthorization) MsgTypeURL 

func (m *DepositAuthorization) MsgTypeURL() string

MsgTypeURL implements Authorization.MsgTypeURL.

func (*DepositAuthorization) ProtoMessage 

func (*DepositAuthorization) ProtoMessage()

func (*DepositAuthorization) Reset 

func (m *DepositAuthorization) Reset()

func (*DepositAuthorization) Size 

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

func (*DepositAuthorization) String 

func (m *DepositAuthorization) String() string

func (*DepositAuthorization) Unmarshal 

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

func (*DepositAuthorization) ValidateBasic 

func (m *DepositAuthorization) ValidateBasic() error

ValidateBasic implements Authorization.ValidateBasic.

func (*DepositAuthorization) XXX_DiscardUnknown 

func (m *DepositAuthorization) XXX_DiscardUnknown()

func (*DepositAuthorization) XXX_Marshal 

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

func (*DepositAuthorization) XXX_Merge 

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

func (*DepositAuthorization) XXX_Size 

func (m *DepositAuthorization) XXX_Size() int

func (*DepositAuthorization) XXX_Unmarshal 

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

type EventDeploymentClosed 

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

EventDeploymentClosed is triggered when deployment is closed on chain

func (*EventDeploymentClosed) Descriptor 

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

func (*EventDeploymentClosed) GetID 

func (m *EventDeploymentClosed) GetID() DeploymentID

func (*EventDeploymentClosed) Marshal 

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

func (*EventDeploymentClosed) MarshalTo 

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

func (*EventDeploymentClosed) MarshalToSizedBuffer 

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

func (*EventDeploymentClosed) ProtoMessage 

func (*EventDeploymentClosed) ProtoMessage()

func (*EventDeploymentClosed) Reset 

func (m *EventDeploymentClosed) Reset()

func (*EventDeploymentClosed) Size 

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

func (*EventDeploymentClosed) String 

func (m *EventDeploymentClosed) String() string

func (*EventDeploymentClosed) Unmarshal 

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

func (*EventDeploymentClosed) XXX_DiscardUnknown 

func (m *EventDeploymentClosed) XXX_DiscardUnknown()

func (*EventDeploymentClosed) XXX_Marshal 

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

func (*EventDeploymentClosed) XXX_Merge 

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

func (*EventDeploymentClosed) XXX_Size 

func (m *EventDeploymentClosed) XXX_Size() int

func (*EventDeploymentClosed) XXX_Unmarshal 

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

type EventDeploymentCreated 

type EventDeploymentCreated struct {
	ID   DeploymentID `protobuf:"bytes,1,opt,name=id,proto3" json:"id" yaml:"id"`
	Hash []byte       `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash" yaml:"hash"`
}

EventDeploymentCreated event is triggered when deployment is created on chain

func (*EventDeploymentCreated) Descriptor 

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

func (*EventDeploymentCreated) GetHash 

func (m *EventDeploymentCreated) GetHash() []byte

func (*EventDeploymentCreated) GetID 

func (m *EventDeploymentCreated) GetID() DeploymentID

func (*EventDeploymentCreated) Marshal 

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

func (*EventDeploymentCreated) MarshalTo 

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

func (*EventDeploymentCreated) MarshalToSizedBuffer 

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

func (*EventDeploymentCreated) ProtoMessage 

func (*EventDeploymentCreated) ProtoMessage()

func (*EventDeploymentCreated) Reset 

func (m *EventDeploymentCreated) Reset()

func (*EventDeploymentCreated) Size 

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

func (*EventDeploymentCreated) String 

func (m *EventDeploymentCreated) String() string

func (*EventDeploymentCreated) Unmarshal 

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

func (*EventDeploymentCreated) XXX_DiscardUnknown 

func (m *EventDeploymentCreated) XXX_DiscardUnknown()

func (*EventDeploymentCreated) XXX_Marshal 

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

func (*EventDeploymentCreated) XXX_Merge 

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

func (*EventDeploymentCreated) XXX_Size 

func (m *EventDeploymentCreated) XXX_Size() int

func (*EventDeploymentCreated) XXX_Unmarshal 

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

type EventDeploymentUpdated 

type EventDeploymentUpdated struct {
	ID   DeploymentID `protobuf:"bytes,1,opt,name=id,proto3" json:"id" yaml:"id"`
	Hash []byte       `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash" yaml:"hash"`
}

EventDeploymentUpdated is triggered when deployment is updated on chain

func (*EventDeploymentUpdated) Descriptor 

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

func (*EventDeploymentUpdated) GetHash 

func (m *EventDeploymentUpdated) GetHash() []byte

func (*EventDeploymentUpdated) GetID 

func (m *EventDeploymentUpdated) GetID() DeploymentID

func (*EventDeploymentUpdated) Marshal 

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

func (*EventDeploymentUpdated) MarshalTo 

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

func (*EventDeploymentUpdated) MarshalToSizedBuffer 

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

func (*EventDeploymentUpdated) ProtoMessage 

func (*EventDeploymentUpdated) ProtoMessage()

func (*EventDeploymentUpdated) Reset 

func (m *EventDeploymentUpdated) Reset()

func (*EventDeploymentUpdated) Size 

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

func (*EventDeploymentUpdated) String 

func (m *EventDeploymentUpdated) String() string

func (*EventDeploymentUpdated) Unmarshal 

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

func (*EventDeploymentUpdated) XXX_DiscardUnknown 

func (m *EventDeploymentUpdated) XXX_DiscardUnknown()

func (*EventDeploymentUpdated) XXX_Marshal 

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

func (*EventDeploymentUpdated) XXX_Merge 

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

func (*EventDeploymentUpdated) XXX_Size 

func (m *EventDeploymentUpdated) XXX_Size() int

func (*EventDeploymentUpdated) XXX_Unmarshal 

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

type EventGroupClosed 

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

EventGroupClosed is triggered when deployment group is closed

func (*EventGroupClosed) Descriptor 

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

func (*EventGroupClosed) GetID 

func (m *EventGroupClosed) GetID() GroupID

func (*EventGroupClosed) Marshal 

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

func (*EventGroupClosed) MarshalTo 

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

func (*EventGroupClosed) MarshalToSizedBuffer 

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

func (*EventGroupClosed) ProtoMessage 

func (*EventGroupClosed) ProtoMessage()

func (*EventGroupClosed) Reset 

func (m *EventGroupClosed) Reset()

func (*EventGroupClosed) Size 

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

func (*EventGroupClosed) String 

func (m *EventGroupClosed) String() string

func (*EventGroupClosed) Unmarshal 

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

func (*EventGroupClosed) XXX_DiscardUnknown 

func (m *EventGroupClosed) XXX_DiscardUnknown()

func (*EventGroupClosed) XXX_Marshal 

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

func (*EventGroupClosed) XXX_Merge 

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

func (*EventGroupClosed) XXX_Size 

func (m *EventGroupClosed) XXX_Size() int

func (*EventGroupClosed) XXX_Unmarshal 

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

type EventGroupPaused 

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

EventGroupPaused is triggered when deployment group is paused

func (*EventGroupPaused) Descriptor 

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

func (*EventGroupPaused) GetID 

func (m *EventGroupPaused) GetID() GroupID

func (*EventGroupPaused) Marshal 

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

func (*EventGroupPaused) MarshalTo 

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

func (*EventGroupPaused) MarshalToSizedBuffer 

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

func (*EventGroupPaused) ProtoMessage 

func (*EventGroupPaused) ProtoMessage()

func (*EventGroupPaused) Reset 

func (m *EventGroupPaused) Reset()

func (*EventGroupPaused) Size 

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

func (*EventGroupPaused) String 

func (m *EventGroupPaused) String() string

func (*EventGroupPaused) Unmarshal 

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

func (*EventGroupPaused) XXX_DiscardUnknown 

func (m *EventGroupPaused) XXX_DiscardUnknown()

func (*EventGroupPaused) XXX_Marshal 

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

func (*EventGroupPaused) XXX_Merge 

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

func (*EventGroupPaused) XXX_Size 

func (m *EventGroupPaused) XXX_Size() int

func (*EventGroupPaused) XXX_Unmarshal 

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

type EventGroupStarted 

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

EventGroupStarted is triggered when deployment group is started

func (*EventGroupStarted) Descriptor 

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

func (*EventGroupStarted) GetID 

func (m *EventGroupStarted) GetID() GroupID

func (*EventGroupStarted) Marshal 

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

func (*EventGroupStarted) MarshalTo 

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

func (*EventGroupStarted) MarshalToSizedBuffer 

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

func (*EventGroupStarted) ProtoMessage 

func (*EventGroupStarted) ProtoMessage()

func (*EventGroupStarted) Reset 

func (m *EventGroupStarted) Reset()

func (*EventGroupStarted) Size 

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

func (*EventGroupStarted) String 

func (m *EventGroupStarted) String() string

func (*EventGroupStarted) Unmarshal 

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

func (*EventGroupStarted) XXX_DiscardUnknown 

func (m *EventGroupStarted) XXX_DiscardUnknown()

func (*EventGroupStarted) XXX_Marshal 

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

func (*EventGroupStarted) XXX_Merge 

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

func (*EventGroupStarted) XXX_Size 

func (m *EventGroupStarted) XXX_Size() int

func (*EventGroupStarted) XXX_Unmarshal 

func (m *EventGroupStarted) 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 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 NewMsgDepositDeployment 

func NewMsgDepositDeployment(id DeploymentID, amount sdk.Coin, depositor string) *MsgDepositDeployment

NewMsgDepositDeployment creates a new MsgDepositDeployment instance

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 (m *MsgDepositDeployment) GetID() DeploymentID

func (*MsgDepositDeployment) GetSigners 

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

GetSigners defines whose signature is required

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) Route 

func (msg *MsgDepositDeployment) Route() string

Route implements the sdk.Msg interface

func (*MsgDepositDeployment) Size 

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

func (*MsgDepositDeployment) String 

func (m *MsgDepositDeployment) String() string

func (*MsgDepositDeployment) Type 

func (msg *MsgDepositDeployment) Type() string

Type implements the sdk.Msg interface

func (*MsgDepositDeployment) Unmarshal 

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

func (*MsgDepositDeployment) ValidateBasic 

func (msg *MsgDepositDeployment) ValidateBasic() error

ValidateBasic does basic validation like check owner and groups length

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 (m *MsgDepositDeploymentResponse) String() 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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.