firemesh

Documentation

Overview

Package FIREMESH implements a CloudEvents adapter that allows Triggermesh Sources to integrate with a Firefly Node.

Index

• func EnvAccessorCtor() pkgadapter.EnvConfigAccessor
• func NewAdapter(ctx context.Context, envAcc pkgadapter.EnvConfigAccessor, ...) pkgadapter.Adapter
• type Blob
• type BlobDataUploadResponse
• type BroadcastBlobData
• type BroadcastMessage
• type BroadcastMessageData
• type BroadcastMessageHeader
• type Data

Functions

func EnvAccessorCtor

func EnvAccessorCtor() pkgadapter.EnvConfigAccessor

EnvAccessorCtor for configuration parameters

func NewAdapter

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

NewAdapter adapter implementation

Types

type Blob

type Blob struct {
	Hash string `json:"hash"`
	Size int    `json:"size"`
	Name string `json:"name"`
}

type BlobDataUploadResponse

type BlobDataUploadResponse struct {
	ID        string      `json:"id"`
	Validator string      `json:"validator"`
	Namespace string      `json:"namespace"`
	Hash      string      `json:"hash"`
	Created   time.Time   `json:"created"`
	Value     interface{} `json:"value"`
	Blob      Blob        `json:"blob"`
}

type BroadcastBlobData

type BroadcastBlobData struct {
	Data   []Data                 `json:"data"`
	Header BroadcastMessageHeader `json:"header"`
}

type BroadcastMessage

type BroadcastMessage struct {
	Header BroadcastMessageHeader `json:"header"`
	Data   []BroadcastMessageData `json:"data"`
}

type BroadcastMessageData

type BroadcastMessageData struct {
	Value interface{} `json:"value"`
}

type BroadcastMessageHeader

type BroadcastMessageHeader struct {
	Tag    string   `json:"tag"`
	Topics []string `json:"topics"`
}

type Data

type Data struct {
	ID string `json:"id"`
}