k8sApi

Documentation

Index

• func RegisterK8SDaemonServer(s *grpc.Server, srv K8SDaemonServer)
• 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 K8SDaemonClient
  • func NewK8SDaemonClient(cc *grpc.ClientConn) K8SDaemonClient
• type K8SDaemonServer
• type Pod
  • func (*Pod) Descriptor() ([]byte, []int)
  • func (m *Pod) GetId() string
  • func (m *Pod) GetName() string
  • func (m *Pod) GetNamespace() string
  • func (*Pod) ProtoMessage()
  • func (m *Pod) Reset()
  • func (m *Pod) String() string
  • func (m *Pod) XXX_DiscardUnknown()
  • func (m *Pod) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Pod) XXX_Merge(src proto.Message)
  • func (m *Pod) XXX_Size() int
  • func (m *Pod) XXX_Unmarshal(b []byte) error
• type PodDeletion
  • func (*PodDeletion) Descriptor() ([]byte, []int)
  • func (m *PodDeletion) GetPodId() int32
  • func (*PodDeletion) ProtoMessage()
  • func (m *PodDeletion) Reset()
  • func (m *PodDeletion) String() string
  • func (m *PodDeletion) XXX_DiscardUnknown()
  • func (m *PodDeletion) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *PodDeletion) XXX_Merge(src proto.Message)
  • func (m *PodDeletion) XXX_Size() int
  • func (m *PodDeletion) XXX_Unmarshal(b []byte) error
• type Pods
  • func (*Pods) Descriptor() ([]byte, []int)
  • func (m *Pods) GetPods() []*Pod
  • func (*Pods) ProtoMessage()
  • func (m *Pods) Reset()
  • func (m *Pods) String() string
  • func (m *Pods) XXX_DiscardUnknown()
  • func (m *Pods) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Pods) XXX_Merge(src proto.Message)
  • func (m *Pods) XXX_Size() int
  • func (m *Pods) XXX_Unmarshal(b []byte) error
• type UnimplementedK8SDaemonServer
  • func (*UnimplementedK8SDaemonServer) GetPods(ctx context.Context, req *Empty) (*Pods, error)
  • func (*UnimplementedK8SDaemonServer) KillPod(ctx context.Context, req *PodDeletion) (*Empty, error)

Functions

func RegisterK8SDaemonServer

func RegisterK8SDaemonServer(s *grpc.Server, srv K8SDaemonServer)

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 K8SDaemonClient

type K8SDaemonClient interface {
	GetPods(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Pods, error)
	KillPod(ctx context.Context, in *PodDeletion, opts ...grpc.CallOption) (*Empty, error)
}

K8SDaemonClient is the client API for K8SDaemon service.

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

func NewK8SDaemonClient

func NewK8SDaemonClient(cc *grpc.ClientConn) K8SDaemonClient

type K8SDaemonServer

type K8SDaemonServer interface {
	GetPods(context.Context, *Empty) (*Pods, error)
	KillPod(context.Context, *PodDeletion) (*Empty, error)
}

K8SDaemonServer is the server API for K8SDaemon service.

type Pod

type Pod struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string   `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Pod) Descriptor

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

func (*Pod) GetId

func (m *Pod) GetId() string

func (*Pod) GetName

func (m *Pod) GetName() string

func (*Pod) GetNamespace

func (m *Pod) GetNamespace() string

func (*Pod) ProtoMessage

func (*Pod) ProtoMessage()

func (*Pod) Reset

func (m *Pod) Reset()

func (*Pod) String

func (m *Pod) String() string

func (*Pod) XXX_DiscardUnknown

func (m *Pod) XXX_DiscardUnknown()

func (*Pod) XXX_Marshal

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

func (*Pod) XXX_Merge

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

func (*Pod) XXX_Size

func (m *Pod) XXX_Size() int

func (*Pod) XXX_Unmarshal

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

type PodDeletion

type PodDeletion struct {
	PodId                int32    `protobuf:"varint,5,opt,name=podId,proto3" json:"podId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PodDeletion) Descriptor

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

func (*PodDeletion) GetPodId

func (m *PodDeletion) GetPodId() int32

func (*PodDeletion) ProtoMessage

func (*PodDeletion) ProtoMessage()

func (*PodDeletion) Reset

func (m *PodDeletion) Reset()

func (*PodDeletion) String

func (m *PodDeletion) String() string

func (*PodDeletion) XXX_DiscardUnknown

func (m *PodDeletion) XXX_DiscardUnknown()

func (*PodDeletion) XXX_Marshal

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

func (*PodDeletion) XXX_Merge

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

func (*PodDeletion) XXX_Size

func (m *PodDeletion) XXX_Size() int

func (*PodDeletion) XXX_Unmarshal

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

type Pods

type Pods struct {
	Pods                 []*Pod   `protobuf:"bytes,4,rep,name=pods,proto3" json:"pods,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Pods) Descriptor

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

func (*Pods) GetPods

func (m *Pods) GetPods() []*Pod

func (*Pods) ProtoMessage

func (*Pods) ProtoMessage()

func (*Pods) Reset

func (m *Pods) Reset()

func (*Pods) String

func (m *Pods) String() string

func (*Pods) XXX_DiscardUnknown

func (m *Pods) XXX_DiscardUnknown()

func (*Pods) XXX_Marshal

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

func (*Pods) XXX_Merge

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

func (*Pods) XXX_Size

func (m *Pods) XXX_Size() int

func (*Pods) XXX_Unmarshal

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

type UnimplementedK8SDaemonServer

type UnimplementedK8SDaemonServer struct {
}

UnimplementedK8SDaemonServer can be embedded to have forward compatible implementations.

func (*UnimplementedK8SDaemonServer) GetPods

func (*UnimplementedK8SDaemonServer) GetPods(ctx context.Context, req *Empty) (*Pods, error)

func (*UnimplementedK8SDaemonServer) KillPod

func (*UnimplementedK8SDaemonServer) KillPod(ctx context.Context, req *PodDeletion) (*Empty, error)