processor

type Config struct {
	InstanceID string `mapstructure:"-"`

	MsgBuffer int `mapstructure:"msg_buffer"`

	ProcessorsRing ProcessorRingConfig `mapstructure:"ring"`
	Queue          queue.Config        `mapstructure:"queue"`
	ObjStore       objstore.Config     `mapstructure:"objstore"`
	Cluster        cl_cfg.Config       `mapstructure:"cluster"`
	Plugin         plugin.Config       `mapstructure:"plugin"`
}

type Processor struct {
	services.Service
	// contains filtered or unexported fields
}

type ProcessorRingConfig struct {
	Common util.CommonRingConfig `mapstructure:",squash"`
}