backend

Documentation

Index

• type LoggingBackend
  • func (b *LoggingBackend) CanInstall(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)
  • func (b *LoggingBackend) CancelUninstall(_ context.Context, cluster *opnicorev1.Reference) (*emptypb.Empty, error)
  • func (b *LoggingBackend) Info(context.Context, *emptypb.Empty) (*capabilityv1.Details, error)
  • func (b *LoggingBackend) Initialize(conf LoggingBackendConfig)
  • func (b *LoggingBackend) Install(ctx context.Context, req *capabilityv1.InstallRequest) (*capabilityv1.InstallResponse, error)
  • func (b *LoggingBackend) InstallerTemplate(context.Context, *emptypb.Empty) (*capabilityv1.InstallerTemplateResponse, error)
  • func (b *LoggingBackend) Status(ctx context.Context, req *opnicorev1.Reference) (*capabilityv1.NodeCapabilityStatus, error)
  • func (b *LoggingBackend) Sync(ctx context.Context, req *node.SyncRequest) (*node.SyncResponse, error)
  • func (b *LoggingBackend) Uninstall(ctx context.Context, req *capabilityv1.UninstallRequest) (*emptypb.Empty, error)
  • func (b *LoggingBackend) UninstallStatus(_ context.Context, cluster *opnicorev1.Reference) (*opnicorev1.TaskStatus, error)
• type LoggingBackendConfig

Types

type LoggingBackend

type LoggingBackend struct {
	capabilityv1.UnsafeBackendServer
	node.UnsafeNodeLoggingCapabilityServer
	LoggingBackendConfig
	util.Initializer
	// contains filtered or unexported fields
}

func (*LoggingBackend) CanInstall

func (b *LoggingBackend) CanInstall(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)

func (*LoggingBackend) CancelUninstall

func (b *LoggingBackend) CancelUninstall(_ context.Context, cluster *opnicorev1.Reference) (*emptypb.Empty, error)

func (*LoggingBackend) Info

func (b *LoggingBackend) Info(context.Context, *emptypb.Empty) (*capabilityv1.Details, error)

func (*LoggingBackend) Initialize

func (b *LoggingBackend) Initialize(conf LoggingBackendConfig)

TODO: set up watches on underlying k8s objects to dynamically request a sync

func (*LoggingBackend) Install

func (b *LoggingBackend) Install(ctx context.Context, req *capabilityv1.InstallRequest) (*capabilityv1.InstallResponse, error)

func (*LoggingBackend) InstallerTemplate

func (b *LoggingBackend) InstallerTemplate(context.Context, *emptypb.Empty) (*capabilityv1.InstallerTemplateResponse, error)

func (*LoggingBackend) Status

func (b *LoggingBackend) Status(ctx context.Context, req *opnicorev1.Reference) (*capabilityv1.NodeCapabilityStatus, error)

func (*LoggingBackend) Sync

func (b *LoggingBackend) Sync(ctx context.Context, req *node.SyncRequest) (*node.SyncResponse, error)

func (*LoggingBackend) Uninstall

func (b *LoggingBackend) Uninstall(ctx context.Context, req *capabilityv1.UninstallRequest) (*emptypb.Empty, error)

func (*LoggingBackend) UninstallStatus

func (b *LoggingBackend) UninstallStatus(_ context.Context, cluster *opnicorev1.Reference) (*opnicorev1.TaskStatus, error)

type LoggingBackendConfig

type LoggingBackendConfig struct {
	Logger              *slog.Logger                              `validate:"required"`
	StorageBackend      storage.Backend                           `validate:"required"`
	MgmtClient          managementv1.ManagementClient             `validate:"required"`
	Delegate            streamext.StreamDelegate[agent.ClientSet] `validate:"required"`
	UninstallController *task.Controller                          `validate:"required"`
	OpensearchManager   *opensearchdata.Manager                   `validate:"required"`
	ClusterDriver       driver.ClusterDriver                      `validate:"required"`
}