mongodbpool

Documentation

Index

• func NewActivity(metadata *activity.Metadata) activity.Activity
• type MongoDbActivity
  • func (a *MongoDbActivity) Eval(ctx activity.Context) (done bool, err error)
  • func (a *MongoDbActivity) Metadata() *activity.Metadata

Functions

func NewActivity

func NewActivity(metadata *activity.Metadata) activity.Activity

NewActivity creates a new AppActivity

Types

type MongoDbActivity

type MongoDbActivity struct {
	// contains filtered or unexported fields
}

Integration with MongoDb inputs: {uri, dbName, collection, method, [keyName, keyValue, value]} outputs: {output, count}

func (*MongoDbActivity) Eval

func (a *MongoDbActivity) Eval(ctx activity.Context) (done bool, err error)

Eval implements api.Activity.Eval - MongoDb integration

func (*MongoDbActivity) Metadata

func (a *MongoDbActivity) Metadata() *activity.Metadata

Metadata returns the activity's metadata