workflowcache

Documentation

Overview

Package workflowcache is a generated GoMock package.

Index

• type MockWFCache
  • func NewMockWFCache(ctrl *gomock.Controller) *MockWFCache
  • func (m *MockWFCache) AllowExternal(arg0, arg1 string) bool
  • func (m *MockWFCache) AllowInternal(arg0, arg1 string) bool
  • func (m *MockWFCache) EXPECT() *MockWFCacheMockRecorder
• type MockWFCacheMockRecorder
  • func (mr *MockWFCacheMockRecorder) AllowExternal(arg0, arg1 interface{}) *gomock.Call
  • func (mr *MockWFCacheMockRecorder) AllowInternal(arg0, arg1 interface{}) *gomock.Call
• type Params
• type WFCache
  • func New(params Params) WFCache

Types

type MockWFCache

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

MockWFCache is a mock of WFCache interface.

func NewMockWFCache

func NewMockWFCache(ctrl *gomock.Controller) *MockWFCache

NewMockWFCache creates a new mock instance.

func (*MockWFCache) AllowExternal

func (m *MockWFCache) AllowExternal(arg0, arg1 string) bool

AllowExternal mocks base method.

func (*MockWFCache) AllowInternal

func (m *MockWFCache) AllowInternal(arg0, arg1 string) bool

AllowInternal mocks base method.

func (*MockWFCache) EXPECT

func (m *MockWFCache) EXPECT() *MockWFCacheMockRecorder

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

type MockWFCacheMockRecorder

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

MockWFCacheMockRecorder is the mock recorder for MockWFCache.

func (*MockWFCacheMockRecorder) AllowExternal

func (mr *MockWFCacheMockRecorder) AllowExternal(arg0, arg1 interface{}) *gomock.Call

AllowExternal indicates an expected call of AllowExternal.

func (*MockWFCacheMockRecorder) AllowInternal

func (mr *MockWFCacheMockRecorder) AllowInternal(arg0, arg1 interface{}) *gomock.Call

AllowInternal indicates an expected call of AllowInternal.

type Params

type Params struct {
	TTL                            time.Duration
	MaxCount                       int
	ExternalLimiterFactory         quotas.LimiterFactory
	InternalLimiterFactory         quotas.LimiterFactory
	WorkflowIDCacheExternalEnabled dynamicconfig.BoolPropertyFnWithDomainFilter
	WorkflowIDCacheInternalEnabled dynamicconfig.BoolPropertyFnWithDomainFilter
	DomainCache                    cache.DomainCache
	MetricsClient                  metrics.Client
	Logger                         log.Logger
	RatelimitExternalPerWorkflowID dynamicconfig.BoolPropertyFnWithDomainFilter
	RatelimitInternalPerWorkflowID dynamicconfig.BoolPropertyFnWithDomainFilter
}

Params is the parameters for a new WFCache

type WFCache

type WFCache interface {
	AllowExternal(domainID string, workflowID string) bool
	AllowInternal(domainID string, workflowID string) bool
}

WFCache is a per workflow cache used for workflow specific in memory data

func New

func New(params Params) WFCache

New creates a new WFCache