dal

Documentation

Index

• Variables
• func NewBlobFactory(c *kitconf.Data) blob.Factory
• func NewCacheStore(client redis.UniversalClient) store.StoreInterface
• func NewConnStrResolver(c *kitconf.Data, ts saas.TenantStore) data.ConnStrResolver
• func NewConstantConnStrResolver(c *kitconf.Data) data.ConnStrings
• func NewEmailer(c *kitconf.Data) email.LazyClient
• func NewEventSender(c *kitconf.Data, name ConnName) (event.Producer, func(), error)
• func NewRedis(c *kitconf.Data, name ConnName) (*redis.Client, error)
• func NewStringCacheManager(store store.StoreInterface) *cache.Cache[string]
• type ConnName
• type ConstDbProvider
  • func NewConstDbProvider(cache *kitgorm.DbCache, cs data.ConnStrings, d *kitconf.Data) ConstDbProvider

Variables

var (
	//DefaultProviderSet shared provider for all data layer
	DefaultProviderSet = wire.NewSet(
		NewConnStrResolver,
		NewConstantConnStrResolver,
		kitgorm.NewDbCache,

		kitgorm.NewDbProvider,
		NewConstDbProvider,

		kituow.NewUowManager,

		NewBlobFactory,

		NewRedis,
		wire.Bind(new(redis.UniversalClient), new(*redis.Client)),
		NewCacheStore,
		NewStringCacheManager,
		wire.Bind(new(cache.CacheInterface[string]), new(*cache.Cache[string])),

		NewEmailer,
		NewEventSender,
		wire.Value(eventbus.Default),
	)
)

Functions

func NewBlobFactory

func NewBlobFactory(c *kitconf.Data) blob.Factory

func NewCacheStore

func NewCacheStore(client redis.UniversalClient) store.StoreInterface

func NewConnStrResolver

func NewConnStrResolver(c *kitconf.Data, ts saas.TenantStore) data.ConnStrResolver

func NewConstantConnStrResolver

func NewConstantConnStrResolver(c *kitconf.Data) data.ConnStrings

NewConstantConnStrResolver ignore multi-tenancy

func NewEmailer

func NewEmailer(c *kitconf.Data) email.LazyClient

func NewEventSender

func NewEventSender(c *kitconf.Data, name ConnName) (event.Producer, func(), error)

func NewRedis

func NewRedis(c *kitconf.Data, name ConnName) (*redis.Client, error)

func NewStringCacheManager

func NewStringCacheManager(store store.StoreInterface) *cache.Cache[string]

Types

type ConnName

type ConnName string

type ConstDbProvider

type ConstDbProvider sgorm.DbProvider

func NewConstDbProvider

func NewConstDbProvider(cache *kitgorm.DbCache, cs data.ConnStrings, d *kitconf.Data) ConstDbProvider

NewConstDbProvider ignore multi-tenancy