gevents

Apr 9, 2023

Changes in this version

+ type PublishOption func(*pubOptions)

+ func WithMustHaveSubscriber() PublishOption

+ type RegisterOption func(opt *registerOptions)

+ func WithRegisterPriority(priority int) RegisterOption

Sep 26, 2022

Changes in this version

+ type MockExecutor struct

+ func NewMockExecutor(ctrl *gomock.Controller) *MockExecutor

+ func (m *MockExecutor) EXPECT() *MockExecutorMockRecorder

+ func (m *MockExecutor) Execute(ctx context.Context, event interface{}) error

+ func (m *MockExecutor) Types() []reflect.Type

+ type MockExecutorMockRecorder struct

+ func (mr *MockExecutorMockRecorder) Execute(ctx, event interface{}) *gomock.Call

+ func (mr *MockExecutorMockRecorder) Types() *gomock.Call

+ type MockPublisher struct

+ func NewMockPublisher(ctrl *gomock.Controller) *MockPublisher

+ func (m *MockPublisher) EXPECT() *MockPublisherMockRecorder

+ func (m *MockPublisher) Publish(ctx context.Context, event interface{}, opts ...PublishOpt) error

+ type MockPublisherMockRecorder struct

+ func (mr *MockPublisherMockRecorder) Publish(ctx, event interface{}, opts ...interface{}) *gomock.Call

Sep 10, 2022

Changes in this version

+ type RegisteOptFunc func(opt *registeOpt)

+ func RegisteWithPriority(priority int) RegisteOptFunc

Jun 29, 2022

Changes in this version

+ func Clear()

+ func Register(executors ...Executor)

+ func SetDefaultExecutor(executor Executor)

+ type DefaultPublisher struct

+ func (ep *DefaultPublisher) Publish(ctx context.Context, event interface{}, opts ...PublishOpt) error

+ type Executor interface

+ Execute func(ctx context.Context, event interface{}) error

+ Types func() []reflect.Type

+ type Option struct

+ type PublishOpt func(*Option)

+ func MustHaveSubscriber() PublishOpt

+ type Publisher interface

+ Publish func(ctx context.Context, event interface{}, opts ...PublishOpt) error