mongodbtarget

Documentation

Overview

Package mongodbtarget implements an adapter that connects to a MongoDB database and allows a user to insert, query, and update documents via cloudevents.

Index

• func EnvAccessorCtor() pkgadapter.EnvConfigAccessor
• func NewTarget(ctx context.Context, envAcc pkgadapter.EnvConfigAccessor, ...) pkgadapter.Adapter
• type InsertPayload
• type QueryPayload
• type QueryResponse
• type UpdatePayload

Functions

func EnvAccessorCtor

func EnvAccessorCtor() pkgadapter.EnvConfigAccessor

EnvAccessorCtor for configuration parameters

func NewTarget

func NewTarget(ctx context.Context, envAcc pkgadapter.EnvConfigAccessor, ceClient cloudevents.Client) pkgadapter.Adapter

NewTarget returns the adapter implementation.

Types

type InsertPayload

type InsertPayload struct {
	Database   string          `json:"database"`
	Collection string          `json:"collection"`
	Key        string          `json:"key"`
	Document   json.RawMessage `json:"document"`
}

InsertPayload defines the expected data structure found at the "io.triggermesh.mongodb.insert" payload.

type QueryPayload

type QueryPayload struct {
	Database   string `json:"database"`
	Collection string `json:"collection"`
	Key        string `json:"key"`
	Value      string `json:"value"`
}

QueryPayload defines the expected data found at the "io.triggermesh.mongodb.query" payload.

type QueryResponse

type QueryResponse struct {
	Collection map[string]string `json:"collection"`
}

QueryResponse defines the expected data structure received from a query to MongoDB.

type UpdatePayload

type UpdatePayload struct {
	Database    string `json:"database"`
	Collection  string `json:"collection"`
	SearchKey   string `json:"searchKey"`
	SearchValue string `json:"searchValue"`
	UpdateKey   string `json:"updateKey"`
	UpdateValue string `json:"updateValue"`
}

UpdatePayload defines the expected data found at the "io.triggermesh.mongodb.update" payload.