v1beta1

package
v0.0.0-...-b3a6efc Latest Latest
Warning

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

 Go to latest Published: Jan 23, 2023 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrAttributesDuplicateKeys = errors.New("attributes cannot have duplicate keys")
	ErrInvalidAttributeKey     = errors.New("attribute key does not match regexp " + attributeNameRegexpString)
)
View Source 
var (
	ErrInvalidLengthAttribute        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAttribute          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAttribute = 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 (
	ErrInvalidLengthResource        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowResource          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupResource = fmt.Errorf("proto: unexpected end of group")
)
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 Endpoint_Kind_name = map[int32]string{
	0: "SHARED_HTTP",
	1: "RANDOM_PORT",
}
View Source 
var Endpoint_Kind_value = map[string]int32{
	"SHARED_HTTP": 0,
	"RANDOM_PORT": 1,
}

Functions

func AttributesSubsetOf 

func AttributesSubsetOf(a, b Attributes) bool

AttributesSubsetOf check if a is subset of that For example there are two yaml files being converted into these attributes example 1: a is subset of b --- // a // nolint: gofmt attributes: 

region:
  - us-east-1

--- b attributes: 

region:
  - us-east-1
  - us-east-2

example 2: a is not subset of b attributes: 

region:
  - us-east-1

--- b attributes: 

region:
  - us-east-2
  - us-east-3

example 3: a is subset of b attributes: 

region:
  - us-east-2
  - us-east-3

--- b attributes: 

region:
  - us-east-2

Types

type Attribute 

type Attribute struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty" yaml:"key"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty" yaml:"value"`
}

Attribute represents key value pair

func NewStringAttribute 

func NewStringAttribute(key, val string) Attribute

func (*Attribute) Descriptor 

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

func (*Attribute) Equal 

func (m *Attribute) Equal(rhs *Attribute) bool

func (*Attribute) Marshal 

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

func (*Attribute) MarshalTo 

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

func (*Attribute) MarshalToSizedBuffer 

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

func (*Attribute) ProtoMessage 

func (*Attribute) ProtoMessage()

func (*Attribute) Reset 

func (m *Attribute) Reset()

func (*Attribute) Size 

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

func (*Attribute) String 

func (m *Attribute) String() string

func (Attribute) SubsetOf 

func (m Attribute) SubsetOf(rhs Attribute) bool

func (*Attribute) Unmarshal 

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

func (*Attribute) XXX_DiscardUnknown 

func (m *Attribute) XXX_DiscardUnknown()

func (*Attribute) XXX_Marshal 

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

func (*Attribute) XXX_Merge 

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

func (*Attribute) XXX_Size 

func (m *Attribute) XXX_Size() int

func (*Attribute) XXX_Unmarshal 

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

type AttributeValue 

type AttributeValue string

type Attributes 

type Attributes []Attribute

Attributes purpose of using this type in favor of Cosmos's sdk.Attribute is ability to later extend it with operators to support querying on things like cpu/memory/storage attributes At this moment type though is same as sdk.Attributes but all akash libraries were turned to use a new one

func (Attributes) SubsetOf 

func (attr Attributes) SubsetOf(that Attributes) bool

func (Attributes) Validate 

func (attr Attributes) Validate() error

type CPU 

type CPU struct {
	Units      ResourceValue `protobuf:"bytes,1,opt,name=units,proto3" json:"units"`
	Attributes []Attribute   `protobuf:"bytes,2,rep,name=attributes,proto3" json:"attributes,omitempty" yaml:"cpu,omitempty"`
}

CPU stores resource units and cpu config attributes

func (*CPU) Descriptor 

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

func (*CPU) Equal 

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

func (*CPU) GetAttributes 

func (m *CPU) GetAttributes() []Attribute

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.v1beta1.Endpoint_Kind" json:"kind,omitempty"`
}

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

func (Endpoint_Kind) EnumDescriptor 

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

func (Endpoint_Kind) String 

func (x Endpoint_Kind) String() string

type Memory 

type Memory struct {
	Quantity   ResourceValue `protobuf:"bytes,1,opt,name=quantity,proto3" json:"size" yaml:"size"`
	Attributes []Attribute   `protobuf:"bytes,2,rep,name=attributes,proto3" json:"attributes,omitempty" yaml:"cpu,omitempty"`
}

Memory stores resource quantity and memory attributes

func (*Memory) Descriptor 

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

func (*Memory) Equal 

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

func (*Memory) GetAttributes 

func (m *Memory) GetAttributes() []Attribute

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 PlacementRequirements 

type PlacementRequirements struct {
	// SignedBy list of keys that tenants expect to have signatures from
	SignedBy SignedBy `protobuf:"bytes,1,opt,name=signed_by,json=signedBy,proto3" json:"signed_by" yaml:"signed_by"`
	// Attribute list of attributes tenant expects from the provider
	Attributes []Attribute `protobuf:"bytes,2,rep,name=attributes,proto3" json:"attributes" yaml:"attributes"`
}

PlacementRequirements

func (*PlacementRequirements) Descriptor 

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

func (*PlacementRequirements) Marshal 

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

func (*PlacementRequirements) MarshalTo 

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

func (*PlacementRequirements) MarshalToSizedBuffer 

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

func (*PlacementRequirements) ProtoMessage 

func (*PlacementRequirements) ProtoMessage()

func (*PlacementRequirements) Reset 

func (m *PlacementRequirements) Reset()

func (*PlacementRequirements) Size 

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

func (*PlacementRequirements) String 

func (m *PlacementRequirements) String() string

