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"`
	StrValue   string            `json:"strValue"`
	MapStrVal  map[string]string `json:"mapStrVal"`
}

InsertPayload defines the expected data structure found at the event 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"`
}

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"`
}