opensearch

Documentation

Index

• func MakeTestClient(_ context.Context, config common.TestClientConfig) (*opensearch.Client, error)
• func NewEngine(ec common.EngineConfig) common.Engine
• type Engine
  • func (e *Engine) HandleConnection(ctx context.Context, _ *common.Session) error
  • func (e *Engine) InitializeConnection(clientConn net.Conn, sessionCtx *common.Session) error
  • func (e *Engine) SendError(err error)
• type TestServer
  • func NewTestServer(config common.TestServerConfig, opts ...TestServerOption) (svr *TestServer, err error)
  • func (s *TestServer) Close() error
  • func (s *TestServer) Port() string
  • func (s *TestServer) Serve() error
• type TestServerOption

Functions

func MakeTestClient

func MakeTestClient(_ context.Context, config common.TestClientConfig) (*opensearch.Client, error)

MakeTestClient returns Redis client connection according to the provided parameters.

func NewEngine

func NewEngine(ec common.EngineConfig) common.Engine

NewEngine create new OpenSearch engine.

Types

type Engine

type Engine struct {
	// EngineConfig is the common database engine configuration.
	common.EngineConfig

	// CredentialsGetter is used to obtain STS credentials.
	CredentialsGetter libaws.CredentialsGetter
	// contains filtered or unexported fields
}

Engine handles connections from OpenSearch clients coming from Teleport proxy over reverse tunnel.

func (*Engine) HandleConnection

func (e *Engine) HandleConnection(ctx context.Context, _ *common.Session) error

HandleConnection authorizes the incoming client connection, connects to the target OpenSearch server and starts proxying requests between client/server.

func (*Engine) InitializeConnection

func (e *Engine) InitializeConnection(clientConn net.Conn, sessionCtx *common.Session) error

InitializeConnection initializes the engine with the client connection.

func (*Engine) SendError

func (e *Engine) SendError(err error)

SendError sends an error to OpenSearch client.

type TestServer

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

func NewTestServer

func NewTestServer(config common.TestServerConfig, opts ...TestServerOption) (svr *TestServer, err error)

NewTestServer returns a new instance of a test OpenSearch server.

func (*TestServer) Close

func (s *TestServer) Close() error

Close starts serving client connections.

func (*TestServer) Port

func (s *TestServer) Port() string

func (*TestServer) Serve

func (s *TestServer) Serve() error

Serve starts serving client connections.

type TestServerOption

type TestServerOption func(*TestServer)

TestServerOption allows setting test server options.