udsink

Documentation

Index

• func NewUDSHTTPBasedUDSink(socketPath string, opts ...udsSinkOption) *udsHTTPBasedUDSink
• func NewUserDefinedSink(vertex *dfv1.Vertex, fromBuffer isb.BufferReader, opts ...Option) (*userDefinedSink, error)
• type ApplyUDSinkErr
  • func (e ApplyUDSinkErr) Error() string
  • func (e ApplyUDSinkErr) IsInternalErr() bool
  • func (e ApplyUDSinkErr) IsUserUDSinkErr() bool
• type InternalErr
• type Option
  • func WithLogger(log *zap.SugaredLogger) Option

Functions

func NewUDSHTTPBasedUDSink

func NewUDSHTTPBasedUDSink(socketPath string, opts ...udsSinkOption) *udsHTTPBasedUDSink

func NewUserDefinedSink

func NewUserDefinedSink(vertex *dfv1.Vertex, fromBuffer isb.BufferReader, opts ...Option) (*userDefinedSink, error)

NewUserDefinedSink returns genericSink type.

Types

type ApplyUDSinkErr

type ApplyUDSinkErr struct {
	UserUDSinkErr bool
	Message       string
	InternalErr
}

ApplyUDSinkErr represents any UDSink related error

func (ApplyUDSinkErr) Error

func (e ApplyUDSinkErr) Error() string

func (ApplyUDSinkErr) IsInternalErr

func (e ApplyUDSinkErr) IsInternalErr() bool

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

func (ApplyUDSinkErr) IsUserUDSinkErr

func (e ApplyUDSinkErr) IsUserUDSinkErr() bool

IsUserUDSinkErr is true if the problem is due to the user code in the UDSink.

type InternalErr

type InternalErr struct {
	Flag        bool
	MainCarDown bool
}

InternalErr represents errors internal to the platform

type Option

type Option func(*userDefinedSink) error

func WithLogger

func WithLogger(log *zap.SugaredLogger) Option