adaptor

Documentation

Index

• type CiamWatcher
  • func NewCognito(c Cognito) CiamWatcher
• type Cognito
  • func (c *Cognito) Authenticate(m model.CiamAuthenticationRequest) (*model.CiamAuthenticationResponse, *model.TechnicalError)
  • func (c *Cognito) JwtInfo(t string) (map[string]interface{}, *model.TechnicalError)
  • func (c *Cognito) OnboardPartner(m model.CiamOnboardPartnerRequest) (*model.CiamUserResponse, *model.TechnicalError)
• type Consul
  • func (c *Consul) Register() *model.TechnicalError
• type ConsulWatcher
  • func NewConsul(c Consul) ConsulWatcher
• type Gopaid
  • func (g *Gopaid) Topup(inp *model.GopaidTopUpRequest) (*model.GopaidTopupResponse, *model.TechnicalError)
• type GopaidAdapter
  • func NewGopaid(g Gopaid) GopaidAdapter
• type Josvo
  • func (j *Josvo) AccountTransfer(inp *model.JosvoAccountTransferRequest) (*model.JosvoAccountTransferResponse, *model.TechnicalError)
• type JosvoAdapter
  • func NewJosvo(j Josvo) JosvoAdapter
• type Linksaja
  • func (l *Linksaja) Authorization() (*model.LinksajaAuthorizationResponse, *model.TechnicalError)
  • func (l *Linksaja) FundTransfer(inp *model.LinksajaFundTransferRequest) (*model.LinksajaFundTransferResponse, *model.TechnicalError)
• type LinksajaAdapter
  • func NewLinksaja(l Linksaja) LinksajaAdapter
• type Middletrans
  • func (mt *Middletrans) WalletTransfer(inp *model.MiddletransWalletTransferRequest) (*model.MiddletransWalletTransferResponse, *model.TechnicalError)
• type MiddletransAdapter
  • func NewMiddletrans(mt Middletrans) MiddletransAdapter
• type Rest
  • func (r *Rest) Client() *httpclient.Client
• type S3Bucket
  • func (b *S3Bucket) Upload(req *model.S3UploadRequest) (*s3manager.UploadOutput, *model.TechnicalError)
• type S3Watcher
  • func NewS3(b S3Bucket) S3Watcher
• type SES
  • func (s *SES) SendEmail(m model.SendEmailRequest) (*model.TransactionResponse, *model.TechnicalError)
• type SESAdapter
  • func NewSES(s SES) SESAdapter
• type SQS
  • func (s *SQS) DeleteMessages(q string, h string) *sqs.DeleteMessageOutput
  • func (s *SQS) GetMessages(t string) *sqs.Message
  • func (s *SQS) SendMessage(q string, msg string) error
• type SQSAdapter
  • func NewSQS(c SQS) SQSAdapter
• type Xenit
  • func (x *Xenit) WalletTopup(inp *model.XenitWalletTopupRequest) (*model.XenitWalletTopupResponse, *model.TechnicalError)
• type XenitAdapter
  • func NewXenit(x Xenit) XenitAdapter

Types

type CiamWatcher

type CiamWatcher interface {
	JwtInfo(t string) (map[string]interface{}, *model.TechnicalError)
	OnboardPartner(m model.CiamOnboardPartnerRequest) (*model.CiamUserResponse, *model.TechnicalError)
	Authenticate(m model.CiamAuthenticationRequest) (*model.CiamAuthenticationResponse, *model.TechnicalError)
}

func NewCognito

func NewCognito(c Cognito) CiamWatcher

type Cognito

type Cognito struct {
	Provider *cognito.CognitoIdentityProvider
	UserPool string
	ClientId string
	Scrt     string
	Region   string
	JWK      string
	Logger   *zap.Logger
}

func (*Cognito) Authenticate

func (c *Cognito) Authenticate(m model.CiamAuthenticationRequest) (*model.CiamAuthenticationResponse, *model.TechnicalError)

func (*Cognito) JwtInfo

func (c *Cognito) JwtInfo(t string) (map[string]interface{}, *model.TechnicalError)

func (*Cognito) OnboardPartner

func (c *Cognito) OnboardPartner(m model.CiamOnboardPartnerRequest) (*model.CiamUserResponse, *model.TechnicalError)

type Consul

type Consul struct {
	Host    string
	Port    int
	Service string
	Logger  *zap.Logger
	Viper   *viper.Viper
}

func (*Consul) Register

func (c *Consul) Register() *model.TechnicalError

type ConsulWatcher

type ConsulWatcher interface {
	Register() *model.TechnicalError
}

func NewConsul

func NewConsul(c Consul) ConsulWatcher

type Gopaid

type Gopaid struct {
	Host   string
	ApiKey string
	Logger *zap.Logger
	Rest
}

func (*Gopaid) Topup

func (g *Gopaid) Topup(inp *model.GopaidTopUpRequest) (*model.GopaidTopupResponse, *model.TechnicalError)

type GopaidAdapter

type GopaidAdapter interface {
	Topup(inp *model.GopaidTopUpRequest) (*model.GopaidTopupResponse, *model.TechnicalError)
}

func NewGopaid

func NewGopaid(g Gopaid) GopaidAdapter

type Josvo

type Josvo struct {
	Host   string
	ApiKey string
	Logger *zap.Logger
	Rest
}

func (*Josvo) AccountTransfer

func (j *Josvo) AccountTransfer(inp *model.JosvoAccountTransferRequest) (*model.JosvoAccountTransferResponse, *model.TechnicalError)

type JosvoAdapter

type JosvoAdapter interface {
	AccountTransfer(inp *model.JosvoAccountTransferRequest) (*model.JosvoAccountTransferResponse, *model.TechnicalError)
}

func NewJosvo

func NewJosvo(j Josvo) JosvoAdapter

type Linksaja

type Linksaja struct {
	Host     string
	Logger   *zap.Logger
	Username string
	Password string
	Rest
}

func (*Linksaja) Authorization

func (l *Linksaja) Authorization() (*model.LinksajaAuthorizationResponse, *model.TechnicalError)

func (*Linksaja) FundTransfer

func (l *Linksaja) FundTransfer(inp *model.LinksajaFundTransferRequest) (*model.LinksajaFundTransferResponse, *model.TechnicalError)

type LinksajaAdapter

type LinksajaAdapter interface {
	Authorization() (*model.LinksajaAuthorizationResponse, *model.TechnicalError)
	FundTransfer(inp *model.LinksajaFundTransferRequest) (*model.LinksajaFundTransferResponse, *model.TechnicalError)
}

func NewLinksaja

func NewLinksaja(l Linksaja) LinksajaAdapter

type Middletrans

type Middletrans struct {
	Host   string
	ApiKey string
	Logger *zap.Logger
	Rest
}

func (*Middletrans) WalletTransfer

func (mt *Middletrans) WalletTransfer(inp *model.MiddletransWalletTransferRequest) (*model.MiddletransWalletTransferResponse, *model.TechnicalError)

type MiddletransAdapter

type MiddletransAdapter interface {
	WalletTransfer(inp *model.MiddletransWalletTransferRequest) (*model.MiddletransWalletTransferResponse,
		*model.TechnicalError)
}

func NewMiddletrans

func NewMiddletrans(mt Middletrans) MiddletransAdapter

type Rest

type Rest struct {
	BackoffInterval   time.Duration
	MaxJitterInterval time.Duration
	Timeout           time.Duration
}

func (*Rest) Client

func (r *Rest) Client() *httpclient.Client

type S3Bucket

type S3Bucket struct {
	Bucket   string
	Uploader *s3manager.Uploader
	Logger   *zap.Logger
}

func (*S3Bucket) Upload

func (b *S3Bucket) Upload(req *model.S3UploadRequest) (*s3manager.UploadOutput, *model.TechnicalError)

type S3Watcher

type S3Watcher interface {
	Upload(req *model.S3UploadRequest) (*s3manager.UploadOutput, *model.TechnicalError)
}

func NewS3

func NewS3(b S3Bucket) S3Watcher

type SES

type SES struct {
	Sender *string
	SES    *sesv2.SESV2
	Logger *zap.Logger
}

func (*SES) SendEmail

func (s *SES) SendEmail(m model.SendEmailRequest) (*model.TransactionResponse, *model.TechnicalError)

type SESAdapter

type SESAdapter interface {
	SendEmail(m model.SendEmailRequest) (*model.TransactionResponse, *model.TechnicalError)
}

func NewSES

func NewSES(s SES) SESAdapter

type SQS

type SQS struct {
	SQS *sqs.SQS
}

func (*SQS) DeleteMessages

func (s *SQS) DeleteMessages(q string, h string) *sqs.DeleteMessageOutput

func (*SQS) GetMessages

func (s *SQS) GetMessages(t string) *sqs.Message

func (*SQS) SendMessage

func (s *SQS) SendMessage(q string, msg string) error

type SQSAdapter

type SQSAdapter interface {
	GetMessages(q string) *sqs.Message
	DeleteMessages(q string, h string) *sqs.DeleteMessageOutput
	SendMessage(q string, msg string) error
}

func NewSQS

func NewSQS(c SQS) SQSAdapter

type Xenit

type Xenit struct {
	Host               string
	BasicAuthorization string
	Logger             *zap.Logger
	Rest
}

func (*Xenit) WalletTopup

func (x *Xenit) WalletTopup(inp *model.XenitWalletTopupRequest) (*model.XenitWalletTopupResponse, *model.TechnicalError)

type XenitAdapter

type XenitAdapter interface {
	WalletTopup(inp *model.XenitWalletTopupRequest) (*model.XenitWalletTopupResponse, *model.TechnicalError)
}

func NewXenit

func NewXenit(x Xenit) XenitAdapter