da

Documentation

Index

• func NewService(userAssetRepos domain.IUserAssetRepository) da.PaymentService
• type Options
  • func Configure(configProvider configparser.Provider) (*Options, error)
  • func DefaultOptions() *Options
  • func (m *Options) String() (str string)
• type Server
  • func NewServer(ctx context.Context) (*Server, error)
  • func (s *Server) Run(ctx context.Context) error
• type ServerOptions
  • func DefaultServerOptions() *ServerOptions

Functions

func NewService

func NewService(userAssetRepos domain.IUserAssetRepository) da.PaymentService

Types

type Options

type Options struct {
	Server        *ServerOptions                                `mapstructure:"server"`
	MysqlDBClient *injectors.MysqlDBClientOptions               `mapstructure:"mysqlDBClient"`
	RmqConsumers  map[string]*subscriber.RmqPushConsumerOptions `mapstructure:"rmqConsumers"`
}

Options payment da opts

func Configure

func Configure(configProvider configparser.Provider) (*Options, error)

Configure inject config

func DefaultOptions

func DefaultOptions() *Options

DefaultOptions default opts

func (*Options) String

func (m *Options) String() (str string)

type Server

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

func NewServer

func NewServer(ctx context.Context) (*Server, error)

NewServer build server with wire, dependency obj inject, so init random

func (*Server) Run

func (s *Server) Run(ctx context.Context) error

Run reviews server

type ServerOptions

type ServerOptions struct {
	Addr                      string                 `mapstructure:"addr"`
	LogLevel                  logutils.Level         `mapstructure:"logLevel"`
	ProjectName               string                 `mapstructure:"projectName"`
	LogMeta                   map[string]interface{} `mapstructure:"logMeta"`
	OltpGrpcCollectorEndpoint string                 `mapstructure:"oltpCollectorGrpcEndpoint"`
}

func DefaultServerOptions

func DefaultServerOptions() *ServerOptions

DefaultServerOptions default opts