imageapi

package
v0.1.2 Latest Latest
Warning

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

 Go to latest Published: Aug 5, 2021 License: BSD-3-Clause Imports: 26 Imported by: 0

README

imageapi module

This module can control image loading on nodes through the locally running imageapi

Documentation

Index

Constants

View Source 
const (
	ContainerState_DELETED  = "DELETED"
	ContainerState_CREATED  = "created"
	ContainerState_RUNNING  = "running"
	ContainerState_STOPPING = "stopping"
	ContainerState_EXITED   = "exited"
	ContainerState_DEAD     = "dead"
)

we define an extra container state to recognize deleted containers

Variables

View Source 
var (
	ErrInvalidLengthImageapiConfig        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowImageapiConfig          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupImageapiConfig = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ApiServer_Status_name = map[int32]string{
	0: "UNKNOWN",
	1: "OK",
	2: "ERROR",
}
View Source 
var ApiServer_Status_value = map[string]int32{
	"UNKNOWN": 0,
	"OK":      1,
	"ERROR":   2,
}

Functions

This section is empty.

Types

type ApiServer 

type ApiServer struct {
	Server               string           `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"`
	Port                 int32            `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	Https                bool             `protobuf:"varint,3,opt,name=https,proto3" json:"https,omitempty"`
	ApiBase              string           `protobuf:"bytes,4,opt,name=api_base,json=apiBase,proto3" json:"api_base,omitempty"`
	Status               ApiServer_Status `protobuf:"varint,5,opt,name=status,proto3,enum=ImageAPI.ApiServer_Status" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ApiServer) Descriptor 

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

func (*ApiServer) GetApiBase 

func (m *ApiServer) GetApiBase() string

func (*ApiServer) GetHttps 

func (m *ApiServer) GetHttps() bool

func (*ApiServer) GetPort 

func (m *ApiServer) GetPort() int32

func (*ApiServer) GetServer 

func (m *ApiServer) GetServer() string

func (*ApiServer) GetStatus 

func (m *ApiServer) GetStatus() ApiServer_Status

func (*ApiServer) Marshal 

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

func (*ApiServer) MarshalTo 

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

func (*ApiServer) MarshalToSizedBuffer 

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

func (*ApiServer) ProtoMessage 

func (*ApiServer) ProtoMessage()

func (*ApiServer) Reset 

func (m *ApiServer) Reset()

func (*ApiServer) Size 

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

func (*ApiServer) String 

func (m *ApiServer) String() string

func (*ApiServer) Unmarshal 

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

func (*ApiServer) XXX_DiscardUnknown 

func (m *ApiServer) XXX_DiscardUnknown()

func (*ApiServer) XXX_Marshal 

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

func (*ApiServer) XXX_Merge 

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

func (*ApiServer) XXX_MessageName 

func (*ApiServer) XXX_MessageName() string

func (*ApiServer) XXX_Size 

func (m *ApiServer) XXX_Size() int

func (*ApiServer) XXX_Unmarshal 

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

type ApiServer_Status 

type ApiServer_Status int32
const (
	ApiServer_UNKNOWN ApiServer_Status = 0
	ApiServer_OK      ApiServer_Status = 1
	ApiServer_ERROR   ApiServer_Status = 2
)

func (ApiServer_Status) EnumDescriptor 

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

func (ApiServer_Status) String 

func (x ApiServer_Status) String() string

type Config 

type Config struct {
	ApiServer            *ApiServer `protobuf:"bytes,1,opt,name=api_server,json=apiServer,proto3" json:"api_server,omitempty"`
	PollingInterval      string     `protobuf:"bytes,3,opt,name=polling_interval,json=pollingInterval,proto3" json:"polling_interval,omitempty"`
	MaxRetries           int32      `protobuf:"varint,4,opt,name=max_retries,json=maxRetries,proto3" json:"max_retries,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Config) Descriptor 

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

func (*Config) GetApiServer 

func (m *Config) GetApiServer() *ApiServer

func (*Config) GetMaxRetries 

func (m *Config) GetMaxRetries() int32

func (*Config) GetPollingInterval 

func (m *Config) GetPollingInterval() string

func (*Config) Marshal 

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

func (*Config) MarshalTo 

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

func (*Config) MarshalToSizedBuffer 

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

func (*Config) ProtoMessage 

func (*Config) ProtoMessage()

func (*Config) Reset 

func (m *Config) Reset()

func (*Config) Size 

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

func (*Config) String 

func (m *Config) String() string

func (*Config) Unmarshal 

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

func (*Config) XXX_DiscardUnknown 

func (m *Config) XXX_DiscardUnknown()

func (*Config) XXX_Marshal 

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

func (*Config) XXX_Merge 

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

func (*Config) XXX_MessageName 

func (*Config) XXX_MessageName() string

func (*Config) XXX_Size 

func (m *Config) XXX_Size() int

func (*Config) XXX_Unmarshal 

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

type ImageAPI 

type ImageAPI struct {
	// contains filtered or unexported fields
}

ImageAPI provides layer1 image loading capabilities

func (*ImageAPI) ConfigURL 

func (*ImageAPI) ConfigURL() string

ConfigURL gives the any resolver URL for the config

func (*ImageAPI) Entry 

func (is *ImageAPI) Entry()

Entry is the module's executable entrypoint

func (*ImageAPI) Init 

func (is *ImageAPI) Init(api types.ModuleAPIClient)

Init is used to intialize an executable module prior to entrypoint

func (*ImageAPI) Name 

func (*ImageAPI) Name() string

Name returns the FQDN of the module

func (*ImageAPI) NewConfig 

func (*ImageAPI) NewConfig() proto.Message

NewConfig returns a fully initialized default config

func (*ImageAPI) SetDiscoveryChan 

func (is *ImageAPI) SetDiscoveryChan(c chan<- types.Event)

SetDiscoveryChan sets the current discovery channel this is generally done by the API

func (*ImageAPI) SetEventsChan 

func (ia *ImageAPI) SetEventsChan(c <-chan types.Event)

func (*ImageAPI) SetMutationChan 

func (is *ImageAPI) SetMutationChan(c <-chan types.Event)

SetMutationChan sets the current mutation channel this is generally done by the API

func (*ImageAPI) Stop 

func (is *ImageAPI) Stop()

Stop should perform a graceful exit

func (*ImageAPI) UpdateConfig 

func (is *ImageAPI) UpdateConfig(cfg proto.Message) (e error)

UpdateConfig updates the running config

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.