ondisk

Documentation

Index

• Constants
• type Stream
  • func Init(name string, ctx context.Context) (s *Stream, err error)
  • func (s *Stream) End() (pos uint64, err error)
  • func (s *Stream) Name() string
  • func (s *Stream) Stream(from store.StreamPosition, ctx context.Context) (out <-chan store.ReadEvent, err error)
  • func (s *Stream) Write() chan<- store.WriteEvent

Constants

const (
	B  = 1
	KB = B << 10
	MB = KB << 10
	GB = MB << 10
)

Types

type Stream

type Stream struct {
	// contains filtered or unexported fields
}

func Init

func Init(name string, ctx context.Context) (s *Stream, err error)

func (*Stream) End

func (s *Stream) End() (pos uint64, err error)

func (*Stream) Name

func (s *Stream) Name() string

func (*Stream) Stream

func (s *Stream) Stream(
	from store.StreamPosition,
	ctx context.Context,
) (out <-chan store.ReadEvent, err error)

func (*Stream) Write

func (s *Stream) Write() chan<- store.WriteEvent