transformation

Documentation

Index

• Constants
• Variables
• type JmesTransformer
  • func (jt *JmesTransformer) Initialize() (err error)
  • func (jt *JmesTransformer) Transform(ctx context.Context, data *structpb.Struct) (*structpb.Struct, error)
• type JsonataTransformer
  • func (jt *JsonataTransformer) Initialize() (err error)
  • func (jt *JsonataTransformer) Transform(ctx context.Context, data *structpb.Struct) (*structpb.Struct, error)
• type Transformation
  • func New(id, kind string, bufferSize int, subscriptions []string, ...) (*Transformation, error)
  • func (t *Transformation) Init() (pubsub.Broker, error)
  • func (t *Transformation) Process(ctx context.Context) error
• type TransformerImpl
  • func HclImpl(kind string, body hcl.Body) (TransformerImpl, hcl.Diagnostics)

Constants

const (
	KindJmespath = "jmespath"
	KindJsonata  = "jsonata"
)

Variables

var (
	ErrNotAMap = errors.New("interface{} is not a struct")
)

var (
	ErrUnknownTransformer = errors.New("unkown transformer")
)

Types

type JmesTransformer

type JmesTransformer struct {
	Expression string `hcl:"expression"`
	// contains filtered or unexported fields
}

func (*JmesTransformer) Initialize

func (jt *JmesTransformer) Initialize() (err error)

func (*JmesTransformer) Transform

func (jt *JmesTransformer) Transform(ctx context.Context, data *structpb.Struct) (*structpb.Struct, error)

type JsonataTransformer

type JsonataTransformer struct {
	Expression string `hcl:"expression"`
	// contains filtered or unexported fields
}

func (*JsonataTransformer) Initialize

func (jt *JsonataTransformer) Initialize() (err error)

func (*JsonataTransformer) Transform

func (jt *JsonataTransformer) Transform(ctx context.Context, data *structpb.Struct) (*structpb.Struct, error)

type Transformation

type Transformation struct {
	ID            string
	Kind          string
	Subscriptions []string
	Broker        pubsub.Broker
	Subscriber    pubsub.Subscriber

	BufferSize int
	// contains filtered or unexported fields
}

func New

func New(id, kind string, bufferSize int, subscriptions []string, transformer TransformerImpl) (*Transformation, error)

func (*Transformation) Init

func (t *Transformation) Init() (pubsub.Broker, error)

func (*Transformation) Process

func (t *Transformation) Process(ctx context.Context) error

type TransformerImpl

type TransformerImpl interface {
	Transform(ctx context.Context, data *structpb.Struct) (*structpb.Struct, error)
	Initialize() error
}

func HclImpl

func HclImpl(kind string, body hcl.Body) (TransformerImpl, hcl.Diagnostics)