Documentation
¶
Index ¶
- Constants
- type Channel
- type Collector
- type Config
- type ListenAPI
- type Options
- func (eo Options) EffExecuteTimeout(defOpts Options) (time.Duration, error)
- func (eo Options) EffRetryExecuteDelay(defOpts Options) (time.Duration, error)
- func (eo Options) EffRetryExecuteMaxDelay(defOpts Options) (time.Duration, error)
- func (eo Options) EffTTL(defOpts Options) (time.Duration, error)
- type PromMetrics
- type RedisStorage
- type Service
- type TaskExecutor
- type Tracing
Constants ¶
View Source
const (
EnvPrefix = "CHANNEL_TRANSFER"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Channel ¶ added in v0.0.6
type Channel struct {
Name string `mapstructure:"name" validate:"required"`
TaskExecutor *TaskExecutor `mapstructure:"taskExecutor"`
}
type Config ¶
type Config struct {
LogLevel string `mapstructure:"logLevel" validate:"required"`
LogType string `mapstructure:"logType" validate:"required"`
ProfilePath string `mapstructure:"profilePath"`
UserName string `mapstructure:"userName" validate:"required"`
ListenAPI *ListenAPI `mapstructure:"listenAPI"`
RedisStorage *RedisStorage `mapstructure:"redisStorage" validate:"required"`
Service *Service `mapstructure:"service" validate:"required"`
PromMetrics *PromMetrics `mapstructure:"promMetrics"`
Tracing *Tracing `mapstructure:"tracing"`
Channels []Channel `mapstructure:"channels" validate:"required,dive,required"`
Options Options `mapstructure:"options" validate:"required"`
}
func (Config) WithoutSensitiveData ¶
WithoutSensitiveData returns copy of config with empty sensitive data. This config might be used for trace logging.
type ListenAPI ¶
type Options ¶
type Options struct {
BatchTxPreimagePrefix string `mapstructure:"batchTxPreimagePrefix" validate:"required"`
CollectorsBufSize uint `mapstructure:"collectorsBufSize" validate:"required"`
ExecuteTimeout *time.Duration `mapstructure:"executeTimeout"`
RetryExecuteAttempts uint `mapstructure:"retryExecuteAttempts" validate:"required"`
RetryExecuteMaxDelay *time.Duration `mapstructure:"retryExecuteMaxDelay"`
RetryExecuteDelay *time.Duration `mapstructure:"retryExecuteDelay"`
TTL *time.Duration `mapstructure:"ttl"`
TransfersInHandleOnChannel uint `mapstructure:"transfersInHandleOnChannel" validate:"required"`
NewestRequestStreamBufferSize uint `mapstructure:"newestRequestStreamBufferSize" validate:"required"`
ServedChannels []string `mapstructure:"servedChannels"`
}
func (Options) EffExecuteTimeout ¶
func (Options) EffRetryExecuteDelay ¶
func (Options) EffRetryExecuteMaxDelay ¶
type PromMetrics ¶
type RedisStorage ¶
type RedisStorage struct {
Addr []string `mapstructure:"addr" validate:"required,dive,required"`
Password string `mapstructure:"password"`
DBPrefix string `mapstructure:"dbPrefix" validate:"required"`
AfterTransferTTL *time.Duration `mapstructure:"afterTransferTTL" validate:"required"`
CACert string `mapstructure:"caCert,omitempty"`
TLSHostnameOverride string `mapstructure:"tlsHostnameOverride,omitempty"`
ClientKey string `mapstructure:"clientKey,omitempty"`
ClientCert string `mapstructure:"clientCert,omitempty"`
// contains filtered or unexported fields
}
func (*RedisStorage) EffAfterTransferTTL ¶
func (rs *RedisStorage) EffAfterTransferTTL(cfg RedisStorage) (time.Duration, error)
func (*RedisStorage) TLSConfig ¶
func (rs *RedisStorage) TLSConfig() *tls.Config
type Service ¶
type Service struct {
Address string `mapstructure:"address" validate:"required"`
// contains filtered or unexported fields
}
type TaskExecutor ¶ added in v0.0.6
type TaskExecutor struct {
AddressGRPC string `mapstructure:"addressGRPC" validate:"required"`
// contains filtered or unexported fields
}
func (*TaskExecutor) TLSConfig ¶ added in v0.0.6
func (b *TaskExecutor) TLSConfig() *tls.Config
Click to show internal directories.
Click to hide internal directories.