kubelet

package

v0.0.0-...-ebbaa34 Latest Latest Go to latest Published: May 27, 2020 License: Apache-2.0 Imports: 39 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/hth0919/kubeletCRD

Documentation ¶

Index ¶

func RegisterPodConfigurationServer(s *grpc.Server, srv PodConfigurationServer)
func Run(opt Options)
type Empty
type KETIkubelet
type Options
type PodConfigurationClient
- func NewPodConfigurationClient(cc grpc.ClientConnInterface) PodConfigurationClient
type PodConfigurationServer
type PodInfo
type PodsByCreationTime
type SyncHandler
type UnimplementedPodConfigurationServer
- func (*UnimplementedPodConfigurationServer) SendPod(ctx context.Context, req *PodInfo) (*Empty, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
container
docker
status
types Common types in the Kubelet.	Common types in the Kubelet.
update

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL