transformation

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

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

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

	BufferSize int
	// contains filtered or unexported fields
}

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