criers

type AzSbConfig struct {
	Endpoint string                 `yaml:"endpoint"`
	Topic    string                 `yaml:"topic"`
	Layout   map[string]interface{} `yaml:"layout"`
}

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

type Crier interface {
	Send(ctx context.Context, data []byte) error
	Close()
}

type NatsSbConfig struct {
	Endpoint string                 `yaml:"endpoint"`
	Topic    string                 `yaml:"topic"`
	Layout   map[string]interface{} `yaml:"layout"`
}

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

type ReceiverConfig struct {
	Name   string        `yaml:"name"`
	Azsb   *AzSbConfig   `yaml:"azsb"`
	Nats   *NatsSbConfig `yaml:"nats"`
	Stdout *StdoutConfig `yaml:"stdout"`
}

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

type StdoutConfig struct {
	Layout map[string]interface{} `yaml:"layout"`
}