pubsub

Documentation

Index

• type CreateEvent
• type CreatorPublisher
• type CreatorSubscriber
• type DeleteAllEvent
• type DeleteByIDEvent
• type DeleterPublisher
• type DeleterSubscriber
• type Subscription
• type UpdateEvent
• type UpdaterPublisher
• type UpdaterSubscriber

Types

type CreateEvent

type CreateEvent[Ent any] struct{ Entity Ent }

type CreatorPublisher

type CreatorPublisher[Ent any] interface {
	SubscribeToCreatorEvents(context.Context, CreatorSubscriber[Ent]) (Subscription, error)
}

type CreatorSubscriber

type CreatorSubscriber[Ent any] interface {
	HandleCreateEvent(ctx context.Context, event CreateEvent[Ent]) error
	errutils.ErrorHandler
}

type DeleteAllEvent

type DeleteAllEvent struct{}

type DeleteByIDEvent

type DeleteByIDEvent[ID any] struct{ ID ID }

type DeleterPublisher

type DeleterPublisher[ID any] interface {
	SubscribeToDeleterEvents(context.Context, DeleterSubscriber[ID]) (Subscription, error)
}

type DeleterSubscriber

type DeleterSubscriber[ID any] interface {
	HandleDeleteByIDEvent(ctx context.Context, event DeleteByIDEvent[ID]) error
	HandleDeleteAllEvent(ctx context.Context, event DeleteAllEvent) error
	errutils.ErrorHandler
}

type Subscription

type Subscription interface {
	io.Closer
}

type UpdateEvent

type UpdateEvent[Ent any] struct{ Entity Ent }

type UpdaterPublisher

type UpdaterPublisher[Ent any] interface {
	SubscribeToUpdaterEvents(context.Context, UpdaterSubscriber[Ent]) (Subscription, error)
}

type UpdaterSubscriber

type UpdaterSubscriber[Ent any] interface {
	HandleUpdateEvent(ctx context.Context, event UpdateEvent[Ent]) error
	errutils.ErrorHandler
}