function

Apr 12, 2023

Changes in this version

type Message

+ func NewMessage(value []byte) Message

+ func (m Message) WithKeys(keys []string) Message

+ func (m Message) WithTags(tags []string) Message

type MessageT

+ func NewMessageT(eventTime time.Time, value []byte) MessageT

+ func (m MessageT) WithKeys(keys []string) MessageT

+ func (m MessageT) WithTags(tags []string) MessageT

Apr 10, 2023

Changes in this version

+ const TCP

+ const TCP_ADDR

+ const UDS

+ const UDS_ADDR

+ func IsMapMultiProcEnabled() bool

Apr 6, 2023

retracted

Changes in this version

type Datum

+ Metadata func() DatumMetadata

+ type DatumMetadata interface

+ ID func() string

+ NumDelivered func() uint64

Apr 5, 2023

Changes in this version

+ const Delimiter

type Message

+ func (m *Message) Keys() []string

type MessageT

+ func (m *MessageT) Keys() []string

Jan 20, 2023

Changes in this version

type Client

+ MapTFn func(ctx context.Context, datum *functionpb.Datum) ([]*functionpb.Datum, error)

+ type MapTFunc func(ctx context.Context, key string, datum Datum) MessageTs

+ func (mf MapTFunc) HandleDo(ctx context.Context, key string, datum Datum) MessageTs

+ type MapTHandler interface

+ HandleDo func(ctx context.Context, key string, datum Datum) MessageTs

+ type MessageT struct

+ EventTime time.Time

+ Key string

+ Value []byte

+ func MessageTTo(eventTime time.Time, to string, value []byte) MessageT

+ func MessageTToAll(eventTime time.Time, value []byte) MessageT

+ func MessageTToDrop() MessageT

+ type MessageTs []MessageT

+ func MessageTsBuilder() MessageTs

+ func (m MessageTs) Append(msg MessageT) MessageTs

+ func (m MessageTs) Items() []MessageT

type Service

+ MapperT MapTHandler

+ func (fs *Service) MapTFn(ctx context.Context, d *functionpb.Datum) (*functionpb.DatumList, error)

Nov 10, 2022

Changes in this version

+ const DefaultMaxMessageSize

+ const WinEndTime

+ const WinStartTime

type IntervalWindow

+ func NewIntervalWindow(startTime time.Time, endTime time.Time) IntervalWindow

type Metadata

+ func NewMetadata(window IntervalWindow) Metadata

Sep 1, 2022

Changes in this version

+ const Addr

+ const DatumKey

+ const Protocol

+ var ALL = fmt.Sprintf("%U__ALL__", '\\')

+ var DROP = fmt.Sprintf("%U__DROP__", '\\')

+ type Client interface

+ CloseConn func(ctx context.Context) error

+ IsReady func(ctx context.Context, in *emptypb.Empty) (bool, error)

+ MapFn func(ctx context.Context, datum *functionpb.Datum) ([]*functionpb.Datum, error)

+ ReduceFn func(ctx context.Context, datumStreamCh <-chan *functionpb.Datum) ([]*functionpb.Datum, error)

+ type Datum interface

+ EventTime func() time.Time

+ Value func() []byte

+ Watermark func() time.Time

+ type IntervalWindow interface

+ EndTime func() time.Time

+ StartTime func() time.Time

+ type MapFunc func(ctx context.Context, key string, datum Datum) Messages

+ func (mf MapFunc) HandleDo(ctx context.Context, key string, datum Datum) Messages

+ type MapHandler interface

+ HandleDo func(ctx context.Context, key string, datum Datum) Messages

+ type Message struct

+ Key string

+ Value []byte

+ func MessageTo(to string, value []byte) Message

+ func MessageToAll(value []byte) Message

+ func MessageToDrop() Message

+ type Messages []Message

+ func MessagesBuilder() Messages

+ func (m Messages) Append(msg Message) Messages

+ func (m Messages) Items() []Message

+ type Metadata interface

+ IntervalWindow func() IntervalWindow

+ type ReduceFunc func(ctx context.Context, key string, reduceCh <-chan Datum, md Metadata) Messages

+ func (rf ReduceFunc) HandleDo(ctx context.Context, key string, reduceCh <-chan Datum, md Metadata) Messages

+ type ReduceHandler interface

+ HandleDo func(ctx context.Context, key string, reduceCh <-chan Datum, md Metadata) Messages

+ type Service struct

+ Mapper MapHandler

+ Reducer ReduceHandler

+ func (fs *Service) IsReady(context.Context, *emptypb.Empty) (*functionpb.ReadyResponse, error)

+ func (fs *Service) MapFn(ctx context.Context, d *functionpb.Datum) (*functionpb.DatumList, error)

+ func (fs *Service) ReduceFn(stream functionpb.UserDefinedFunction_ReduceFnServer) error