consumer

package

v3.6.15 Latest Latest Go to latest Published: Aug 5, 2026 License: AGPL-3.0 Imports: 29 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/grafana/loki

Links

Open Source Insights

Documentation ¶

Index ¶

type Config
type Service
- func New(kafkaCfg kafka.Config, cfg Config, mCfg metastore.Config, ...) *Service

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	logsobj.BuilderConfig
	UploaderConfig   uploader.Config `yaml:"uploader"`
	IdleFlushTimeout time.Duration   `yaml:"idle_flush_timeout"`
}

func (*Config) RegisterFlags ¶

func (cfg *Config) RegisterFlags(f *flag.FlagSet)

func (*Config) RegisterFlagsWithPrefix ¶

func (cfg *Config) RegisterFlagsWithPrefix(prefix string, f *flag.FlagSet)

func (*Config) Validate ¶

func (cfg *Config) Validate() error

type Service ¶

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

func New ¶

func New(kafkaCfg kafka.Config, cfg Config, mCfg metastore.Config, bucket objstore.Bucket, scratchStore scratch.Store, instanceID string, partitionRing ring.PartitionRingReader, reg prometheus.Registerer, logger log.Logger) *Service

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
logsobj Package logsobj provides tooling for creating logs-oriented data objects.	Package logsobj provides tooling for creating logs-oriented data objects.

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