transformer

Documentation

Index

• type GRPCBasedTransformer
  • func NewGRPCBasedTransformer(client sourcetransformer.Client) *GRPCBasedTransformer
  • func (u *GRPCBasedTransformer) ApplyTransform(ctx context.Context, readMessage *isb.ReadMessage) ([]*isb.WriteMessage, error)
  • func (u *GRPCBasedTransformer) CloseConn(ctx context.Context) error
  • func (u *GRPCBasedTransformer) IsHealthy(ctx context.Context) error
  • func (u *GRPCBasedTransformer) WaitUntilReady(ctx context.Context) error

Types

type GRPCBasedTransformer

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

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

func (*GRPCBasedTransformer) CloseConn

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

CloseConn closes the gRPC client connection.

func (*GRPCBasedTransformer) IsHealthy

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

IsHealthy checks if the transformer container is healthy.

func (*GRPCBasedTransformer) WaitUntilReady

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

WaitUntilReady waits until the client is connected.