logging

Documentation

Index

• Constants
• Variables
• func ErrCheckOpensearchClusterFailed(clienterr error) error
• func ErrCreateFailedAlreadyExists(id string) error
• func ErrCreateNamespaceFailed(clienterr error) error
• func ErrGenerateCredentialsFailed(err error) error
• func ErrListingClustersFaled(clienterr error) error
• func ErrStoreClusterFailed(err error) error
• func ErrStoreUserCredentialsFailed(err error) error
• func Scheme(ctx context.Context) meta.Scheme
• type OpensearchDetailsResponse
• type Plugin
  • func NewPlugin(ctx context.Context, opts ...PluginOption) *Plugin
  • func (p *Plugin) CanInstall() error
  • func (p *Plugin) ConfigureRoutes(app *fiber.App)
  • func (p *Plugin) Install(cluster *core.Reference) error
  • func (p *Plugin) InstallerTemplate() string
  • func (p *Plugin) UseKeyValueStore(system.KVStoreClient)
  • func (p *Plugin) UseManagementAPI(client management.ManagementClient)
• type PluginOption
  • func WithNamespace(namespace string) PluginOption
  • func WithOpensearchCluster(cluster *opnimeta.OpensearchClusterRef) PluginOption
• type PluginOptions
  • func (o *PluginOptions) Apply(opts ...PluginOption)

Constants

const (
	ClusterIDHeader = "OpniClusterID"
)

const (
	OpensearchBindingName = "opni-logging"
)

Variables

var (
	ErrClusterAlreadyExists = errors.New("cluster already exists")
	ErrClusterIDMissing     = errors.New("request does not include cluster ID")
)

Functions

func ErrCheckOpensearchClusterFailed

func ErrCheckOpensearchClusterFailed(clienterr error) error

func ErrCreateFailedAlreadyExists

func ErrCreateFailedAlreadyExists(id string) error

func ErrCreateNamespaceFailed

func ErrCreateNamespaceFailed(clienterr error) error

func ErrGenerateCredentialsFailed

func ErrGenerateCredentialsFailed(err error) error

func ErrListingClustersFaled

func ErrListingClustersFaled(clienterr error) error

func ErrStoreClusterFailed

func ErrStoreClusterFailed(err error) error

func ErrStoreUserCredentialsFailed

func ErrStoreUserCredentialsFailed(err error) error

func Scheme

func Scheme(ctx context.Context) meta.Scheme

Types

type OpensearchDetailsResponse

type OpensearchDetailsResponse struct {
	Username    string `json:"username"`
	Password    string `json:"password"`
	ExternalURL string `json:"externalURL"`
}

type Plugin

type Plugin struct {
	PluginOptions
	// contains filtered or unexported fields
}

func NewPlugin

func NewPlugin(ctx context.Context, opts ...PluginOption) *Plugin

func (*Plugin) CanInstall

func (p *Plugin) CanInstall() error

func (*Plugin) ConfigureRoutes

func (p *Plugin) ConfigureRoutes(app *fiber.App)

func (*Plugin) Install

func (p *Plugin) Install(cluster *core.Reference) error

func (*Plugin) InstallerTemplate

func (p *Plugin) InstallerTemplate() string

func (*Plugin) UseKeyValueStore

func (p *Plugin) UseKeyValueStore(system.KVStoreClient)

func (*Plugin) UseManagementAPI

func (p *Plugin) UseManagementAPI(client management.ManagementClient)

type PluginOption

type PluginOption func(*PluginOptions)

func WithNamespace

func WithNamespace(namespace string) PluginOption

func WithOpensearchCluster

func WithOpensearchCluster(cluster *opnimeta.OpensearchClusterRef) PluginOption

type PluginOptions

type PluginOptions struct {
	// contains filtered or unexported fields
}

func (*PluginOptions) Apply

func (o *PluginOptions) Apply(opts ...PluginOption)