cache

Documentation

Index

• func NewWorkflowExecutorLRUCache(mc metrics.Client, size int, expiration time.Duration) workflow.ExecutorCache
• type LruCache
  • func (lc *LruCache) Get(ctx context.Context, instance *core.WorkflowInstance) (workflow.WorkflowExecutor, bool, error)
  • func (lc *LruCache) StartEviction(ctx context.Context)
  • func (lc *LruCache) Store(ctx context.Context, instance *core.WorkflowInstance, ...) error

Functions

func NewWorkflowExecutorLRUCache

func NewWorkflowExecutorLRUCache(mc metrics.Client, size int, expiration time.Duration) workflow.ExecutorCache

Types

type LruCache

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

func (*LruCache) Get

func (lc *LruCache) Get(ctx context.Context, instance *core.WorkflowInstance) (workflow.WorkflowExecutor, bool, error)

func (*LruCache) StartEviction

func (lc *LruCache) StartEviction(ctx context.Context)

func (*LruCache) Store

func (lc *LruCache) Store(ctx context.Context, instance *core.WorkflowInstance, executor workflow.WorkflowExecutor) error