udf

Apr 8, 2024

Changes in this version

+ const ServiceID

+ func AsProtobufMessage(source interface{}, state data.Map, target proto.Message) (interface{}, error)

+ func DateOfBirth(source interface{}, state data.Map) (interface{}, error)

+ func FromProtobufMessage(source interface{}, state data.Map, sourceMessage proto.Message) (interface{}, error)

+ func GZipContentCorrupter(source interface{}, state data.Map) (interface{}, error)

+ func GZipper(source interface{}, state data.Map) (interface{}, error)

+ func Hostname(source interface{}, state data.Map) (interface{}, error)

+ func LoadData(source interface{}, state data.Map) (interface{}, error)

+ func New() endly.Service

+ func NewAvroReader(source interface{}, state data.Map) (interface{}, error)

+ func NewAvroWriter(args ...interface{}) (func(source interface{}, state data.Map) (interface{}, error), error)

+ func NewCsvReader(args ...interface{}) (func(source interface{}, state data.Map) (interface{}, error), error)

+ func NewProtoReader(args ...interface{}) (func(source interface{}, state data.Map) (interface{}, error), error)

+ func NewProtoWriter(args ...interface{}) (func(source interface{}, state data.Map) (interface{}, error), error)

+ func RegisterProviders(providers []*endly.UdfProvider) error

+ func TransformWithUDF(context *endly.Context, udfName, source string, payload interface{}) (interface{}, error)

+ func URLJoin(source interface{}, state data.Map) (interface{}, error)

+ func URLPath(source interface{}, state data.Map) (interface{}, error)

+ type ProtoCodec struct

+ func NewProtoCodec(schemaFile, importPath string, msgType string, lowercaseKey bool) (*ProtoCodec, error)

+ func (c *ProtoCodec) AsBinary(msgType string, msg interface{}) ([]byte, error)

+ func (c *ProtoCodec) AsMessage(msgType string, data []byte) (interface{}, error)

+ type RegisterRequest struct

+ UDFs []*endly.UdfProvider

+ func NewRegisterRequestFromURL(URL string) (*RegisterRequest, error)

+ type RegisterResponse struct