events

Documentation

Index

• Constants
• Variables
• func NewEventService(bufSize int) *defaultEventService
• type Event
  • func (e *Event) GetPayLoad() interface{}
  • func (e *Event) GetType() string
• type IEvent
• type Service

Constants

const (
	EventChanSize = 4096
)

Variables

var DisconnectedErr = errors.New("Service Disconnected ")

Functions

func NewEventService

func NewEventService(bufSize int) *defaultEventService

Types

type Event

type Event struct {
	Type    string
	PayLoad interface{}
}

func (*Event) GetPayLoad

func (e *Event) GetPayLoad() interface{}

func (*Event) GetType

func (e *Event) GetType() string

type IEvent

type IEvent interface {
	GetType() string
	GetPayLoad() interface{}
}

type Service

type Service interface {
	Connect() error

	Disconnect() error

	Get(ctx context.Context) (IEvent, error)

	Put(ctx context.Context, event IEvent) error
}