cache

Documentation

Overview

Package cache is a generated GoMock package.

Index

• Variables
• type Cache
  • func NewCache(shard shard.Context) Cache
• type CacheImpl
  • func (c *CacheImpl) GetOrCreateCurrentWorkflowExecution(ctx context.Context, namespaceID namespace.ID, workflowID string, ...) (workflow.Context, ReleaseCacheFunc, error)
  • func (c *CacheImpl) GetOrCreateWorkflowExecution(ctx context.Context, namespaceID namespace.ID, ...) (workflow.Context, ReleaseCacheFunc, error)
• type MockCache
  • func NewMockCache(ctrl *gomock.Controller) *MockCache
  • func (m *MockCache) EXPECT() *MockCacheMockRecorder
  • func (m *MockCache) GetOrCreateCurrentWorkflowExecution(ctx context.Context, namespaceID namespace.ID, workflowID string, ...) (workflow.Context, ReleaseCacheFunc, error)
  • func (m *MockCache) GetOrCreateWorkflowExecution(ctx context.Context, namespaceID namespace.ID, execution v1.WorkflowExecution, ...) (workflow.Context, ReleaseCacheFunc, error)
• type MockCacheMockRecorder
  • func (mr *MockCacheMockRecorder) GetOrCreateCurrentWorkflowExecution(ctx, namespaceID, workflowID, lockPriority interface{}) *gomock.Call
  • func (mr *MockCacheMockRecorder) GetOrCreateWorkflowExecution(ctx, namespaceID, execution, lockPriority interface{}) *gomock.Call
• type NewCacheFn
  • func NewCacheFnProvider() NewCacheFn
• type ReleaseCacheFunc

Variables

var Module = fx.Options(
	fx.Provide(NewCacheFnProvider),
)

Types

type Cache

type Cache interface {
	GetOrCreateCurrentWorkflowExecution(
		ctx context.Context,
		namespaceID namespace.ID,
		workflowID string,
		lockPriority workflow.LockPriority,
	) (workflow.Context, ReleaseCacheFunc, error)

	GetOrCreateWorkflowExecution(
		ctx context.Context,
		namespaceID namespace.ID,
		execution commonpb.WorkflowExecution,
		lockPriority workflow.LockPriority,
	) (workflow.Context, ReleaseCacheFunc, error)
}

func NewCache

func NewCache(shard shard.Context) Cache

type CacheImpl

type CacheImpl struct {
	cache.Cache
	// contains filtered or unexported fields
}

func (*CacheImpl) GetOrCreateCurrentWorkflowExecution

func (c *CacheImpl) GetOrCreateCurrentWorkflowExecution(
	ctx context.Context,
	namespaceID namespace.ID,
	workflowID string,
	lockPriority workflow.LockPriority,
) (workflow.Context, ReleaseCacheFunc, error)

func (*CacheImpl) GetOrCreateWorkflowExecution

func (c *CacheImpl) GetOrCreateWorkflowExecution(
	ctx context.Context,
	namespaceID namespace.ID,
	execution commonpb.WorkflowExecution,
	lockPriority workflow.LockPriority,
) (workflow.Context, ReleaseCacheFunc, error)

type MockCache

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

MockCache is a mock of Cache interface.

func NewMockCache

func NewMockCache(ctrl *gomock.Controller) *MockCache

NewMockCache creates a new mock instance.

func (*MockCache) EXPECT

func (m *MockCache) EXPECT() *MockCacheMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCache) GetOrCreateCurrentWorkflowExecution

func (m *MockCache) GetOrCreateCurrentWorkflowExecution(ctx context.Context, namespaceID namespace.ID, workflowID string, lockPriority workflow.LockPriority) (workflow.Context, ReleaseCacheFunc, error)

GetOrCreateCurrentWorkflowExecution mocks base method.

func (*MockCache) GetOrCreateWorkflowExecution

func (m *MockCache) GetOrCreateWorkflowExecution(ctx context.Context, namespaceID namespace.ID, execution v1.WorkflowExecution, lockPriority workflow.LockPriority) (workflow.Context, ReleaseCacheFunc, error)

GetOrCreateWorkflowExecution mocks base method.

type MockCacheMockRecorder

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

MockCacheMockRecorder is the mock recorder for MockCache.

func (*MockCacheMockRecorder) GetOrCreateCurrentWorkflowExecution

func (mr *MockCacheMockRecorder) GetOrCreateCurrentWorkflowExecution(ctx, namespaceID, workflowID, lockPriority interface{}) *gomock.Call

GetOrCreateCurrentWorkflowExecution indicates an expected call of GetOrCreateCurrentWorkflowExecution.

func (*MockCacheMockRecorder) GetOrCreateWorkflowExecution

func (mr *MockCacheMockRecorder) GetOrCreateWorkflowExecution(ctx, namespaceID, execution, lockPriority interface{}) *gomock.Call

GetOrCreateWorkflowExecution indicates an expected call of GetOrCreateWorkflowExecution.

type NewCacheFn

type NewCacheFn func(shard shard.Context) Cache

func NewCacheFnProvider

func NewCacheFnProvider() NewCacheFn

NewCacheFnProvider provide a NewCacheFn that can be used to create new workflow cache.

type ReleaseCacheFunc

type ReleaseCacheFunc func(err error)

ReleaseCacheFunc must be called to release the workflow context from the cache. Make sure not to access the mutable state or workflow context after releasing back to the cache. If there is any error when using the mutable state (e.g. mutable state is mutated and dirty), call release with the error so the in-memory copy will be thrown away.

var NoopReleaseFn ReleaseCacheFunc = func(err error) {}