station

package
v0.0.0-...-2b0c82f Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 5, 2023 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ProvideUniversalClients

func ProvideUniversalClients(
	c redis2.UniversalClient,
) []redis2.UniversalClient

Types

type Options

type Options struct {
	Server                   *ServerOptions                       `mapstructure:"server"`
	RedisClusterClient       *injectors.RedisClusterClientOptions `mapstructure:"redisClusterClient"`
	AssetChangeEventProducer *injectors.RmqProducerClientOptions  `mapstructure:"assetChangeEventProducer"`
	PaymentDaClient          *injectors.PaymentDaClientOptions    `mapstruct:"paymentDaClient"`

	UserAssetTxMethod string `mapstructure:"userAssetTxMethod"`

	RmqConsumers map[string]*subscriber.RmqPushConsumerOptions `mapstructure:"rmqConsumers"`
}

func Configure

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

Configure inject config

func DefaultOptions

func DefaultOptions() *Options

DefaultOptions default opts

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) (err error)

Run kitex 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"`
}

ServerOptions server options

func DefaultServerOptions

func DefaultServerOptions() *ServerOptions

DefaultServerOptions default opts

Directories

Path Synopsis
rmq

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL