infrastructure

Documentation

Index

• type Infrastructure
  • func New(provider configuration.Provider) (*Infrastructure, error)
  • func (infra *Infrastructure) Connect(ctx context.Context) error
  • func (infra *Infrastructure) Disconnect(ctx context.Context) error
  • func (infra *Infrastructure) Liveness() error
  • func (infra *Infrastructure) Readiness() error

Types

type Infrastructure

type Infrastructure struct {
	Timer                  timer.Timer
	Send                   sender.Send
	Idempotency            idempotency.Idempotency
	CircuitBreaker         circuitbreaker.CircuitBreaker
	DistributedLockManager dlm.Factory
	Authenticator          authenticator.Authenticator
	Stream                 streaming.Stream
	Cache                  cache.Cache
	// contains filtered or unexported fields
}

func New

func New(provider configuration.Provider) (*Infrastructure, error)

func (*Infrastructure) Connect

func (infra *Infrastructure) Connect(ctx context.Context) error

func (*Infrastructure) Disconnect

func (infra *Infrastructure) Disconnect(ctx context.Context) error

func (*Infrastructure) Liveness

func (infra *Infrastructure) Liveness() error

func (*Infrastructure) Readiness

func (infra *Infrastructure) Readiness() error