deep

Documentation

Index

• func NewDeepReceiver(cfg *DeepConfig, next types.ProcessSnapshots, pollNext types.ProcessPoll, ...) (types.Receiver, error)
• type DeepConfig
  • func CreateConfig(cfg interface{}) (*DeepConfig, error)
• type Protocols

Functions

func NewDeepReceiver

func NewDeepReceiver(cfg *DeepConfig, next types.ProcessSnapshots, pollNext types.ProcessPoll, logger log.Logger) (types.Receiver, error)

Types

type DeepConfig

type DeepConfig struct {
	Protocols *Protocols `mapstructure:"protocols"`
	Debug     bool       `mapstructure:"debug"`
}

func CreateConfig

func CreateConfig(cfg interface{}) (*DeepConfig, error)

type Protocols

type Protocols struct {
	GRPC *configgrpc.GRPCServerSettings `mapstructure:"grpc"`
}