factory

Documentation

Index

• func GetEngine(ctx context.Context, config types.Config, ...) (client engine.API, err error)
• func GetEngineFromCache(_ context.Context, endpoint, ca, cert, key string) engine.API
• func InitEngineCache(ctx context.Context, config types.Config, stor store.Store)
• func RemoveEngineFromCache(ctx context.Context, endpoint, ca, cert, key string)
• type EngineCache
  • func NewEngineCache(config types.Config, stor store.Store) *EngineCache
  • func (e *EngineCache) CheckAlive(ctx context.Context)
  • func (e *EngineCache) CheckNodeStatus(ctx context.Context)
  • func (e *EngineCache) Delete(key string)
  • func (e *EngineCache) Get(key string) engine.API
  • func (e *EngineCache) Set(params engineParams, client engine.API)

Functions

func GetEngine

func GetEngine(ctx context.Context, config types.Config, nodename, endpoint, ca, cert, key string) (client engine.API, err error)

GetEngine get engine with cache

func GetEngineFromCache

func GetEngineFromCache(_ context.Context, endpoint, ca, cert, key string) engine.API

GetEngineFromCache .

func InitEngineCache

func InitEngineCache(ctx context.Context, config types.Config, stor store.Store)

InitEngineCache init engine cache and start engine cache checker

func RemoveEngineFromCache

func RemoveEngineFromCache(ctx context.Context, endpoint, ca, cert, key string)

RemoveEngineFromCache .

Types

type EngineCache

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

EngineCache .

func NewEngineCache

func NewEngineCache(config types.Config, stor store.Store) *EngineCache

NewEngineCache .

func (*EngineCache) CheckAlive

func (e *EngineCache) CheckAlive(ctx context.Context)

CheckAlive checks if the engine in cache is available

func (*EngineCache) CheckNodeStatus

func (e *EngineCache) CheckNodeStatus(ctx context.Context)

func (*EngineCache) Delete

func (e *EngineCache) Delete(key string)

Delete .

func (*EngineCache) Get

func (e *EngineCache) Get(key string) engine.API

Get .

func (*EngineCache) Set

func (e *EngineCache) Set(params engineParams, client engine.API)

Set .