foundation

Documentation

Index

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

Types

type Stream

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

func Init

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

func (*Stream) End

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

func (*Stream) Name

func (es *Stream) Name() string

func (*Stream) Stream

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

func (*Stream) Write

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