Function newPartitionSectionWriter

modules/blockbuilder/partition_writer.go:46–61

(logger log.Logger, partition, firstOffset uint64, startTime time.Time, cycleDuration, slackDuration time.Duration, blockCfg BlockConfig, overrides Overrides, wal *wal.WAL, enc encoding.VersionedEncoding)

}

func newPartitionSectionWriter(logger log.Logger, partition, firstOffset uint64, startTime time.Time, cycleDuration, slackDuration time.Duration, blockCfg BlockConfig, overrides Overrides, wal *wal.WAL, enc encoding.VersionedEncoding) *writer {
	return &writer{
		logger:        logger,
		partition:     partition,
		startOffset:   firstOffset,
		startTime:     startTime,
		cycleDuration: cycleDuration,
		slackDuration: slackDuration,
		blockCfg:      blockCfg,
		overrides:     overrides,
		wal:           wal,
		enc:           enc,
		mtx:           sync.Mutex{},
		m:             make(map[string]*tenantStore),
	}
}

func (p *writer) pushBytes(ts time.Time, tenant string, req *tempopb.PushBytesRequest) error {
	level.Debug(p.logger).Log(