opener.go 469 B

123456789101112131415161718192021
  1. package walimpls
  2. import (
  3. "context"
  4. "github.com/milvus-io/milvus/pkg/streaming/util/types"
  5. )
  6. // OpenOption is the option for allocating wal impls instance.
  7. type OpenOption struct {
  8. Channel types.PChannelInfo // Channel to open.
  9. }
  10. // OpenerImpls is the interface for build WALImpls instance.
  11. type OpenerImpls interface {
  12. // Open open a WALImpls instance.
  13. Open(ctx context.Context, opt *OpenOption) (WALImpls, error)
  14. // Close release the resources.
  15. Close()
  16. }