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
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 *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"`
}
Source Files
Click to show internal directories.
Click to hide internal directories.