Documentation ¶
Index ¶
- Constants
- Variables
- type ApiServer
- func (*ApiServer) Descriptor() ([]byte, []int)
- func (m *ApiServer) GetApiBase() string
- func (m *ApiServer) GetHttps() bool
- func (m *ApiServer) GetPort() int32
- func (m *ApiServer) GetServer() string
- func (m *ApiServer) GetStatus() ApiServer_Status
- func (m *ApiServer) Marshal() (dAtA []byte, err error)
- func (m *ApiServer) MarshalTo(dAtA []byte) (int, error)
- func (m *ApiServer) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ApiServer) ProtoMessage()
- func (m *ApiServer) Reset()
- func (m *ApiServer) Size() (n int)
- func (m *ApiServer) String() string
- func (m *ApiServer) Unmarshal(dAtA []byte) error
- func (m *ApiServer) XXX_DiscardUnknown()
- func (m *ApiServer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ApiServer) XXX_Merge(src proto.Message)
- func (*ApiServer) XXX_MessageName() string
- func (m *ApiServer) XXX_Size() int
- func (m *ApiServer) XXX_Unmarshal(b []byte) error
- type ApiServer_Status
- type Config
- func (*Config) Descriptor() ([]byte, []int)
- func (m *Config) GetApiServer() *ApiServer
- func (m *Config) GetMaxRetries() int32
- func (m *Config) GetPollingInterval() string
- func (m *Config) Marshal() (dAtA []byte, err error)
- func (m *Config) MarshalTo(dAtA []byte) (int, error)
- func (m *Config) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Config) ProtoMessage()
- func (m *Config) Reset()
- func (m *Config) Size() (n int)
- func (m *Config) String() string
- func (m *Config) Unmarshal(dAtA []byte) error
- func (m *Config) XXX_DiscardUnknown()
- func (m *Config) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Config) XXX_Merge(src proto.Message)
- func (*Config) XXX_MessageName() string
- func (m *Config) XXX_Size() int
- func (m *Config) XXX_Unmarshal(b []byte) error
- type ImageAPI
- func (*ImageAPI) ConfigURL() string
- func (is *ImageAPI) Entry()
- func (is *ImageAPI) Init(api types.ModuleAPIClient)
- func (*ImageAPI) Name() string
- func (*ImageAPI) NewConfig() proto.Message
- func (is *ImageAPI) SetDiscoveryChan(c chan<- types.Event)
- func (ia *ImageAPI) SetEventsChan(c <-chan types.Event)
- func (is *ImageAPI) SetMutationChan(c <-chan types.Event)
- func (is *ImageAPI) Stop()
- func (is *ImageAPI) UpdateConfig(cfg proto.Message) (e error)
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) GetApiBase ¶
func (*ApiServer) GetStatus ¶
func (m *ApiServer) GetStatus() ApiServer_Status
func (*ApiServer) MarshalToSizedBuffer ¶
func (*ApiServer) ProtoMessage ¶
func (*ApiServer) ProtoMessage()
func (*ApiServer) XXX_DiscardUnknown ¶
func (m *ApiServer) XXX_DiscardUnknown()
func (*ApiServer) XXX_Marshal ¶
func (*ApiServer) XXX_MessageName ¶
func (*ApiServer) XXX_Unmarshal ¶
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) GetApiServer ¶
func (*Config) GetMaxRetries ¶
func (*Config) GetPollingInterval ¶
func (*Config) MarshalToSizedBuffer ¶
func (*Config) ProtoMessage ¶
func (*Config) ProtoMessage()
func (*Config) XXX_DiscardUnknown ¶
func (m *Config) XXX_DiscardUnknown()
func (*Config) XXX_Marshal ¶
func (*Config) XXX_MessageName ¶
func (*Config) XXX_Unmarshal ¶
type ImageAPI ¶
type ImageAPI struct {
// contains filtered or unexported fields
}
ImageAPI provides layer1 image loading capabilities
func (*ImageAPI) Init ¶
func (is *ImageAPI) Init(api types.ModuleAPIClient)
Init is used to intialize an executable module prior to entrypoint
func (*ImageAPI) SetDiscoveryChan ¶
SetDiscoveryChan sets the current discovery channel this is generally done by the API
func (*ImageAPI) SetEventsChan ¶
func (*ImageAPI) SetMutationChan ¶
SetMutationChan sets the current mutation channel this is generally done by the API
Click to show internal directories.
Click to hide internal directories.