checkpointcollector

type CheckpointCollector struct {
	Cnumber      int
	Pods         map[string]map[string]string
	DispatchList map[string]string
	DockerClient *client.Client
	KubeClient   clientset.Interface
	KetiClient   keticlient.KetiV1Interface
	Period       int64
	UpdateChan   chan cptypes.ContainerUpdate
	DoneChan     chan int
	Connection   *LogConnection
	Recorder     record.EventRecorder
	EventClient  v1core.EventsGetter
}

type CheckpointPeriodClient interface {
	SetCheckpointPeriod(ctx context.Context, in *InputValue, opts ...grpc.CallOption) (*ReturnValue, error)
	CheckpointCreate(ctx context.Context, in *CreateCheckpoint, opts ...grpc.CallOption) (*PodReturnValue, error)
	ConvertPod(ctx context.Context, in *Convert, opts ...grpc.CallOption) (*Empty, error)
	CreateDocker(ctx context.Context, in *Connect, opts ...grpc.CallOption) (CheckpointPeriod_CreateDockerClient, error)
	LogPod(ctx context.Context, in *LogValue, opts ...grpc.CallOption) (*LogReturnValue, error)
	ExecPod(ctx context.Context, in *ExecValue, opts ...grpc.CallOption) (CheckpointPeriod_ExecPodClient, error)
}

type CheckpointPeriodServer interface {
	SetCheckpointPeriod(context.Context, *InputValue) (*ReturnValue, error)
	CheckpointCreate(context.Context, *CreateCheckpoint) (*PodReturnValue, error)
	ConvertPod(context.Context, *Convert) (*Empty, error)
	CreateDocker(*Connect, CheckpointPeriod_CreateDockerServer) error
	LogPod(context.Context, *LogValue) (*LogReturnValue, error)
	ExecPod(*ExecValue, CheckpointPeriod_ExecPodServer) error
}

type CheckpointPeriod_CreateDockerClient interface {
	Recv() (*LogValue, error)
	grpc.ClientStream
}

type CheckpointPeriod_CreateDockerServer interface {
	Send(*LogValue) error
	grpc.ServerStream
}

type CheckpointPeriod_ExecPodClient interface {
	Recv() (*ExecReturnValue, error)
	grpc.ClientStream
}

type CheckpointPeriod_ExecPodServer interface {
	Send(*ExecReturnValue) error
	grpc.ServerStream
}

type Connect struct {
	ContainerID string `protobuf:"bytes,1,opt,name=ContainerID,proto3" json:"ContainerID,omitempty"`
	// contains filtered or unexported fields
}

type Convert struct {
	Container map[string]string `` /* 159-byte string literal not displayed */
	Err       string            `protobuf:"bytes,2,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

type CreateCheckpoint struct {
	PodName string `protobuf:"bytes,1,opt,name=PodName,proto3" json:"PodName,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

type GRPCHandler interface {
	HandleADD(pods []*ketiv1.Pod)
	HandleRemove(pods []*ketiv1.Pod)
	HandleCheckPoint(podname resource)
	HandleCheckPointAll(pods map[string]map[string]string)
}

type InputValue struct {
	Period  int64    `protobuf:"varint,1,opt,name=Period,proto3" json:"Period,omitempty"`
	PodName []string `protobuf:"bytes,2,rep,name=PodName,proto3" json:"PodName,omitempty"`
	// contains filtered or unexported fields
}

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

type LogReturnValue struct {
	LogReader string `protobuf:"bytes,1,opt,name=LogReader,proto3" json:"LogReader,omitempty"`
	// contains filtered or unexported fields
}

type LogValue struct {
	ContainerID string `protobuf:"bytes,1,opt,name=ContainerID,proto3" json:"ContainerID,omitempty"`
	Message     string `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"`
	Timestamps  bool   `protobuf:"varint,3,opt,name=Timestamps,proto3" json:"Timestamps,omitempty"`
	Tail        bool   `protobuf:"varint,4,opt,name=Tail,proto3" json:"Tail,omitempty"`
	// contains filtered or unexported fields
}

type PodReturnValue struct {
	CheckpointName string `protobuf:"bytes,1,opt,name=CheckpointName,proto3" json:"CheckpointName,omitempty"`
	Err            string `protobuf:"bytes,2,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

type ReturnValue struct {
	Period int64  `protobuf:"varint,1,opt,name=Period,proto3" json:"Period,omitempty"`
	Err    string `protobuf:"bytes,2,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedCheckpointPeriodServer struct {
}