event

Documentation

Index

• Constants
• Variables
• func RegisterPublisher(name string, pub Publisher)
• type Event
  • func (e Event) GetSubject(prefix string) string
  • func (e Event) IsOver() bool
  • func (v Event) MarshalEasyJSON(w *jwriter.Writer)
  • func (v Event) MarshalJSON() ([]byte, error)
  • func (v *Event) UnmarshalEasyJSON(l *jlexer.Lexer)
  • func (v *Event) UnmarshalJSON(data []byte) error
• type Publisher
  • func GetPublisher(name string) (Publisher, error)

Constants

const (
	OverID = "_OVER_" // 事件结束 ID
)

Variables

var (
	ErrPublisherNotFound = errors.New("publisher not found")
)

Functions

func RegisterPublisher

func RegisterPublisher(name string, pub Publisher)

Types

type Event

type Event struct {
	ID         string                 `json:"id"`
	Schema     string                 `json:"schema"`
	Table      string                 `json:"table"`
	Action     string                 `json:"action"`
	Data       map[string]interface{} `json:"data"`
	CommitTime time.Time              `json:"commit_time"`
}

Event event structure for publishing to the NATS server.

func (Event) GetSubject

func (e Event) GetSubject(prefix string) string

GetSubject creates subject name from the prefix, schema and table name.

func (Event) IsOver

func (e Event) IsOver() bool

IsOver 判断是否是结束事件

func (Event) MarshalEasyJSON

func (v Event) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (Event) MarshalJSON

func (v Event) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*Event) UnmarshalEasyJSON

func (v *Event) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*Event) UnmarshalJSON

func (v *Event) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

type Publisher

type Publisher interface {
	Publish(subject string, evt *Event) error
	Close() error
}

Publisher 事件发布接口

func GetPublisher

func GetPublisher(name string) (Publisher, error)