event

Documentation

Index

• Constants
• type DefaultEvent
  • func NewEvent(header map[string]interface{}, body []byte) *DefaultEvent
  • func (de *DefaultEvent) Body() []byte
  • func (de *DefaultEvent) Fill(meta api.Meta, header map[string]interface{}, body []byte)
  • func (de *DefaultEvent) Header() map[string]interface{}
  • func (de *DefaultEvent) Meta() api.Meta
  • func (de *DefaultEvent) Release()
  • func (de *DefaultEvent) String() string
• type DefaultMeta
  • func NewDefaultMeta() *DefaultMeta
  • func (dm *DefaultMeta) Get(key string) (value interface{}, exist bool)
  • func (dm *DefaultMeta) GetAll() map[string]interface{}
  • func (dm *DefaultMeta) Set(key string, value interface{})
  • func (dm *DefaultMeta) Source() string
  • func (dm *DefaultMeta) String() string
• type Factory
• type Pool
  • func NewDefaultPool(capacity int) *Pool
  • func NewPool(capacity int, factory Factory) *Pool
  • func (p *Pool) Get() api.Event
  • func (p *Pool) GetN(n int) []api.Event
  • func (p *Pool) Put(event api.Event)
  • func (p *Pool) PutAll(events []api.Event)

Constants

const (
	SystemKeyPrefix  = "system"
	PrivateKeyPrefix = "@private"

	SystemPipelineKey    = SystemKeyPrefix + "PipelineName"
	SystemSourceKey      = SystemKeyPrefix + "SourceName"
	SystemProductTimeKey = SystemKeyPrefix + "ProductTime"

	Body = "body"
)

Types

type DefaultEvent

type DefaultEvent struct {
	H map[string]interface{} `json:"header"`
	B []byte                 `json:"body"`
	M api.Meta               `json:"meta"`
}

func NewEvent

func NewEvent(header map[string]interface{}, body []byte) *DefaultEvent

func (*DefaultEvent) Body

func (de *DefaultEvent) Body() []byte

func (*DefaultEvent) Fill

func (de *DefaultEvent) Fill(meta api.Meta, header map[string]interface{}, body []byte)

func (*DefaultEvent) Header

func (de *DefaultEvent) Header() map[string]interface{}

func (*DefaultEvent) Meta

func (de *DefaultEvent) Meta() api.Meta

func (*DefaultEvent) Release

func (de *DefaultEvent) Release()

func (*DefaultEvent) String

func (de *DefaultEvent) String() string

type DefaultMeta

type DefaultMeta struct {
	Properties map[string]interface{} `json:"properties"`
}

func NewDefaultMeta

func NewDefaultMeta() *DefaultMeta

func (*DefaultMeta) Get

func (dm *DefaultMeta) Get(key string) (value interface{}, exist bool)

func (*DefaultMeta) GetAll

func (dm *DefaultMeta) GetAll() map[string]interface{}

func (*DefaultMeta) Set

func (dm *DefaultMeta) Set(key string, value interface{})

func (*DefaultMeta) Source

func (dm *DefaultMeta) Source() string

func (*DefaultMeta) String

func (dm *DefaultMeta) String() string

type Factory

type Factory func() api.Event

type Pool

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

func NewDefaultPool

func NewDefaultPool(capacity int) *Pool

func NewPool

func NewPool(capacity int, factory Factory) *Pool

func (*Pool) Get

func (p *Pool) Get() api.Event

func (*Pool) GetN

func (p *Pool) GetN(n int) []api.Event

func (*Pool) Put

func (p *Pool) Put(event api.Event)

func (*Pool) PutAll

func (p *Pool) PutAll(events []api.Event)