infrastructure

Documentation

Index

• type UserCognitoRepository
  • func NewUserCognitoRepository(logger log.Logger, cfg *config.Kernel) *UserCognitoRepository
  • func (r *UserCognitoRepository) FetchByID(ctx context.Context, id string) (*domain.User, error)
  • func (r *UserCognitoRepository) ReplacePicture(ctx context.Context, id, pictureURL string) error
• type UserSAGAKafkaEvent
  • func NewUserSAGAKafkaEvent(cfg *config.Kernel) *UserSAGAKafkaEvent
  • func (e *UserSAGAKafkaEvent) BlobFailed(ctx context.Context, msg string) error
  • func (e *UserSAGAKafkaEvent) Failed(ctx context.Context, service, msg string) error
  • func (e *UserSAGAKafkaEvent) Verified(ctx context.Context, service string) error

Types

type UserCognitoRepository

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

UserCognitoRepository User provider's AWS Cognito repo implementation

func NewUserCognitoRepository

func NewUserCognitoRepository(logger log.Logger, cfg *config.Kernel) *UserCognitoRepository

func (*UserCognitoRepository) FetchByID

func (r *UserCognitoRepository) FetchByID(ctx context.Context, id string) (*domain.User, error)

func (*UserCognitoRepository) ReplacePicture

func (r *UserCognitoRepository) ReplacePicture(ctx context.Context, id, pictureURL string) error

type UserSAGAKafkaEvent

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

func NewUserSAGAKafkaEvent

func NewUserSAGAKafkaEvent(cfg *config.Kernel) *UserSAGAKafkaEvent

func (*UserSAGAKafkaEvent) BlobFailed

func (e *UserSAGAKafkaEvent) BlobFailed(ctx context.Context, msg string) error

func (*UserSAGAKafkaEvent) Failed

func (e *UserSAGAKafkaEvent) Failed(ctx context.Context, service, msg string) error

func (*UserSAGAKafkaEvent) Verified

func (e *UserSAGAKafkaEvent) Verified(ctx context.Context, service string) error