v1

Documentation

Index

• type CachingFactory
  • func NewFactory(logger logging.Logger, jobsCfg model.JobsConfig, fips bool) *CachingFactory
  • func (c *CachingFactory) Clear()
  • func (c *CachingFactory) GetAccountClient(region string, role model.Role) account.Client
  • func (c *CachingFactory) GetCloudwatchClient(region string, role model.Role, ...) cloudwatch_client.Client
  • func (c *CachingFactory) GetTaggingClient(region string, role model.Role, concurrencyLimit int) tagging.Client
  • func (c *CachingFactory) Refresh()

Types

type CachingFactory

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

func NewFactory

func NewFactory(logger logging.Logger, jobsCfg model.JobsConfig, fips bool) *CachingFactory

NewFactory creates a new client factory to use when fetching data from AWS with sdk v2

func (*CachingFactory) Clear

func (c *CachingFactory) Clear()

Refresh and Clear help to avoid using lock primitives by asserting that there are no ongoing writes to the map.

func (*CachingFactory) GetAccountClient

func (c *CachingFactory) GetAccountClient(region string, role model.Role) account.Client

func (*CachingFactory) GetCloudwatchClient

func (c *CachingFactory) GetCloudwatchClient(region string, role model.Role, concurrency cloudwatch_client.ConcurrencyConfig) cloudwatch_client.Client

func (*CachingFactory) GetTaggingClient

func (c *CachingFactory) GetTaggingClient(region string, role model.Role, concurrencyLimit int) tagging.Client

func (*CachingFactory) Refresh

func (c *CachingFactory) Refresh()