app

Documentation

Index

• type App
  • func Initialize(i *common.Inject) (x *App)
  • func (x *App) Get(key string) *nats.Subscription
  • func (x *App) NamespaceParse() string
  • func (x *App) Pipe(input M, paths []string, kind interface{}) (err error)
  • func (x *App) Push(key string, msg *nats.Msg) (err error)
  • func (x *App) Remove(key string)
  • func (x *App) RemoveSubscribe(key string) (err error)
  • func (x *App) Run() (err error)
  • func (x *App) Set(key string, v *nats.Subscription)
  • func (x *App) SetSubscribe(key string, option *client.StreamOption) (err error)
  • func (x *App) Transform(data M, rules M) (err error)
• type M
• type Payload

Types

type App

type App struct {
	*common.Inject

	M sync.Map
}

func Initialize

func Initialize(i *common.Inject) (x *App)

func (*App) Get

func (x *App) Get(key string) *nats.Subscription

func (*App) NamespaceParse

func (x *App) NamespaceParse() string

func (*App) Pipe

func (x *App) Pipe(input M, paths []string, kind interface{}) (err error)

func (*App) Push

func (x *App) Push(key string, msg *nats.Msg) (err error)

func (*App) Remove

func (x *App) Remove(key string)

func (*App) RemoveSubscribe

func (x *App) RemoveSubscribe(key string) (err error)

func (*App) Run

func (x *App) Run() (err error)

func (*App) Set

func (x *App) Set(key string, v *nats.Subscription)

func (*App) SetSubscribe

func (x *App) SetSubscribe(key string, option *client.StreamOption) (err error)

func (*App) Transform

func (x *App) Transform(data M, rules M) (err error)

type M

type M = map[string]interface{}

type Payload

type Payload struct {
	Timestamp time.Time              `msgpack:"timestamp"`
	Data      map[string]interface{} `msgpack:"data"`
	XData     map[string]interface{} `msgpack:"xdata"`
}