applier

Documentation

Index

• Variables
• func NewUDSGRPCBasedUDF() (*udsGRPCBasedUDF, error)
• type Applier
• type ApplyFunc
  • func (a ApplyFunc) Apply(ctx context.Context, message *isb.ReadMessage) ([]*isb.Message, error)
• type ApplyUDFErr
  • func (e ApplyUDFErr) Error() string
  • func (e ApplyUDFErr) IsInternalErr() bool
  • func (e ApplyUDFErr) IsUserUDFErr() bool
• type InternalErr

Variables

var (
	// Terminal Applier do not make any change to the message
	Terminal = ApplyFunc(func(ctx context.Context, msg *isb.ReadMessage) ([]*isb.Message, error) {
		return []*isb.Message{&msg.Message}, nil
	})
)

Functions

func NewUDSGRPCBasedUDF

func NewUDSGRPCBasedUDF() (*udsGRPCBasedUDF, error)

NewUDSGRPCBasedUDF returns a new udsGRPCBasedUDF object.

Types

type Applier

type Applier interface {
	Apply(ctx context.Context, message *isb.ReadMessage) ([]*isb.Message, error)
}

Applier applies the HTTPBasedUDF on the read message and gives back a new message. Any UserError will be retried here, while InternalErr can be returned and could be retried by the callee.

type ApplyFunc

type ApplyFunc func(context.Context, *isb.ReadMessage) ([]*isb.Message, error)

ApplyFunc untility function used to create a Applier implementation

func (ApplyFunc) Apply

func (a ApplyFunc) Apply(ctx context.Context, message *isb.ReadMessage) ([]*isb.Message, error)

type ApplyUDFErr

type ApplyUDFErr struct {
	UserUDFErr bool
	Message    string
	InternalErr
}

ApplyUDFErr represents any UDF related error

func (ApplyUDFErr) Error

func (e ApplyUDFErr) Error() string

func (ApplyUDFErr) IsInternalErr

func (e ApplyUDFErr) IsInternalErr() bool

IsInternalErr is true if this is a platform issue. This is a blocking error.

func (ApplyUDFErr) IsUserUDFErr

func (e ApplyUDFErr) IsUserUDFErr() bool

IsUserUDFErr is true if the problem is due to the user code in the UDF.

type InternalErr

type InternalErr struct {
	Flag        bool
	MainCarDown bool
}

InternalErr represents errors internal to the platform