transform

Documentation

Index

• Constants
• Variables
• func NewTransformIntegrationCreator(deps domain.IntegrationDeps) domain.IntegrationCreator
• type Access
• type FieldAccess
  • func (f FieldAccess) Apply(data any) (any, error)
• type FieldPathParser
  • func NewFieldPathParser() *FieldPathParser
  • func (p *FieldPathParser) DeleteValue(data any, fieldPath string) error
  • func (p *FieldPathParser) GetValue(data any, fieldPath string) (any, error)
  • func (p *FieldPathParser) SetValue(data any, fieldPath string, value any) error
• type IndexAccess
  • func (i IndexAccess) Apply(data any) (any, error)
• type JoinCriteria
• type JoinParams
• type Segment
  • func (s Segment) Apply(data any) (any, error)
• type TransformIntegration
  • func NewTransformIntegration(deps TransformIntegrationDependencies) (*TransformIntegration, error)
  • func (i *TransformIntegration) AppendStreams(ctx context.Context, params domain.IntegrationInput, ...) ([]domain.Item, error)
  • func (i *TransformIntegration) Execute(ctx context.Context, params domain.IntegrationInput) (domain.IntegrationOutput, error)
  • func (i *TransformIntegration) InnerJoin(ctx context.Context, params domain.IntegrationInput, ...) ([]domain.Item, error)
  • func (i *TransformIntegration) LeftJoin(ctx context.Context, params domain.IntegrationInput, ...) ([]domain.Item, error)
  • func (i *TransformIntegration) OuterJoin(ctx context.Context, params domain.IntegrationInput, ...) ([]domain.Item, error)
  • func (i *TransformIntegration) ReverseInnerJoin(ctx context.Context, params domain.IntegrationInput, ...) ([]domain.Item, error)
  • func (i *TransformIntegration) RightJoin(ctx context.Context, params domain.IntegrationInput, ...) ([]domain.Item, error)
• type TransformIntegrationCreator
  • func (c *TransformIntegrationCreator) CreateIntegration(ctx context.Context, p domain.CreateIntegrationParams) (domain.IntegrationExecutor, error)
• type TransformIntegrationDependencies

Constants

const (
	IntegrationActionType_Append          domain.IntegrationActionType = "append"
	IntegrationActionType_InnerJoin       domain.IntegrationActionType = "inner_join"
	IntegrationActionType_OuterJoin       domain.IntegrationActionType = "outer_join"
	IntegrationActionType_LeftJoin        domain.IntegrationActionType = "left_join"
	IntegrationActionType_RightJoin       domain.IntegrationActionType = "right_join"
	IntegrationActionType_ExcludeMatching domain.IntegrationActionType = "exclude_matching"
)

Variables

var (
	Schema = schema
)

Functions

func NewTransformIntegrationCreator

func NewTransformIntegrationCreator(deps domain.IntegrationDeps) domain.IntegrationCreator

Types

type Access

type Access interface {
	Apply(data any) (any, error)
}

type FieldAccess

type FieldAccess struct {
	Name string
}

func (FieldAccess) Apply

func (f FieldAccess) Apply(data any) (any, error)

type FieldPathParser

type FieldPathParser struct{}

func NewFieldPathParser

func NewFieldPathParser() *FieldPathParser

func (*FieldPathParser) DeleteValue

func (p *FieldPathParser) DeleteValue(data any, fieldPath string) error

func (*FieldPathParser) GetValue

func (p *FieldPathParser) GetValue(data any, fieldPath string) (any, error)

func (*FieldPathParser) SetValue

func (p *FieldPathParser) SetValue(data any, fieldPath string, value any) error

type IndexAccess

type IndexAccess struct {
	Index int
}

func (IndexAccess) Apply

func (i IndexAccess) Apply(data any) (any, error)

type JoinCriteria

type JoinCriteria struct {
	LeftFieldKey  string `json:"left_field_key"`
	RightFieldKey string `json:"right_field_key"`
}

type JoinParams

type JoinParams struct {
	Criteria         []JoinCriteria `json:"criteria"`
	HandleCollisions bool           `json:"handle_collisions"`
}

type Segment

type Segment struct {
	Accesses []Access
}

func (Segment) Apply

func (s Segment) Apply(data any) (any, error)

type TransformIntegration

type TransformIntegration struct {
	// contains filtered or unexported fields
}

func NewTransformIntegration

func NewTransformIntegration(deps TransformIntegrationDependencies) (*TransformIntegration, error)

func (*TransformIntegration) AppendStreams

func (i *TransformIntegration) AppendStreams(ctx context.Context, params domain.IntegrationInput, itemsByInput [][]domain.Item) ([]domain.Item, error)

func (*TransformIntegration) Execute

func (i *TransformIntegration) Execute(ctx context.Context, params domain.IntegrationInput) (domain.IntegrationOutput, error)

func (*TransformIntegration) InnerJoin

func (i *TransformIntegration) InnerJoin(ctx context.Context, params domain.IntegrationInput, itemsByInput [][]domain.Item) ([]domain.Item, error)

func (*TransformIntegration) LeftJoin

func (i *TransformIntegration) LeftJoin(ctx context.Context, params domain.IntegrationInput, itemsByInput [][]domain.Item) ([]domain.Item, error)

func (*TransformIntegration) OuterJoin

func (i *TransformIntegration) OuterJoin(ctx context.Context, params domain.IntegrationInput, itemsByInput [][]domain.Item) ([]domain.Item, error)

func (*TransformIntegration) ReverseInnerJoin

func (i *TransformIntegration) ReverseInnerJoin(ctx context.Context, params domain.IntegrationInput, itemsByInput [][]domain.Item) ([]domain.Item, error)

func (*TransformIntegration) RightJoin

func (i *TransformIntegration) RightJoin(ctx context.Context, params domain.IntegrationInput, itemsByInput [][]domain.Item) ([]domain.Item, error)

type TransformIntegrationCreator

type TransformIntegrationCreator struct {
	// contains filtered or unexported fields
}

func (*TransformIntegrationCreator) CreateIntegration

func (c *TransformIntegrationCreator) CreateIntegration(ctx context.Context, p domain.CreateIntegrationParams) (domain.IntegrationExecutor, error)

type TransformIntegrationDependencies

type TransformIntegrationDependencies struct {
	ParameterBinder domain.IntegrationParameterBinder
}