udsink

Documentation

Index

• func NewUDSGRPCBasedUDSink() (*udsGRPCBasedUDSink, 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
• type UserDefinedSink
  • func NewUserDefinedSink(vertex *dfv1.Vertex, fromBuffer isb.BufferReader, fetchWatermark fetch.Fetcher, ...) (*UserDefinedSink, error)
  • func (br *UserDefinedSink) Close() error
  • func (s *UserDefinedSink) ForceStop()
  • func (s *UserDefinedSink) GetName() string
  • func (s *UserDefinedSink) IsFull() bool
  • func (s *UserDefinedSink) IsHealthy() error
  • func (s *UserDefinedSink) Start() <-chan struct{}
  • func (s *UserDefinedSink) Stop()
  • func (s *UserDefinedSink) Write(ctx context.Context, messages []isb.Message) ([]isb.Offset, []error)

Functions

func NewUDSGRPCBasedUDSink

func NewUDSGRPCBasedUDSink() (*udsGRPCBasedUDSink, error)

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

type UserDefinedSink

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

func NewUserDefinedSink

func NewUserDefinedSink(vertex *dfv1.Vertex, fromBuffer isb.BufferReader, fetchWatermark fetch.Fetcher, publishWatermark map[string]publish.Publisher, opts ...Option) (*UserDefinedSink, error)

NewUserDefinedSink returns genericSink type.

func (*UserDefinedSink) Close

func (br *UserDefinedSink) Close() error

func (*UserDefinedSink) ForceStop

func (s *UserDefinedSink) ForceStop()

func (*UserDefinedSink) GetName

func (s *UserDefinedSink) GetName() string

func (*UserDefinedSink) IsFull

func (s *UserDefinedSink) IsFull() bool

func (*UserDefinedSink) IsHealthy

func (s *UserDefinedSink) IsHealthy() error

IsHealthy checks if the udsink sidecar is healthy.

func (*UserDefinedSink) Start

func (s *UserDefinedSink) Start() <-chan struct{}

func (*UserDefinedSink) Stop

func (s *UserDefinedSink) Stop()

func (*UserDefinedSink) Write

func (s *UserDefinedSink) Write(ctx context.Context, messages []isb.Message) ([]isb.Offset, []error)

Write writes to the UDSink container.