milvus-io--milvus/pkg/streaming/walimpls/opener.go

package walimpls

import (
	"context"

	"github.com/milvus-io/milvus/pkg/v3/streaming/util/types"
	"github.com/milvus-io/milvus/pkg/v3/util/merr"
)

// OpenOption is the option for allocating wal impls instance.
type OpenOption struct {
	Channel types.PChannelInfo // Channel to open.
}

// Validate validates the OpenOption.
func (oo OpenOption) Validate() error {
	if oo.Channel.Name == "" {
		return merr.WrapErrParameterInvalidMsg("channel name is empty")
	}
	if oo.Channel.Term < 0 {
		return merr.WrapErrParameterInvalidMsg("channel term is negative")
	}
	if oo.Channel.AccessMode != types.AccessModeRO && oo.Channel.AccessMode != types.AccessModeRW {
		return merr.WrapErrParameterInvalidMsg("undefined access mode")
	}
	return nil
}

// OpenerImpls is the interface for build WALImpls instance.
type OpenerImpls interface {
	// Open open a WALImpls instance.
	// If the opt.AccessMode is AccessModeRO, the WALImpls should be read-only, the append operation will panic.
	Open(ctx context.Context, opt *OpenOption) (WALImpls, error)

	// Close release the resources.
	Close()
}