event

package
v0.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 18, 2021 License: BSD-3-Clause Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BaseProcesser 

type BaseProcesser struct {
	Bus  *Bus
	Name string
}

BaseProcesser basic processer

func NewBaseProcesser 

func NewBaseProcesser(name string) *BaseProcesser

NewBaseProcesser constructor

func (*BaseProcesser) CreateEvent 

func (b *BaseProcesser) CreateEvent(name, strType string, data Data) *Event

CreateEvent create new event

func (*BaseProcesser) GetName 

func (b *BaseProcesser) GetName() string

GetName return the processer name

func (*BaseProcesser) Init 

func (b *BaseProcesser) Init(bus *Bus) (err error)

Init call before start

func (*BaseProcesser) Send 

func (b *BaseProcesser) Send(name, strType string, data Data)

Send send event

func (*BaseProcesser) Start 

func (b *BaseProcesser) Start() (err error)

Start start the processer

func (*BaseProcesser) Stop 

func (b *BaseProcesser) Stop() (err error)

Stop stop the processer

type Bus 

type Bus struct {
	Sub Subscriber
	Pub Publisher
	// contains filtered or unexported fields
}

Bus event bus

func NewBus 

func NewBus(pub Publisher, sub Subscriber) *Bus

func (*Bus) Close 

func (b *Bus) Close()

func (*Bus) Send 

func (b *Bus) Send(e *Event) (err error)

func (*Bus) Start 

func (b *Bus) Start()

func (*Bus) Subscribe 

func (b *Bus) Subscribe(sub string, cb ProcessCall) (err error)

Subscribe event

func (*Bus) WaitEmpty 

func (b *Bus) WaitEmpty()

type Data 

type Data interface{}

type Event 

type Event struct {
	Name string
	Type string
	Time time.Time
	From string
	Data Data
}

Event base event

func NewEvent 

func NewEvent(name, strType, from string, data Data) *Event

func (*Event) GetData 

func (e *Event) GetData() Data

func (*Event) GetFrom 

func (e *Event) GetFrom() string

func (*Event) GetName 

func (e *Event) GetName() string

func (*Event) GetTime 

func (e *Event) GetTime() time.Time

func (*Event) GetType 

func (e *Event) GetType() string

type ProcessCall 

type ProcessCall func(e Event) error

ProcessCall callback to process event

type ProcessList 

type ProcessList []ProcessCall

type Processer 

type Processer interface {
	Init(*Bus) error
	GetName() string

	Start() error
	Stop() error
}

Processer handler of event

type Processers 

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

Processers processers

func NewProcessers 

func NewProcessers() *Processers

NewProcessers create default Processers

func (*Processers) Add 

func (h *Processers) Add(eh Processer) (err error)

Add add proocesser

func (*Processers) Adds 

func (h *Processers) Adds(ehs ...Processer) (err error)

Adds add processer

func (*Processers) Start 

func (h *Processers) Start() (err error)

Start start all processers

func (*Processers) Stop 

func (h *Processers) Stop() (err error)

Stop stop all processers

func (*Processers) WaitClose 

func (h *Processers) WaitClose(duration time.Duration)

WaitClose wait for duration after bus is empty,and then close

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.