reg

Documentation

Index

• type Registrator
  • func (r *Registrator) Dmesg(ctx context.Context, in *empty.Empty) (data *proto.Data, err error)
  • func (r *Registrator) Kubeconfig(ctx context.Context, in *empty.Empty) (data *proto.Data, err error)
  • func (r *Registrator) Logs(req *proto.LogsRequest, l proto.OSD_LogsServer) (err error)
  • func (r *Registrator) Processes(ctx context.Context, in *empty.Empty) (reply *proto.ProcessesReply, err error)
  • func (r *Registrator) Reboot(ctx context.Context, in *empty.Empty) (reply *proto.RebootReply, err error)
  • func (r *Registrator) Register(s *grpc.Server)
  • func (r *Registrator) Reset(ctx context.Context, in *empty.Empty) (reply *proto.ResetReply, err error)
  • func (r *Registrator) Restart(ctx context.Context, in *proto.RestartRequest) (reply *proto.RestartReply, err error)
  • func (r *Registrator) Version(ctx context.Context, in *empty.Empty) (data *proto.Data, err error)

Types

type Registrator

type Registrator struct {
	Data *userdata.UserData
}

Registrator is the concrete type that implements the factory.Registrator and proto.OSDServer interfaces.

func (*Registrator) Dmesg

func (r *Registrator) Dmesg(ctx context.Context, in *empty.Empty) (data *proto.Data, err error)

Dmesg implements the proto.OSDServer interface. The klogctl syscall is used to read from the ring buffer at /proc/kmsg by taking the SYSLOG_ACTION_READ_ALL action. This action reads all messages remaining in the ring buffer non-destructively.

func (*Registrator) Kubeconfig

func (r *Registrator) Kubeconfig(ctx context.Context, in *empty.Empty) (data *proto.Data, err error)

Kubeconfig implements the proto.OSDServer interface. The admin kubeconfig is generated by kubeadm and placed at /etc/kubernetes/admin.conf. This method returns the contents of the generated admin.conf in the response.

func (*Registrator) Logs

func (r *Registrator) Logs(req *proto.LogsRequest, l proto.OSD_LogsServer) (err error)

Logs implements the proto.OSDServer interface. Service or container logs can be requested and the contents of the log file are streamed in chunks.

func (*Registrator) Processes

func (r *Registrator) Processes(ctx context.Context, in *empty.Empty) (reply *proto.ProcessesReply, err error)

Processes implements the proto.OSDServer interface.

func (*Registrator) Reboot

func (r *Registrator) Reboot(ctx context.Context, in *empty.Empty) (reply *proto.RebootReply, err error)

Reboot implements the proto.OSDServer interface.

func (*Registrator) Register

func (r *Registrator) Register(s *grpc.Server)

Register implements the factory.Registrator interface.

func (*Registrator) Reset

func (r *Registrator) Reset(ctx context.Context, in *empty.Empty) (reply *proto.ResetReply, err error)

Reset implements the proto.OSDServer interface.

func (*Registrator) Restart

func (r *Registrator) Restart(ctx context.Context, in *proto.RestartRequest) (reply *proto.RestartReply, err error)

Restart implements the proto.OSDServer interface.

func (*Registrator) Version

func (r *Registrator) Version(ctx context.Context, in *empty.Empty) (data *proto.Data, err error)

Version implements the proto.OSDServer interface.