v1beta4

package
v0.0.2-rc2 Latest Latest
Warning

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

 Go to latest Published: Oct 28, 2024 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      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 */
}

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           Endpoint_Kind `protobuf:"varint,1,opt,name=kind,proto3,enum=akash.base.resources.v1beta4.Endpoint_Kind" json:"kind,omitempty"`
	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

This 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 {
	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 cpu config 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   ResourceValue                                      `protobuf:"bytes,1,opt,name=quantity,proto3" json:"size" yaml:"size"`
	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 github_com_cosmos_cosmos_sdk_types.Int `protobuf:"bytes,1,opt,name=val,proto3,customtype=github.com/cosmos/cosmos-sdk/types.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        uint32    `protobuf:"varint,1,opt,name=id,proto3" json:"id" yaml:"id"`
	CPU       *CPU      `protobuf:"bytes,2,opt,name=cpu,proto3" json:"cpu,omitempty" yaml:"cpu,omitempty"`
	Memory    *Memory   `protobuf:"bytes,3,opt,name=memory,proto3" json:"memory,omitempty" yaml:"memory,omitempty"`
	Storage   Volumes   `protobuf:"bytes,4,rep,name=storage,proto3,castrepeated=Volumes" json:"storage,omitempty" yaml:"storage,omitempty"`
	GPU       *GPU      `protobuf:"bytes,5,opt,name=gpu,proto3" json:"gpu,omitempty" yaml:"gpu,omitempty"`
	Endpoints Endpoints `protobuf:"bytes,6,rep,name=endpoints,proto3,castrepeated=Endpoints" json:"endpoints,omitempty" yaml:"endpoints,omitempty"`
}

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       string                                             `protobuf:"bytes,1,opt,name=name,proto3" json:"name" yaml:"name"`
	Quantity   ResourceValue                                      `protobuf:"bytes,2,opt,name=quantity,proto3" json:"size" yaml:"size"`
	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

  • cpu.pb.go
  • endpoint.go
  • endpoint.pb.go
  • gpu.pb.go
  • memory.pb.go
  • resources.go
  • resources.pb.go
  • resourcevalue.go
  • resourcevalue.pb.go
  • storage.pb.go

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.