eventstore

Documentation

Index

• Constants
• type Client
  • func NewClient(host string) (c *Client, err error)
  • func (c *Client) Close() error
• type Stream
  • func NewStream(c *Client, stream 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 BATCH_SIZE = 1000 //5000 is an arbitrary number, should probably be based on something else.

Types

type Client

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

func NewClient

func NewClient(host string) (c *Client, err error)

func (*Client) Close

func (c *Client) Close() error

type Stream

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

Stream Adding 1 to all revisions so position 0 is reserved for the null condition.

func NewStream

func NewStream(c *Client, stream 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