event

Documentation

Index

• func Provider(handler func(resolver infra.Resolver, listener Listener), options ...Option) infra.Provider
• type AsyncEvent
• type Event
• type Listener
• type Manager
  • func NewEventManager(store Store) Manager
• type MemoryEventStore
  • func (eventStore *MemoryEventStore) Listen(evtType string, listener interface{})
  • func (eventStore *MemoryEventStore) Publish(evt Event) error
  • func (eventStore *MemoryEventStore) SetManager(manager Manager)
  • func (eventStore *MemoryEventStore) Start(ctx context.Context) <-chan interface{}
• type Option
  • func SetStoreOption(h func(cc infra.Resolver) Store) Option
• type Publisher
• type Store
  • func NewMemoryEventStore(async bool, capacity int) Store

Functions

func Provider

func Provider(handler func(resolver infra.Resolver, listener Listener), options ...Option) infra.Provider

Provider create a event Provider

Types

type AsyncEvent

type AsyncEvent interface {
	Async() bool
}

type Event

type Event struct {
	Name  string
	Event interface{}
}

type Listener

type Listener interface {
	Listen(listeners ...interface{})
}

type Manager

type Manager interface {
	Publisher
	Listener
	Call(evt interface{}, listener interface{})
	Start(ctx context.Context) <-chan interface{}
}

func NewEventManager

func NewEventManager(store Store) Manager

NewEventManager create a eventManager

type MemoryEventStore

type MemoryEventStore struct {
	// contains filtered or unexported fields
}

MemoryEventStore is a event store for sync operations

func (*MemoryEventStore) Listen

func (eventStore *MemoryEventStore) Listen(evtType string, listener interface{})

Listen add a listener to a event

func (*MemoryEventStore) Publish

func (eventStore *MemoryEventStore) Publish(evt Event) error

Publish an event

func (*MemoryEventStore) SetManager

func (eventStore *MemoryEventStore) SetManager(manager Manager)

SetManager event manager

func (*MemoryEventStore) Start

func (eventStore *MemoryEventStore) Start(ctx context.Context) <-chan interface{}

type Option

type Option func(p *provider)

func SetStoreOption

func SetStoreOption(h func(cc infra.Resolver) Store) Option

SetStoreOption 设置底层存储实现

type Publisher

type Publisher interface {
	Publish(evt interface{}) error
}

type Store

type Store interface {
	Listen(eventName string, listener interface{})
	Publish(evt Event) error
	SetManager(manager Manager)
	Start(ctx context.Context) <-chan interface{}
}

Store is an interface for event store

func NewMemoryEventStore

func NewMemoryEventStore(async bool, capacity int) Store

NewMemoryEventStore create a sync event store