func (*PlacementRequirements) Unmarshal 

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

func (*PlacementRequirements) XXX_DiscardUnknown 

func (m *PlacementRequirements) XXX_DiscardUnknown()

func (*PlacementRequirements) XXX_Marshal 

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

func (*PlacementRequirements) XXX_Merge 

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

func (*PlacementRequirements) XXX_Size 

func (m *PlacementRequirements) XXX_Size() int

func (*PlacementRequirements) XXX_Unmarshal 

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

type ResUnit 

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

type ResourceGroup 

type ResourceGroup interface {
	GetName() string
	GetResources() []Resources
}

ResourceGroup is the interface that wraps GetName and GetResources methods

type ResourceUnits 

type ResourceUnits struct {
	CPU       *CPU       `protobuf:"bytes,1,opt,name=cpu,proto3" json:"cpu,omitempty" yaml:"cpu,omitempty"`
	Memory    *Memory    `protobuf:"bytes,2,opt,name=memory,proto3" json:"memory,omitempty" yaml:"memory,omitempty"`
	Storage   *Storage   `protobuf:"bytes,3,opt,name=storage,proto3" json:"storage,omitempty" yaml:"storage,omitempty"`
	Endpoints []Endpoint `protobuf:"bytes,4,rep,name=endpoints,proto3" json:"endpoints" yaml:"endpoints"`
}

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

func (ResourceUnits) Add 

func (m ResourceUnits) Add(rhs ResourceUnits) (ResourceUnits, error)

AddUnit it rather searches for existing entry of the same type and sums values if type not found it appends

func (*ResourceUnits) Descriptor 

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

func (*ResourceUnits) Equal 

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

func (ResourceUnits) Equals 

func (m ResourceUnits) Equals(rhs ResourceUnits) bool

func (*ResourceUnits) GetCPU 

func (m *ResourceUnits) GetCPU() *CPU

func (*ResourceUnits) GetEndpoints 

func (m *ResourceUnits) GetEndpoints() []Endpoint

func (*ResourceUnits) GetMemory 

func (m *ResourceUnits) GetMemory() *Memory

func (*ResourceUnits) GetStorage 

func (m *ResourceUnits) GetStorage() *Storage

func (*ResourceUnits) Marshal 

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

func (*ResourceUnits) MarshalTo 

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

func (*ResourceUnits) MarshalToSizedBuffer 

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

func (*ResourceUnits) ProtoMessage 

func (*ResourceUnits) ProtoMessage()

func (*ResourceUnits) Reset 

func (m *ResourceUnits) Reset()

func (*ResourceUnits) Size 

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

func (*ResourceUnits) String 

func (m *ResourceUnits) String() string

func (ResourceUnits) Sub 

func (m ResourceUnits) Sub(rhs ResourceUnits) (ResourceUnits, error)

Sub tbd

func (*ResourceUnits) Unmarshal 

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

func (*ResourceUnits) XXX_DiscardUnknown 

func (m *ResourceUnits) XXX_DiscardUnknown()

func (*ResourceUnits) XXX_Marshal 

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

func (*ResourceUnits) XXX_Merge 

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

func (*ResourceUnits) XXX_Size 

func (m *ResourceUnits) XXX_Size() int

func (*ResourceUnits) XXX_Unmarshal 

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

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) 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 {
	Resources ResourceUnits `json:"resources"`
	Count     uint32        `json:"count"`
}

Resources stores Unit details and Count value

type SignedBy 

type SignedBy struct {
	// all_of all keys in this list must have signed attributes
	AllOf []string `protobuf:"bytes,1,rep,name=all_of,json=allOf,proto3" json:"all_of" yaml:"allOf"`
	// any_of at least of of the keys from the list must have signed attributes
	AnyOf []string `protobuf:"bytes,2,rep,name=any_of,json=anyOf,proto3" json:"any_of" yaml:"anyOf"`
}

SignedBy represents validation accounts that tenant expects signatures for provider attributes AllOf has precedence i.e. if there is at least one entry AnyOf is ignored regardless to how many entries there this behaviour to be discussed

func (*SignedBy) Descriptor 

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

func (*SignedBy) Marshal 

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

func (*SignedBy) MarshalTo 

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

func (*SignedBy) MarshalToSizedBuffer 

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

func (*SignedBy) ProtoMessage 

func (*SignedBy) ProtoMessage()

func (*SignedBy) Reset 

func (m *SignedBy) Reset()

func (*SignedBy) Size 

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

func (*SignedBy) String 

func (m *SignedBy) String() string

func (*SignedBy) Unmarshal 

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

func (*SignedBy) XXX_DiscardUnknown 

func (m *SignedBy) XXX_DiscardUnknown()

func (*SignedBy) XXX_Marshal 

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

func (*SignedBy) XXX_Merge 

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

func (*SignedBy) XXX_Size 

func (m *SignedBy) XXX_Size() int

func (*SignedBy) XXX_Unmarshal 

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

type Storage 

type Storage struct {
	Quantity   ResourceValue `protobuf:"bytes,1,opt,name=quantity,proto3" json:"size" yaml:"size"`
	Attributes []Attribute   `protobuf:"bytes,2,rep,name=attributes,proto3" json:"attributes,omitempty" yaml:"cpu,omitempty"`
}

Storage stores resource quantity and storage attributes

func (*Storage) Descriptor 

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

func (*Storage) Equal 

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

func (*Storage) GetAttributes 

func (m *Storage) GetAttributes() []Attribute

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
	// contains filtered or unexported methods
}

type UnitType 

type UnitType int

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.