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 *corev1.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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LoggingBackend ¶
type LoggingBackend struct { capabilityv1.UnsafeBackendServer node.UnsafeNodeLoggingCapabilityServer LoggingBackendConfig util.Initializer // contains filtered or unexported fields }
func (*LoggingBackend) CanInstall ¶
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 *corev1.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 *zap.SugaredLogger `validate:"required"` StorageBackend storage.Backend `validate:"required"` MgmtClient managementv1.ManagementClient `validate:"required"` NodeManagerClient capabilityv1.NodeManagerClient `validate:"required"` UninstallController *task.Controller `validate:"required"` OpensearchManager *opensearchdata.Manager `validate:"required"` ClusterDriver driver.ClusterDriver `validate:"required"` }
Click to show internal directories.
Click to hide internal directories.