v1

package
v0.1.8 Latest Latest
Warning

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

 Go to latest Published: Nov 26, 2025 License: Apache-2.0 Imports: 16 Imported by: 21

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 (
	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")
	ErrInvalidEscrowID = cerrors.Register(ModuleName, errInvalidEscrowID, "invalid escrow id")
)
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 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 (
	// ModuleCdc references the global x/deployment 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/deployment and
	// defined at the application level.
	//
	// Deprecated: ModuleCdc use is deprecated
	ModuleCdc = codec.NewProtoCodec(cdctypes.NewInterfaceRegistry())
)

Functions

func DeploymentPrefix 

func DeploymentPrefix() []byte

func GroupPrefix 

func GroupPrefix() []byte

func ParamsPrefix 

func ParamsPrefix() []byte

Types

type Deployment 

type Deployment struct {
	// ID is the unique identifier of the deployment.
	ID DeploymentID `protobuf:"bytes,1,opt,name=id,proto3" json:"id" yaml:"id"`
	// State defines the sate of the deployment.
	// A deployment can be either active or inactive.
	State Deployment_State `protobuf:"varint,2,opt,name=state,proto3,enum=akash.deployment.v1.Deployment_State" json:"state" yaml:"state"`
	// Hash is an hashed representation of the deployment.
	Hash []byte `protobuf:"bytes,3,opt,name=hash,proto3" json:"hash" yaml:"hash"`
	// CreatedAt indicates when the deployment was created as a block height value.
	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() Deployment_State

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 is the account bech32 address of the user who owns the deployment.
	// It is a string representing a valid bech32 account address.
	//
	// Example:
	//   "akash1..."
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner" yaml:"owner"`
	// Dseq (deployment sequence number) is a unique numeric identifier for the deployment.
	// It is used to differentiate deployments created by the same owner.
	DSeq uint64 `protobuf:"varint,2,opt,name=dseq,proto3" json:"dseq" yaml:"dseq"`
}

DeploymentID represents a unique identifier for a specific deployment on the network. It is composed of two fields: an owner address and a sequence number (dseq).

func DeploymentIDFromEscrowID 

func DeploymentIDFromEscrowID(id ev1.Account) (DeploymentID, error)

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

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

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

func (id DeploymentID) ToEscrowAccountID() ev1.Account

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 EventDeploymentClosed 

type EventDeploymentClosed struct {
	// ID is the unique identifier of the deployment.
	ID DeploymentID `protobuf:"bytes,1,opt,name=id,proto3" json:"id" yaml:"id"`
}

EventDeploymentClosed is triggered when deployment is closed on chain. It contains all the information required to identify a deployment.

func (*EventDeploymentClosed) Descriptor 

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

func (*EventDeploymentClosed) Equal 

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

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 is the unique identifier of the deployment.
	ID DeploymentID `protobuf:"bytes,1,opt,name=id,proto3" json:"id" yaml:"id"`
	// Hash is an hashed representation of the deployment.
	Hash []byte `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash" yaml:"hash"`
}

EventDeploymentCreated event is triggered when deployment is created on chain. It contains all the information required to identify a deployment.

func (*EventDeploymentCreated) Descriptor 

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

func (*EventDeploymentCreated) Equal 

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

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 is the unique identifier of the deployment.
	ID DeploymentID `protobuf:"bytes,1,opt,name=id,proto3" json:"id" yaml:"id"`
	// Hash is an hashed representation of the deployment.
	Hash []byte `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash" yaml:"hash"`
}

EventDeploymentUpdated is triggered when deployment is updated on chain. It contains all the information required to identify a deployment.

func (*EventDeploymentUpdated) Descriptor 

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

func (*EventDeploymentUpdated) Equal 

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

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 is the unique identifier of the group.
	ID GroupID `protobuf:"bytes,1,opt,name=id,proto3" json:"id" yaml:"id"`
}

EventGroupClosed is triggered when deployment group is closed. It contains all the information required to identify a group.

func (*EventGroupClosed) Descriptor 

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

func (*EventGroupClosed) Equal 

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

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 is the unique identifier of the group.
	ID GroupID `protobuf:"bytes,1,opt,name=id,proto3" json:"id" yaml:"id"`
}

EventGroupPaused is triggered when deployment group is paused. It contains all the information required to identify a group.

func (*EventGroupPaused) Descriptor 

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

func (*EventGroupPaused) Equal 

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

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 is the unique identifier of the group.
	ID GroupID `protobuf:"bytes,1,opt,name=id,proto3" json:"id" yaml:"id"`
}

EventGroupStarted is triggered when deployment group is started. It contains all the information required to identify a group.

func (*EventGroupStarted) Descriptor 

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

func (*EventGroupStarted) Equal 

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

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 is the account address of the user who owns the group.
	// It is a string representing a valid account address.
	//
	// Example:
	//   "akash1..."
	Owner string `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner" yaml:"owner"`
	// Dseq (deployment sequence number) is a unique numeric identifier for the deployment.
	// It is used to differentiate deployments created by the same owner.
	DSeq uint64 `protobuf:"varint,2,opt,name=dseq,proto3" json:"dseq" yaml:"dseq"`
	// Gseq (group sequence number) is a unique numeric identifier for the group.
	// It is used to differentiate groups created by the same owner in a deployment.
	GSeq uint32 `protobuf:"varint,3,opt,name=gseq,proto3" json:"gseq" yaml:"gseq"`
}

GroupID uniquely identifies a group within a deployment on the network. A group represents a specific collection of resources or configurations within a deployment. It stores owner, deployment sequence number (dseq) and group sequence number (gseq).

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

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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