v1beta4

package
v0.1.9 Latest Latest
Warning

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

 Go to latest Published: Feb 24, 2026 License: Apache-2.0 Imports: 10 Imported by: 11

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCpu        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCpu          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCpu = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthEndpoint        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEndpoint          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEndpoint = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthGpu        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGpu          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGpu = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthMemory        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMemory          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMemory = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthResources        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowResources          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupResources = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrOverflow       = errors.New("resource value overflow")
	ErrCannotSub      = errors.New("cannot subtract resources when lhs does not have same units as rhs")
	ErrNegativeResult = errors.New("result of subtraction is negative")
)
View Source 
var (
	ErrInvalidLengthResourcevalue        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowResourcevalue          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupResourcevalue = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthStorage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStorage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupStorage = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Endpoint_Kind_name = map[int32]string{
	0: "SHARED_HTTP",
	1: "RANDOM_PORT",
	2: "LEASED_IP",
}
View Source 
var Endpoint_Kind_value = map[string]int32{
	"SHARED_HTTP": 0,
	"RANDOM_PORT": 1,
	"LEASED_IP":   2,
}

Functions

This section is empty.

Types

type CPU 

type CPU struct {
	// Units of the CPU, which represents the number of CPUs available.
	// This field is required and must be a non-negative integer.
	Units ResourceValue `protobuf:"bytes,1,opt,name=units,proto3" json:"units"`
	// Attributes holds a list of key-value attributes that describe the GPU, such as its model, memory and interface.
	// This field is required and must be a list of `Attribute` messages.
	Attributes pkg_akt_dev_go_node_types_attributes_v1.Attributes `` /* 165-byte string literal not displayed */
}

CPU stores resource units and cpu config attributes.

func (*CPU) Descriptor 

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

func (CPU) Dup 

func (m CPU) Dup() *CPU

func (*CPU) Equal 

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

func (*CPU) EqualUnits 

func (m *CPU) EqualUnits(that *CPU) bool

func (*CPU) GetAttributes 

func (m *CPU) GetAttributes() pkg_akt_dev_go_node_types_attributes_v1.Attributes

func (*CPU) GetUnits 

func (m *CPU) GetUnits() ResourceValue

func (*CPU) Marshal 

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

func (*CPU) MarshalTo 

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

func (*CPU) MarshalToSizedBuffer 

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

func (*CPU) ProtoMessage 

func (*CPU) ProtoMessage()

func (*CPU) Reset 

func (m *CPU) Reset()

func (*CPU) Size 

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

func (*CPU) String 

func (m *CPU) String() string

func (*CPU) Unmarshal 

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

func (*CPU) XXX_DiscardUnknown 

func (m *CPU) XXX_DiscardUnknown()

func (*CPU) XXX_Marshal 

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

func (*CPU) XXX_Merge 

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

func (*CPU) XXX_Size 

func (m *CPU) XXX_Size() int

func (*CPU) XXX_Unmarshal 

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

type Endpoint 

type Endpoint struct {
	// Kind describes how the endpoint is implemented when the lease is deployed.
	Kind Endpoint_Kind `protobuf:"varint,1,opt,name=kind,proto3,enum=akash.base.resources.v1beta4.Endpoint_Kind" json:"kind,omitempty"`
	// SequenceNumber represents a sequence number for the Endpoint.
	SequenceNumber uint32 `protobuf:"varint,2,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number" yaml:"sequence_number"`
}

Endpoint describes a publicly accessible IP service.

func (*Endpoint) Descriptor 

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

func (*Endpoint) Equal 

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

func (*Endpoint) GetKind 

func (m *Endpoint) GetKind() Endpoint_Kind

func (*Endpoint) GetSequenceNumber 

func (m *Endpoint) GetSequenceNumber() uint32

func (*Endpoint) Marshal 

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

func (*Endpoint) MarshalTo 

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

func (*Endpoint) MarshalToSizedBuffer 

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

func (*Endpoint) ProtoMessage 

func (*Endpoint) ProtoMessage()

func (*Endpoint) Reset 

func (m *Endpoint) Reset()

func (*Endpoint) Size 

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

func (*Endpoint) String 

func (m *Endpoint) String() string

func (*Endpoint) Unmarshal 

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

func (*Endpoint) XXX_DiscardUnknown 

func (m *Endpoint) XXX_DiscardUnknown()

func (*Endpoint) XXX_Marshal 

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

func (*Endpoint) XXX_Merge 

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

func (*Endpoint) XXX_Size 

func (m *Endpoint) XXX_Size() int

func (*Endpoint) XXX_Unmarshal 

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

type Endpoint_Kind 

type Endpoint_Kind int32

Kind describes how the endpoint is implemented when the lease is deployed. 

const (
	// Describes an endpoint that becomes a Kubernetes Ingress.
	Endpoint_SHARED_HTTP Endpoint_Kind = 0
	// Describes an endpoint that becomes a Kubernetes NodePort.
	Endpoint_RANDOM_PORT Endpoint_Kind = 1
	// Describes an endpoint that becomes a leased IP.
	Endpoint_LEASED_IP Endpoint_Kind = 2
)

func (Endpoint_Kind) EnumDescriptor 

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

func (Endpoint_Kind) String 

func (x Endpoint_Kind) String() string

type Endpoints 

type Endpoints []Endpoint

func (Endpoints) Dup 

func (u Endpoints) Dup() Endpoints

func (Endpoints) Len 

func (u Endpoints) Len() int

func (Endpoints) Less 

func (u Endpoints) Less(i, j int) bool

func (Endpoints) Swap 

func (u Endpoints) Swap(i, j int)

type GPU 

type GPU struct {
	// The resource value of the GPU, which represents the number of GPUs available.
	// This field is required and must be a non-negative integer.
	Units      ResourceValue                                      `protobuf:"bytes,1,opt,name=units,proto3" json:"units"`
	Attributes pkg_akt_dev_go_node_types_attributes_v1.Attributes `` /* 165-byte string literal not displayed */
}

GPU stores resource units and gpu configuration attributes.

func (*GPU) Descriptor 

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

func (GPU) Dup 

func (m GPU) Dup() *GPU

func (*GPU) Equal 

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

func (*GPU) EqualUnits 

func (m *GPU) EqualUnits(that *GPU) bool

func (*GPU) GetAttributes 

func (m *GPU) GetAttributes() pkg_akt_dev_go_node_types_attributes_v1.Attributes

func (*GPU) GetUnits 

func (m *GPU) GetUnits() ResourceValue

func (*GPU) Marshal 

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

func (*GPU) MarshalTo 

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

func (*GPU) MarshalToSizedBuffer 

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

func (*GPU) ProtoMessage 

func (*GPU) ProtoMessage()

func (*GPU) Reset 

func (m *GPU) Reset()

func (*GPU) Size 

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

func (*GPU) String 

func (m *GPU) String() string

func (*GPU) Unmarshal 

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

func (*GPU) XXX_DiscardUnknown 

func (m *GPU) XXX_DiscardUnknown()

func (*GPU) XXX_Marshal 

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

func (*GPU) XXX_Merge 

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

func (*GPU) XXX_Size 

func (m *GPU) XXX_Size() int

func (*GPU) XXX_Unmarshal 

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

type Memory 

type Memory struct {
	// Quantity of memory available, which represents the amount of memory in bytes.
	// This field is required and must be a non-negative integer.
	Quantity ResourceValue `protobuf:"bytes,1,opt,name=quantity,proto3" json:"size" yaml:"size"`
	// Attributes that describe the memory, such as its type and speed.
	// This field is required and must be a list of Attribute key-values.
	Attributes pkg_akt_dev_go_node_types_attributes_v1.Attributes `` /* 165-byte string literal not displayed */
}

Memory stores resource quantity and memory attributes.

func (*Memory) Descriptor 

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

func (Memory) Dup 

func (m Memory) Dup() *Memory

func (*Memory) Equal 

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

func (*Memory) EqualUnits 

func (m *Memory) EqualUnits(that *Memory) bool

func (*Memory) GetAttributes 

func (m *Memory) GetAttributes() pkg_akt_dev_go_node_types_attributes_v1.Attributes

func (*Memory) GetQuantity 

func (m *Memory) GetQuantity() ResourceValue

func (*Memory) Marshal 

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

func (*Memory) MarshalTo 

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

func (*Memory) MarshalToSizedBuffer 

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

func (*Memory) ProtoMessage 

func (*Memory) ProtoMessage()

func (*Memory) Reset 

func (m *Memory) Reset()

func (*Memory) Size 

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

func (*Memory) String 

func (m *Memory) String() string

func (*Memory) Unmarshal 

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

func (*Memory) XXX_DiscardUnknown 

func (m *Memory) XXX_DiscardUnknown()

func (*Memory) XXX_Marshal 

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

func (*Memory) XXX_Merge 

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

func (*Memory) XXX_Size 

func (m *Memory) XXX_Size() int

func (*Memory) XXX_Unmarshal 

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

type ResUnit 

type ResUnit interface {
	Equals(ResUnit) bool
	Add(unit ResUnit) bool
}

type ResourceValue 

type ResourceValue struct {
	Val cosmossdk_io_math.Int `protobuf:"bytes,1,opt,name=val,proto3,customtype=cosmossdk.io/math.Int" json:"val"`
}

Unit stores cpu, memory and storage metrics.

func NewResourceValue 

func NewResourceValue(val uint64) ResourceValue

func (*ResourceValue) Descriptor 

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

func (ResourceValue) Dup 

func (m ResourceValue) Dup() ResourceValue

func (*ResourceValue) Equal 

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

func (*ResourceValue) Marshal 

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

func (*ResourceValue) MarshalTo 

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

func (*ResourceValue) MarshalToSizedBuffer 

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

func (*ResourceValue) ProtoMessage 

func (*ResourceValue) ProtoMessage()

func (*ResourceValue) Reset 

func (m *ResourceValue) Reset()

func (*ResourceValue) Size 

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

func (*ResourceValue) String 

func (m *ResourceValue) String() string

func (*ResourceValue) Unmarshal 

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

func (ResourceValue) Value 

func (m ResourceValue) Value() uint64

func (*ResourceValue) XXX_DiscardUnknown 

func (m *ResourceValue) XXX_DiscardUnknown()

func (*ResourceValue) XXX_Marshal 

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

func (*ResourceValue) XXX_Merge 

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

func (*ResourceValue) XXX_Size 

func (m *ResourceValue) XXX_Size() int

func (*ResourceValue) XXX_Unmarshal 

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

type Resources 

type Resources struct {
	// Id is a unique identifier for the resources.
	ID uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id" yaml:"id"`
	// CPU resources available, including the architecture, number of cores and other details.
	// This field is optional and can be empty if no CPU resources are available.
	CPU *CPU `protobuf:"bytes,2,opt,name=cpu,proto3" json:"cpu,omitempty" yaml:"cpu,omitempty"`
	// Memory resources available, including the quantity and attributes.
	// This field is optional and can be empty if no memory resources are available.
	Memory *Memory `protobuf:"bytes,3,opt,name=memory,proto3" json:"memory,omitempty" yaml:"memory,omitempty"`
	// Storage resources available, including the quantity and attributes.
	// This field is optional and can be empty if no storage resources are available.
	Storage Volumes `protobuf:"bytes,4,rep,name=storage,proto3,castrepeated=Volumes" json:"storage,omitempty" yaml:"storage,omitempty"`
	// GPU resources available, including the type, architecture and other details.
	// This field is optional and can be empty if no GPU resources are available.
	GPU *GPU `protobuf:"bytes,5,opt,name=gpu,proto3" json:"gpu,omitempty" yaml:"gpu,omitempty"`
	// Endpoint resources available
	Endpoints Endpoints `protobuf:"bytes,6,rep,name=endpoints,proto3,castrepeated=Endpoints" json:"endpoints" yaml:"endpoints"`
}

Resources describes all available resources types for deployment/node etc if field is nil resource is not present in the given data-structure

func (*Resources) Descriptor 

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

func (Resources) Dup 

func (m Resources) Dup() Resources

func (*Resources) Equal 

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

func (*Resources) GetCPU 

func (m *Resources) GetCPU() *CPU

func (*Resources) GetEndpoints 

func (m *Resources) GetEndpoints() Endpoints

func (*Resources) GetGPU 

func (m *Resources) GetGPU() *GPU

func (*Resources) GetID 

func (m *Resources) GetID() uint32

func (*Resources) GetMemory 

func (m *Resources) GetMemory() *Memory

func (*Resources) GetStorage 

func (m *Resources) GetStorage() Volumes

func (Resources) In 

func (m Resources) In(rhs Resources) bool

func (*Resources) Marshal 

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

func (*Resources) MarshalTo 

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

func (*Resources) MarshalToSizedBuffer 

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

func (*Resources) ProtoMessage 

func (*Resources) ProtoMessage()

func (*Resources) Reset 

func (m *Resources) Reset()

func (*Resources) Size 

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

func (*Resources) String 

func (m *Resources) String() string

func (*Resources) Unmarshal 

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

func (Resources) Validate 

func (m Resources) Validate() error

func (*Resources) XXX_DiscardUnknown 

func (m *Resources) XXX_DiscardUnknown()

func (*Resources) XXX_Marshal 

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

func (*Resources) XXX_Merge 

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

func (*Resources) XXX_Size 

func (m *Resources) XXX_Size() int

func (*Resources) XXX_Unmarshal 

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

type Storage 

type Storage struct {
	// Name holds an arbitrary name for the storage resource.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name" yaml:"name"`
	// Quantity of storage available, which represents the amount of memory in bytes.
	// This field is required and must be a non-negative integer.
	Quantity ResourceValue `protobuf:"bytes,2,opt,name=quantity,proto3" json:"size" yaml:"size"`
	// Attributes that describe the storage.
	// This field is required and must be a list of Attribute key-values.
	Attributes pkg_akt_dev_go_node_types_attributes_v1.Attributes `` /* 165-byte string literal not displayed */
}

Storage stores resource quantity and storage attributes.

func (*Storage) Descriptor 

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

func (Storage) Dup 

func (m Storage) Dup() *Storage

func (*Storage) Equal 

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

func (*Storage) GetAttributes 

func (m *Storage) GetAttributes() pkg_akt_dev_go_node_types_attributes_v1.Attributes

func (*Storage) GetName 

func (m *Storage) GetName() string

func (*Storage) GetQuantity 

func (m *Storage) GetQuantity() ResourceValue

func (*Storage) Marshal 

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

func (*Storage) MarshalTo 

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

func (*Storage) MarshalToSizedBuffer 

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

func (*Storage) ProtoMessage 

func (*Storage) ProtoMessage()

func (*Storage) Reset 

func (m *Storage) Reset()

func (*Storage) Size 

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

func (*Storage) String 

func (m *Storage) String() string

func (*Storage) Unmarshal 

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

func (*Storage) XXX_DiscardUnknown 

func (m *Storage) XXX_DiscardUnknown()

func (*Storage) XXX_Marshal 

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

func (*Storage) XXX_Merge 

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

func (*Storage) XXX_Size 

func (m *Storage) XXX_Size() int

func (*Storage) XXX_Unmarshal 

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

type Unit 

type Unit interface {
	String() string
}

type UnitType 

type UnitType int

type Volumes 

type Volumes []Storage

func (Volumes) Dup 

func (m Volumes) Dup() Volumes

func (Volumes) Equal 

func (m Volumes) Equal(rhs Volumes) bool

func (Volumes) EqualUnits 

func (m Volumes) EqualUnits(that Volumes) bool

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.