kube

Documentation

Index

• func NewPlatform(client *k8s.Client) *platform
• type System
  • func NewSystem(cluster *k8s.Cluster) *System
  • func (s *System) DisableOpenTelemetryCollector(context.Context, *v1.DisableOpenTelemetryCollectorRequest) (*v1.DisableOpenTelemetryCollectorResponse, error)
  • func (s *System) EnableOpenTelemetryCollector(ctx context.Context, req *v1.EnableOpenTelemetryCollectorRequest) (*v1.EnableOpenTelemetryCollectorResponse, error)
  • func (s *System) Ping(ctx context.Context, empty *emptypb.Empty) (*v1.Pong, error)
  • func (s *System) UpdateOpenTelemetryCollector(context.Context, *v1.UpdateOpenTelemetryCollectorRequest) (*v1.UpdateOpenTelemetryCollectorResponse, error)

Functions

func NewPlatform

func NewPlatform(client *k8s.Client) *platform

Types

type System

type System struct {
	v1.UnimplementedSystemServer
	// contains filtered or unexported fields
}

func NewSystem

func NewSystem(cluster *k8s.Cluster) *System

func (*System) DisableOpenTelemetryCollector

func (s *System) DisableOpenTelemetryCollector(context.Context, *v1.DisableOpenTelemetryCollectorRequest) (*v1.DisableOpenTelemetryCollectorResponse, error)

func (*System) EnableOpenTelemetryCollector

func (s *System) EnableOpenTelemetryCollector(ctx context.Context, req *v1.EnableOpenTelemetryCollectorRequest) (*v1.EnableOpenTelemetryCollectorResponse, error)

func (*System) Ping

func (s *System) Ping(ctx context.Context, empty *emptypb.Empty) (*v1.Pong, error)

func (*System) UpdateOpenTelemetryCollector

func (s *System) UpdateOpenTelemetryCollector(context.Context, *v1.UpdateOpenTelemetryCollectorRequest) (*v1.UpdateOpenTelemetryCollectorResponse, error)