state

Documentation

Index

• Constants
• type Handler
  • func New(ctx context.Context, c dapr.Client) *Handler
  • func (h *Handler) List(ctx context.Context, in *common.InvocationEvent) (out *common.Content, err error)
  • func (h *Handler) Process(ctx context.Context, e *common.TopicEvent) (retry bool, err error)
  • func (h *Handler) Run(ctx context.Context, in *common.InvocationEvent) (out *common.Content, err error)
• type Run

Constants

const MONGO_URI = "MONGO_URI"

Types

type Handler

type Handler struct {
	Client dapr.Client
	DB     mongo.Collection
}

func New

func New(ctx context.Context, c dapr.Client) *Handler

func (*Handler) List

func (h *Handler) List(ctx context.Context, in *common.InvocationEvent) (out *common.Content, err error)

func (*Handler) Process

func (h *Handler) Process(ctx context.Context, e *common.TopicEvent) (retry bool, err error)

func (*Handler) Run

func (h *Handler) Run(ctx context.Context, in *common.InvocationEvent) (out *common.Content, err error)

type Run

type Run struct {
	ID          primitive.ObjectID  `bson:"_id,omitempty"`
	TimestampID string              `bson:"timestampid,omitempty"`
	RunID       string              `bson:"runid,omitempty"`
	Value       int                 `bson:"value,omitempty"`
	Stage       string              `bson:"stage,omitempty"`
	Timestamp   primitive.Timestamp `bson:"timestamp,omitempty"`
}