event

Documentation

Index

• type Event
  • func New(instanceHash hash.Hash, eventKey string, eventData *types.Struct) *Event
  • func (*Event) Descriptor() ([]byte, []int)
  • func (*Event) ProtoMessage()
  • func (m *Event) Reset()
  • func (m *Event) String() string
  • func (m *Event) XXX_DiscardUnknown()
  • func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Event) XXX_Merge(src proto.Message)
  • func (m *Event) XXX_Size() int
  • func (m *Event) XXX_Unmarshal(b []byte) error
• type Filter
  • func (f *Filter) HasKey() bool
  • func (f *Filter) Match(e *Event) bool
• type Listener
  • func NewListener(ps *pubsub.PubSub, topic string, f *Filter) *Listener
  • func (l *Listener) Close()
  • func (l *Listener) Listen()

Types

type Event

type Event struct {
	// Hash is a unique hash to identify event.
	Hash github_com_mesg_foundation_engine_hash.Hash `` /* 148-byte string literal not displayed */
	// instanceHash is hash of instance that can proceed an execution.
	InstanceHash github_com_mesg_foundation_engine_hash.Hash `` /* 169-byte string literal not displayed */
	// key is the key of the event.
	Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty" hash:"name:3" validate:"required,printascii"`
	// data is the data for the event.
	Data                 *types.Struct `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty" hash:"name:4"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Event represents a single event run in engine.

func New

func New(instanceHash hash.Hash, eventKey string, eventData *types.Struct) *Event

New creates an event eventKey with eventData for service s.

func (*Event) Descriptor

func (*Event) Descriptor() ([]byte, []int)

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) Reset

func (m *Event) Reset()

func (*Event) String

func (m *Event) String() string

func (*Event) XXX_DiscardUnknown

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal

func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event) XXX_Merge

func (m *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_Size

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal

func (m *Event) XXX_Unmarshal(b []byte) error

type Filter

type Filter struct {
	Hash         hash.Hash
	InstanceHash hash.Hash
	Key          string
}

Filter store fileds for matching events.

func (*Filter) HasKey

func (f *Filter) HasKey() bool

HasKey returns true if key is set to specified value.

func (*Filter) Match

func (f *Filter) Match(e *Event) bool

Match matches event.

type Listener

type Listener struct {
	C chan *Event
	// contains filtered or unexported fields
}

Listener provides functionalities to listen MESG events.

func NewListener

func NewListener(ps *pubsub.PubSub, topic string, f *Filter) *Listener

NewListener creates a new Listener with given sdk and filters.

func (*Listener) Close

func (l *Listener) Close()

Close stops listening for events.

func (*Listener) Listen

func (l *Listener) Listen()

Listen listens events that match filter.