streams

Documentation

Index

• type Handler
• type Id
  • func ParseId(format string, args ...interface{}) Id
  • func (id Id) HasEntity() bool
  • func (id Id) String() string
  • func (id Id) Value() (driver.Value, error)
  • func (id Id) WithEntity(format string, args ...interface{}) Id
• type Message
• type NamedSnapshot

Types

type Handler

type Handler interface {
	Handle(ctx context.Context, msg Message) error
}

type Id

type Id struct {
	Group  string
	Entity string
}

func ParseId

func ParseId(format string, args ...interface{}) Id

func (Id) HasEntity

func (id Id) HasEntity() bool

func (Id) String

func (id Id) String() string

func (Id) Value

func (id Id) Value() (driver.Value, error)

func (Id) WithEntity

func (id Id) WithEntity(format string, args ...interface{}) Id

convenience method to construct an entity id from another

type Message

type Message struct {
	Number      int64       // place in the stream, starting at 1
	Stream      Id          // name of the stream this message belongs to
	Type        string      // name of the type of the message
	Data        interface{} // instance of the given Group
	GroupNumber int64       // Ordering within the group
	Time        time.Time   // time the message was first recorded
}

type NamedSnapshot

type NamedSnapshot interface {
	SnapshotName() string
}

Marker interface used to indicate that a view or projection supports snapshotting. The provided name is used to store the instance as a json blob.