Documentation ¶
Index ¶
- Constants
- Variables
- func ChannelBuilder(st stream.Type) string
- func NewCodec(st stream.Type) codec.Codec
- func NewReplayAllStreamsCommand(st stream.Type) stream.Command
- func NewReplayStreamCommand(st stream.Type, sid stream.ID) stream.Command
- func NewReplayStreamFromVersionCommand(st stream.Type, sid stream.ID, from stream.Version) stream.Command
- func SID(st stream.Type, sid stream.ID, ct stream.CommandType) string
- type Bus
- func (b *Bus) Close() (err error)
- func (b *Bus) Receive(ctx context.Context, st stream.Type, h Handler) error
- func (b *Bus) ReplayStream(ctx context.Context, sid stream.ID, st stream.Type) error
- func (b *Bus) ReplayStreamFromVersion(ctx context.Context, sid stream.ID, st stream.Type, from stream.Version) error
- func (b *Bus) ReplayStreams(ctx context.Context, st stream.Type) error
- func (b *Bus) Send(ctx context.Context, c stream.Command) error
- type Controller
- type EventPlayer
- func (r *EventPlayer) ReplayStream(ctx context.Context, sid stream.ID, st stream.Type, withDelay time.Duration) error
- func (r *EventPlayer) ReplayStreamFrom(ctx context.Context, sid stream.ID, st stream.Type, fromEvents stream.Version, ...) error
- func (r *EventPlayer) ReplayStreams(ctx context.Context, st stream.Type, withDelay time.Duration) error
- type Handler
- type InMemStore
- type Option
- type Receiver
- type ReceiverOption
- type Sender
- type SenderOption
- type State
- type Status
- type Store
- type Version
Constants ¶
View Source
const ( ReplayAllStreamsCommand = stream.CommandType("ReplayAllStreams") ReplayStreamCommand = stream.CommandType("ReplayPlayerStream") ReplayStreamFromVersionCommand = stream.CommandType("ReplayStreamFromVersion") )
Variables ¶
Functions ¶
func ChannelBuilder ¶
func NewReplayStreamCommand ¶
Types ¶
type Bus ¶
type Bus struct {
// contains filtered or unexported fields
}
func (*Bus) ReplayStream ¶
func (*Bus) ReplayStreamFromVersion ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
func NewController ¶
func NewController(r *EventPlayer, s Store, o ...Option) *Controller
type EventPlayer ¶
type EventPlayer struct {
// contains filtered or unexported fields
}
func New ¶
func New( eventStore eventstore.Store, publisher eventbus.Publisher, ) *EventPlayer
func (*EventPlayer) ReplayStream ¶
func (*EventPlayer) ReplayStreamFrom ¶
func (*EventPlayer) ReplayStreams ¶
type InMemStore ¶
type InMemStore struct {
// contains filtered or unexported fields
}
func NewInMemStore ¶
func NewInMemStore() *InMemStore
type Receiver ¶
func NewReceiver ¶
func NewReceiver( r messaging.Receiver, e *commandbus.Envelope, o ...ReceiverOption, ) Receiver
type ReceiverOption ¶
type ReceiverOption func(*receiver)
func ReceiverChannelBuilder ¶
func ReceiverChannelBuilder(cb messaging.ChannelBuilderFunc) ReceiverOption
func ReceiverErrorHandler ¶
func ReceiverErrorHandler(h messaging.ErrorHandler) ReceiverOption
type Sender ¶
func NewSender ¶
func NewSender(s messaging.Sender, e *commandbus.Envelope, o ...SenderOption) Sender
type SenderOption ¶
type SenderOption func(*sender)
func SenderChannelBuilder ¶
func SenderChannelBuilder(cb messaging.ChannelBuilderFunc) SenderOption
type State ¶
type State struct {
// contains filtered or unexported fields
}
func (*State) IsProcessing ¶
func (*State) MarshalJSON ¶
func (*State) Processing ¶
func (s *State) Processing()
func (*State) UnmarshalJSON ¶
Click to show internal directories.
Click to hide internal directories.