123456789101112131415161718192021222324252627282930313233 |
- package helper
- import (
- "go.uber.org/zap"
- "github.com/milvus-io/milvus/pkg/log"
- "github.com/milvus-io/milvus/pkg/streaming/util/types"
- "github.com/milvus-io/milvus/pkg/streaming/walimpls"
- )
- // NewWALHelper creates a new WALHelper.
- func NewWALHelper(opt *walimpls.OpenOption) *WALHelper {
- return &WALHelper{
- logger: log.With(zap.Any("channel", opt.Channel)),
- channel: opt.Channel,
- }
- }
- // WALHelper is a helper for WAL implementation.
- type WALHelper struct {
- logger *log.MLogger
- channel types.PChannelInfo
- }
- // Channel returns the channel of the WAL.
- func (w *WALHelper) Channel() types.PChannelInfo {
- return w.channel
- }
- // Log returns the logger of the WAL.
- func (w *WALHelper) Log() *log.MLogger {
- return w.logger
- }
|