helpers

Documentation

Index

• func CallFunctionFromJson(f Callable, jsonArgs interface{}) ([]reflect.Value, error)
• func FillStructFromKV(kv map[string]string, v interface{}) error
• func GetFunctionParametersJsonSchema(reflector *jsonschema.Reflector, f Callable) (*jsonschema.Schema, error)
• func MergeChannels[A any](channels ...<-chan A) <-chan A
• func ParseKV(s string) map[string]string
• type Callable
• type Nothing
• type Result
  • func NewErrorResult[T any](err error) Result[T]
  • func NewResult[T any](value T, err error) Result[T]
  • func NewValueResult[T any](value T) Result[T]
  • func (r Result[T]) Error() error
  • func (r Result[T]) Ok() bool
  • func (r Result[T]) Unwrap() T
  • func (r Result[T]) Value() (T, error)
  • func (r Result[T]) ValueOr(v T) T
• type SubscriptionManager
  • func NewSubscriptionManager() *SubscriptionManager
  • func (s *SubscriptionManager) AddPublishedTopic(topic string, sub message.Publisher)
  • func (s *SubscriptionManager) Publish(payload interface{}) error
  • func (s *SubscriptionManager) PublishBlind(payload interface{})

Functions

func CallFunctionFromJson

func CallFunctionFromJson(f Callable, jsonArgs interface{}) ([]reflect.Value, error)

CallFunctionFromJson calls a function with arguments provided as JSON TODO(manuel, 2024-01-12) make this take a ctx

func FillStructFromKV

func FillStructFromKV(kv map[string]string, v interface{}) error

func GetFunctionParametersJsonSchema

func GetFunctionParametersJsonSchema(reflector *jsonschema.Reflector, f Callable) (*jsonschema.Schema, error)

GetFunctionParametersJsonSchema generates a JSON Schema for the arguments of the given function

func MergeChannels

func MergeChannels[A any](channels ...<-chan A) <-chan A

func ParseKV

func ParseKV(s string) map[string]string

ParseKV transforms a simple format. Each line has a key value pair separated by :. Empty lines are ignored

Types

type Callable

type Callable interface{}

Callable is a type representing any callable function

type Nothing

type Nothing struct{}

type Result

type Result[T any] struct {
	// contains filtered or unexported fields
}

func NewErrorResult

func NewErrorResult[T any](err error) Result[T]

func NewResult

func NewResult[T any](value T, err error) Result[T]

func NewValueResult

func NewValueResult[T any](value T) Result[T]

func (Result[T]) Error

func (r Result[T]) Error() error

func (Result[T]) Ok

func (r Result[T]) Ok() bool

func (Result[T]) Unwrap

func (r Result[T]) Unwrap() T

func (Result[T]) Value

func (r Result[T]) Value() (T, error)

func (Result[T]) ValueOr

func (r Result[T]) ValueOr(v T) T

type SubscriptionManager

type SubscriptionManager struct {
	Subscriptions map[string][]message.Publisher
}

func NewSubscriptionManager

func NewSubscriptionManager() *SubscriptionManager

func (*SubscriptionManager) AddPublishedTopic

func (s *SubscriptionManager) AddPublishedTopic(topic string, sub message.Publisher)

func (*SubscriptionManager) Publish

func (s *SubscriptionManager) Publish(payload interface{}) error

func (*SubscriptionManager) PublishBlind

func (s *SubscriptionManager) PublishBlind(payload interface{})