domain

Documentation

Index

• Variables
• func UseDatastoreGet(app *events.App) pipeline.Pipeline
• func UseDatastorePut(app *events.App) pipeline.Pipeline
• func UseDatastoreScan(app *events.App) pipeline.Pipeline
• func UseEventConstruction(app *events.App) pipeline.Pipeline
• func UseGet(app *events.App) pipeline.Pipe
• func UseMsgBusPub(app *events.App) pipeline.Pipeline
• func UsePub(app *events.App) pipeline.Pipe
• func UseScan(app *events.App) pipeline.Pipe
• func UseSub(app *events.App, server protos.Events_SubServer) pipeline.Pipe
• func UseSubForward(server protos.Events_SubServer) pipeline.Pipeline
• type Domain
  • func New(app *events.App) *Domain
• type GetReq
  • func (req *GetReq) From(r *protos.GetReq)
• type GetRes
  • func (res *GetRes) To() *protos.Event
• type PubReq
  • func (req *PubReq) From(r *protos.PubReq)
• type PubRes
  • func (res *PubRes) To() *protos.PubRes
• type ScanReq
  • func (req *ScanReq) From(r *protos.ScanReq)
• type ScanRes
  • func (res *ScanRes) To() *protos.ScanRes
• type SubReq
• type SubRes
  • func (res *SubRes) To() *protos.Event

Variables

var (
	METRIC_EVENT_GET         = "get"
	METRIC_EVENT_SCAN        = "scan"
	METRIC_EVENT_PUB         = "pub"
	METRIC_EVENT_SUB         = "sub"
	METRIC_EVENT_SUB_FORWARD = "sub_forward"
)

Functions

func UseDatastoreGet

func UseDatastoreGet(app *events.App) pipeline.Pipeline

func UseDatastorePut

func UseDatastorePut(app *events.App) pipeline.Pipeline

func UseDatastoreScan

func UseDatastoreScan(app *events.App) pipeline.Pipeline

func UseEventConstruction

func UseEventConstruction(app *events.App) pipeline.Pipeline

func UseGet

func UseGet(app *events.App) pipeline.Pipe

func UseMsgBusPub

func UseMsgBusPub(app *events.App) pipeline.Pipeline

func UsePub

func UsePub(app *events.App) pipeline.Pipe

func UseScan

func UseScan(app *events.App) pipeline.Pipe

func UseSub

func UseSub(app *events.App, server protos.Events_SubServer) pipeline.Pipe

func UseSubForward

func UseSubForward(server protos.Events_SubServer) pipeline.Pipeline

Types

type Domain

type Domain struct {
	Get  pipeline.Pipe
	Pub  pipeline.Pipe
	Scan pipeline.Pipe
}

func New

func New(app *events.App) *Domain

type GetReq

type GetReq struct {
	Event *entities.Event
}

func (*GetReq) From

func (req *GetReq) From(r *protos.GetReq)

type GetRes

type GetRes struct {
	Event *entities.Event
}

func (*GetRes) To

func (res *GetRes) To() *protos.Event

type PubReq

type PubReq struct {
	Event *entities.Event
}

func (*PubReq) From

func (req *PubReq) From(r *protos.PubReq)

type PubRes

type PubRes struct {
	Event  *entities.Event
	PubKey string
}

func (*PubRes) To

func (res *PubRes) To() *protos.PubRes

type ScanReq

type ScanReq struct {
	Event  *entities.Event
	Cursor string
	Filter string
}

func (*ScanReq) From

func (req *ScanReq) From(r *protos.ScanReq)

type ScanRes

type ScanRes struct {
	Result *datastore.ScanResult
}

func (*ScanRes) To

func (res *ScanRes) To() *protos.ScanRes

type SubReq

type SubReq struct {
	Event *entities.Event
}

type SubRes

type SubRes struct {
	Event *entities.Event
}

func (*SubRes) To

func (res *SubRes) To() *protos.Event