function

Documentation

Index

• type ApplyUDFErr
  • func (e ApplyUDFErr) Error() string
  • func (e ApplyUDFErr) IsInternalErr() bool
  • func (e ApplyUDFErr) IsUserUDFErr() bool
• type InternalErr
• type UDSgRPCBasedUDF
  • func NewUDSgRPCBasedUDF(c clientsdk.Client) (*UDSgRPCBasedUDF, error)
  • func NewUDSgRPCBasedUDFWithClient(client clientsdk.Client) *UDSgRPCBasedUDF
  • func (u *UDSgRPCBasedUDF) ApplyMap(ctx context.Context, readMessage *isb.ReadMessage) ([]*isb.WriteMessage, error)
  • func (u *UDSgRPCBasedUDF) ApplyMapStream(ctx context.Context, message *isb.ReadMessage, ...) error
  • func (u *UDSgRPCBasedUDF) ApplyReduce(ctx context.Context, partitionID *partition.ID, ...) ([]*isb.WriteMessage, error)
  • func (u *UDSgRPCBasedUDF) CloseConn(ctx context.Context) error
  • func (u *UDSgRPCBasedUDF) IsHealthy(ctx context.Context) error
  • func (u *UDSgRPCBasedUDF) WaitUntilReady(ctx context.Context) error

Types

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

type UDSgRPCBasedUDF

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

UDSgRPCBasedUDF applies user defined function over gRPC (over Unix Domain Socket) client/server where server is the UDF.

func NewUDSgRPCBasedUDF

func NewUDSgRPCBasedUDF(c clientsdk.Client) (*UDSgRPCBasedUDF, error)

NewUDSgRPCBasedUDF returns a new UDSgRPCBasedUDF object.

func NewUDSgRPCBasedUDFWithClient

func NewUDSgRPCBasedUDFWithClient(client clientsdk.Client) *UDSgRPCBasedUDF

NewUDSgRPCBasedUDFWithClient need this for testing

func (*UDSgRPCBasedUDF) ApplyMap

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

func (*UDSgRPCBasedUDF) ApplyMapStream

func (u *UDSgRPCBasedUDF) ApplyMapStream(ctx context.Context, message *isb.ReadMessage, writeMessageCh chan<- isb.WriteMessage) error

func (*UDSgRPCBasedUDF) ApplyReduce

func (u *UDSgRPCBasedUDF) ApplyReduce(ctx context.Context, partitionID *partition.ID, messageStream <-chan *isb.ReadMessage) ([]*isb.WriteMessage, error)

ApplyReduce accepts a channel of isbMessages and returns the aggregated result

func (*UDSgRPCBasedUDF) CloseConn

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

CloseConn closes the gRPC client connection.

func (*UDSgRPCBasedUDF) IsHealthy

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

IsHealthy checks if the udf is healthy.

func (*UDSgRPCBasedUDF) WaitUntilReady

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

WaitUntilReady waits until the udf is connected.