transformer

package
v1.0.0-rc4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 3, 2023 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type GRPCBasedTransformer added in v0.10.0

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

GRPCBasedTransformer applies user defined transformer over gRPC (over Unix Domain Socket) client/server where server is the transformer.

func NewGRPCBasedTransformer

func NewGRPCBasedTransformer(client sourcetransformer.Client) *GRPCBasedTransformer

NewGRPCBasedTransformer returns a new gRPCBasedTransformer object.

func (*GRPCBasedTransformer) ApplyTransform added in v0.10.0

func (u *GRPCBasedTransformer) ApplyTransform(ctx context.Context, readMessage *isb.ReadMessage) ([]*isb.WriteMessage, error)

func (*GRPCBasedTransformer) CloseConn added in v0.10.0

func (u *GRPCBasedTransformer) CloseConn(ctx context.Context) error

CloseConn closes the gRPC client connection.

func (*GRPCBasedTransformer) IsHealthy added in v0.10.0

func (u *GRPCBasedTransformer) IsHealthy(ctx context.Context) error

IsHealthy checks if the transformer container is healthy.

func (*GRPCBasedTransformer) WaitUntilReady added in v0.10.0

func (u *GRPCBasedTransformer) WaitUntilReady(ctx context.Context) error

WaitUntilReady waits until the client is connected.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL