Documentation ¶
Index ¶
- Variables
- type Source
- func (s *Source) Close() error
- func (s *Source) Connect(ctx context.Context) error
- func (s *Source) OnConnect(h func(context.Context) error)
- func (s *Source) OnEvent(h eventbridge.EventHandlerFunc)
- func (s *Source) UpdateVersion(ctx context.Context, sid stream.ID, st stream.Type, v stream.Version) (err error)
- func (s *Source) WalkUnpublishedEvents(ctx context.Context, walk eventbridge.WalkFunc) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrConnectionClosed = errors.New("postgreSQL connections are closed")
View Source
var ErrUpdateVersion = errors.New("failed to update version")
Functions ¶
This section is empty.
Types ¶
type Source ¶
type Source struct {
// contains filtered or unexported fields
}
func (*Source) OnEvent ¶
func (s *Source) OnEvent(h eventbridge.EventHandlerFunc)
func (*Source) UpdateVersion ¶
func (*Source) WalkUnpublishedEvents ¶
Click to show internal directories.
Click to hide internal directories.