kubelet

Documentation

Index

• func RegisterPodConfigurationServer(s *grpc.Server, srv PodConfigurationServer)
• func Run(opt Options)
• type Empty
  • func (*Empty) Descriptor() ([]byte, []int)
  • func (*Empty) ProtoMessage()
  • func (m *Empty) Reset()
  • func (m *Empty) String() string
  • func (m *Empty) XXX_DiscardUnknown()
  • func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Empty) XXX_Merge(src proto.Message)
  • func (m *Empty) XXX_Size() int
  • func (m *Empty) XXX_Unmarshal(b []byte) error
• type KETIkubelet
  • func (kl *KETIkubelet) HandlePodAdditions(pods []*v1.Pod)
  • func (kl *KETIkubelet) HandlePodReconcile(pods []*v1.Pod)
  • func (kl *KETIkubelet) HandlePodRemoves(pods []*v1.Pod)
  • func (kl *KETIkubelet) HandlePodSyncs(pods []*v1.Pod)
  • func (kl *KETIkubelet) HandlePodUpdates(pods []*v1.Pod)
  • func (kl *KETIkubelet) SyncLoop(updates <-chan kubetypes.PodUpdate, handler SyncHandler)
• type Options
• type PodConfigurationClient
  • func NewPodConfigurationClient(cc grpc.ClientConnInterface) PodConfigurationClient
• type PodConfigurationServer
• type PodInfo
  • func (*PodInfo) Descriptor() ([]byte, []int)
  • func (m *PodInfo) GetOperation() int32
  • func (m *PodInfo) GetSource() string
  • func (m *PodInfo) GetYaml() []byte
  • func (*PodInfo) ProtoMessage()
  • func (m *PodInfo) Reset()
  • func (m *PodInfo) String() string
  • func (m *PodInfo) XXX_DiscardUnknown()
  • func (m *PodInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PodInfo) XXX_Merge(src proto.Message)
  • func (m *PodInfo) XXX_Size() int
  • func (m *PodInfo) XXX_Unmarshal(b []byte) error
• type PodsByCreationTime
  • func (s PodsByCreationTime) Len() int
  • func (s PodsByCreationTime) Less(i, j int) bool
  • func (s PodsByCreationTime) Swap(i, j int)
• type SyncHandler
• type UnimplementedPodConfigurationServer
  • func (*UnimplementedPodConfigurationServer) SendPod(ctx context.Context, req *PodInfo) (*Empty, error)

Functions

func RegisterPodConfigurationServer

func RegisterPodConfigurationServer(s *grpc.Server, srv PodConfigurationServer)

func Run

func Run(opt Options)

Types

type Empty

type Empty struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Empty) Descriptor

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

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) Reset

func (m *Empty) Reset()

func (*Empty) String

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal

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

func (*Empty) XXX_Merge

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

func (*Empty) XXX_Size

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal

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

type KETIkubelet

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

func (*KETIkubelet) HandlePodAdditions

func (kl *KETIkubelet) HandlePodAdditions(pods []*v1.Pod)

HandlePodAdditions is the callback in SyncHandler for pods being added from a config source.

func (*KETIkubelet) HandlePodReconcile

func (kl *KETIkubelet) HandlePodReconcile(pods []*v1.Pod)

HandlePodReconcile is the callback in the SyncHandler interface for pods that should be reconciled.

func (*KETIkubelet) HandlePodRemoves

func (kl *KETIkubelet) HandlePodRemoves(pods []*v1.Pod)

HandlePodRemoves is the callback in the SyncHandler interface for pods being removed from a config source.

func (*KETIkubelet) HandlePodSyncs

func (kl *KETIkubelet) HandlePodSyncs(pods []*v1.Pod)

HandlePodSyncs is the callback in the syncHandler interface for pods that should be dispatched to pod workers for sync.

func (*KETIkubelet) HandlePodUpdates

func (kl *KETIkubelet) HandlePodUpdates(pods []*v1.Pod)

HandlePodUpdates is the callback in the SyncHandler interface for pods being updated from a config source.

func (*KETIkubelet) SyncLoop

func (kl *KETIkubelet) SyncLoop(updates <-chan kubetypes.PodUpdate, handler SyncHandler)

type Options

type Options struct {
	Kubeconfig *string
	Nodename   *string
}

type PodConfigurationClient

type PodConfigurationClient interface {
	SendPod(ctx context.Context, in *PodInfo, opts ...grpc.CallOption) (*Empty, error)
}

PodConfigurationClient is the client API for PodConfiguration service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPodConfigurationClient

func NewPodConfigurationClient(cc grpc.ClientConnInterface) PodConfigurationClient

type PodConfigurationServer

type PodConfigurationServer interface {
	SendPod(context.Context, *PodInfo) (*Empty, error)
}

PodConfigurationServer is the server API for PodConfiguration service.

type PodInfo

type PodInfo struct {
	Yaml                 []byte   `protobuf:"bytes,1,opt,name=Yaml,proto3" json:"Yaml,omitempty"`
	Operation            int32    `protobuf:"varint,2,opt,name=Operation,proto3" json:"Operation,omitempty"`
	Source               string   `protobuf:"bytes,3,opt,name=Source,proto3" json:"Source,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PodInfo) Descriptor

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

func (*PodInfo) GetOperation

func (m *PodInfo) GetOperation() int32

func (*PodInfo) GetSource

func (m *PodInfo) GetSource() string

func (*PodInfo) GetYaml

func (m *PodInfo) GetYaml() []byte

func (*PodInfo) ProtoMessage

func (*PodInfo) ProtoMessage()

func (*PodInfo) Reset

func (m *PodInfo) Reset()

func (*PodInfo) String

func (m *PodInfo) String() string

func (*PodInfo) XXX_DiscardUnknown

func (m *PodInfo) XXX_DiscardUnknown()

func (*PodInfo) XXX_Marshal

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

func (*PodInfo) XXX_Merge

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

func (*PodInfo) XXX_Size

func (m *PodInfo) XXX_Size() int

func (*PodInfo) XXX_Unmarshal

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

type PodsByCreationTime

type PodsByCreationTime []*v1.Pod

func (PodsByCreationTime) Len

func (s PodsByCreationTime) Len() int

func (PodsByCreationTime) Less

func (s PodsByCreationTime) Less(i, j int) bool

func (PodsByCreationTime) Swap

func (s PodsByCreationTime) Swap(i, j int)

type SyncHandler

type SyncHandler interface {
	HandlePodAdditions(pods []*v1.Pod)
	HandlePodUpdates(pods []*v1.Pod)
	HandlePodRemoves(pods []*v1.Pod)
	HandlePodReconcile(pods []*v1.Pod)
	HandlePodSyncs(pods []*v1.Pod)
	HandlePodCleanups() error
}

type UnimplementedPodConfigurationServer

type UnimplementedPodConfigurationServer struct {
}

UnimplementedPodConfigurationServer can be embedded to have forward compatible implementations.

func (*UnimplementedPodConfigurationServer) SendPod

func (*UnimplementedPodConfigurationServer) SendPod(ctx context.Context, req *PodInfo) (*Empty, error)