elastic

Documentation

Index

• Constants
• func Add(mgr manager.Manager, opts options.AddOptions) error
• func MockESCLICreator(_ client.Client, ctx context.Context, _ string) (utils.ElasticClient, error)
• type ElasticSubController
  • func (r *ElasticSubController) Reconcile(ctx context.Context, request reconcile.Request) (reconcile.Result, error)
• type MockESClient
  • 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

Constants

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

Functions

func Add

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

func MockESCLICreator

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

Types

type ElasticSubController

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 (*ElasticSubController) Reconcile

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

type MockESClient

type MockESClient struct {
	mock.Mock
}

func (*MockESClient) CreateUser

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

func (*MockESClient) DeleteRoles

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

func (*MockESClient) DeleteUser

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

func (*MockESClient) GetUsers

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

func (*MockESClient) SetILMPolicies

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

type MockESClientKey

type MockESClientKey string