plugin

package

v0.0.0-...-0f63273 Latest Latest Go to latest Published: Jul 3, 2024 License: MIT Imports: 15 Imported by: 4

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/cludden/benthos-plugin-temporal

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewVerifyHmacSha256ProcessorConfig[Field interface{ ... }, ConfigSpec interface{ ... }, ...](conf ConfigSpec, fields FieldProvider) ConfigSpec
func NewWorkflowOutputConfig[Field interface{ ... }, ConfigSpec interface{ ... }, ...](conf ConfigSpec, fields FieldProvider) ConfigSpec
type BloblangFunction
type BloblangMapping
type VerifyHmacSha256Processor
- func NewVerifyHmacSha256Processor[InterpolatedString interface{ ... }, Mapping BloblangMapping, ...](conf ParsedConfig, mgr Resources, toBatch func([]Message) MessageBatch) (...)
- func (p *VerifyHmacSha256Processor[InterpolatedString, Mapping, Message, MessageBatch]) Close(ctx context.Context) error
- func (p *VerifyHmacSha256Processor[InterpolatedString, Mapping, Message, MessageBatch]) Process(ctx context.Context, msg Message) (result MessageBatch, err error)
type WorkflowOutput
- func NewWorkflowOutput[InterpolatedString interface{ ... }, Mapping BloblangMapping, ...](conf ParsedConfig, mgr Resources, ...) (o *WorkflowOutput[InterpolatedString, Mapping, Message], maxInFlight int, ...)
type WorkflowOutputOptions

Constants ¶

View Source

const (
	VerifyHmacSha256ProcessorType = "verify_hmac_sha256"
)

View Source

const (
	WorkflowOutputType = "temporal_workflow"
)

Variables ¶

This section is empty.

Functions ¶

func NewVerifyHmacSha256ProcessorConfig ¶

func NewVerifyHmacSha256ProcessorConfig[
	Field interface {
		Default(any) Field
		Description(string) Field
		Optional() Field
	},
	ConfigSpec interface {
		Summary(string) ConfigSpec
		Fields(...Field) ConfigSpec
	},
	FieldProvider interface {
		NewBoolField(string) Field
		NewBloblangField(string) Field
		NewIntField(string) Field
		NewStringField(string) Field
		NewInterpolatedStringEnumField(string, ...string) Field
		NewInterpolatedStringField(string) Field
		NewObjectField(string, ...Field) Field
	},
](conf ConfigSpec, fields FieldProvider) ConfigSpec

func NewWorkflowOutputConfig ¶

func NewWorkflowOutputConfig[
	Field interface {
		Default(any) Field
		Description(string) Field
		Optional() Field
	},
	ConfigSpec interface {
		Summary(string) ConfigSpec
		Fields(...Field) ConfigSpec
	},
	FieldProvider interface {
		NewBoolField(string) Field
		NewBloblangField(string) Field
		NewIntField(string) Field
		NewStringField(string) Field
		NewInterpolatedStringEnumField(string, ...string) Field
		NewInterpolatedStringField(string) Field
		NewObjectField(string, ...Field) Field
	},
](conf ConfigSpec, fields FieldProvider) ConfigSpec

Types ¶

type BloblangFunction ¶

type BloblangFunction func() (any, error)

type BloblangMapping ¶

type BloblangMapping interface {
	Query(any) (any, error)
}

type VerifyHmacSha256Processor ¶

type VerifyHmacSha256Processor[
	InterpolatedString interface {
		TryString(Message) (string, error)
	},
	Mapping BloblangMapping,
	Message interface {
		AsBytes() ([]byte, error)
		AsStructured() (any, error)
		BloblangQuery(Mapping) (Message, error)
	},
	MessageBatch any,
] struct {
	// contains filtered or unexported fields
}

func NewVerifyHmacSha256Processor ¶

func NewVerifyHmacSha256Processor[
	InterpolatedString interface {
		TryString(Message) (string, error)
	},
	Mapping BloblangMapping,
	Message interface {
		AsBytes() ([]byte, error)
		AsStructured() (any, error)
		BloblangQuery(Mapping) (Message, error)
	},
	MessageBatch any,
	ParsedConfig interface {
		Contains(...string) bool
		FieldBloblang(...string) (Mapping, error)
		FieldBool(...string) (bool, error)
		FieldInt(...string) (int, error)
		FieldInterpolatedString(...string) (InterpolatedString, error)
		FieldString(...string) (string, error)
	},
	Resources any,
](conf ParsedConfig, mgr Resources, toBatch func([]Message) MessageBatch) (o *VerifyHmacSha256Processor[InterpolatedString, Mapping, Message, MessageBatch], err error)

func (*VerifyHmacSha256Processor[InterpolatedString, Mapping, Message, MessageBatch]) Close ¶

func (p *VerifyHmacSha256Processor[InterpolatedString, Mapping, Message, MessageBatch]) Close(ctx context.Context) error

func (*VerifyHmacSha256Processor[InterpolatedString, Mapping, Message, MessageBatch]) Process ¶

func (p *VerifyHmacSha256Processor[InterpolatedString, Mapping, Message, MessageBatch]) Process(ctx context.Context, msg Message) (result MessageBatch, err error)

type WorkflowOutput ¶

type WorkflowOutput[
	InterpolatedString interface {
		TryString(Message) (string, error)
	},
	Mapping BloblangMapping,
	Message interface {
		AsBytes() ([]byte, error)
		AsStructured() (any, error)
		BloblangQuery(Mapping) (Message, error)
	},
] struct {
	// contains filtered or unexported fields
}

func NewWorkflowOutput ¶

func NewWorkflowOutput[
	InterpolatedString interface {
		TryString(Message) (string, error)
	},
	Mapping BloblangMapping,
	Message interface {
		AsBytes() ([]byte, error)
		AsStructured() (any, error)
		BloblangQuery(Mapping) (Message, error)
	},
	ParsedConfig interface {
		Contains(...string) bool
		FieldBloblang(...string) (Mapping, error)
		FieldBool(...string) (bool, error)
		FieldInt(...string) (int, error)
		FieldInterpolatedString(...string) (InterpolatedString, error)
		FieldString(...string) (string, error)
	},
	Resources any,
](conf ParsedConfig, mgr Resources, opts ...WorkflowOutputOptions[InterpolatedString, Mapping, Message]) (o *WorkflowOutput[InterpolatedString, Mapping, Message], maxInFlight int, err error)

func (*WorkflowOutput[InterpolatedString, Mapping, Message]) Close ¶

func (o *WorkflowOutput[InterpolatedString, Mapping, Message]) Close(ctx context.Context) error

func (*WorkflowOutput[InterpolatedString, Mapping, Message]) Connect ¶

func (o *WorkflowOutput[InterpolatedString, Mapping, Message]) Connect(ctx context.Context) (err error)

func (*WorkflowOutput[InterpolatedString, Mapping, Message]) Write ¶

func (o *WorkflowOutput[InterpolatedString, Mapping, Message]) Write(ctx context.Context, msg Message) (err error)

type WorkflowOutputOptions ¶

type WorkflowOutputOptions[
	InterpolatedString interface {
		TryString(Message) (string, error)
	},
	Mapping BloblangMapping,
	Message interface {
		AsBytes() ([]byte, error)
		AsStructured() (any, error)
		BloblangQuery(Mapping) (Message, error)
	},
] func(*WorkflowOutput[InterpolatedString, Mapping, Message]) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL