elastic

package

v1.40.11 Latest Latest Go to latest Published: May 20, 2026 License: Apache-2.0 Imports: 45 Imported by: 0

Details

View Source

const (
	LogStorageFinalizer = "tigera.io/eck-cleanup"
)

This section is empty.

func Add(mgr manager.Manager, opts options.AddOptions) error

func AddExternalES(mgr manager.Manager, opts options.AddOptions) error

func MockESCLICreator(_ client.Client, ctx context.Context, _ string, _ bool) (utils.ElasticClient, error)

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

ElasticSubController is a sub-controller of the main LogStorage controller responsible for managing the Elasticsearch service used by Calico.

func (r *ElasticSubController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

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

func (r *ExternalESController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)

type MockESClient struct {
	mock.Mock
}

func (m *MockESClient) CreateUser(_ context.Context, _ *utils.User) error

func (m *MockESClient) DeleteRoles(ctx context.Context, roles []utils.Role) error

func (m *MockESClient) DeleteUser(ctx context.Context, u *utils.User) error

func (m *MockESClient) GetUsers(ctx context.Context) ([]utils.User, error)

func (m *MockESClient) SetILMPolicies(_ context.Context, _ *operatorv1.LogStorage) error

type MockESClientKey string