sink

Documentation

Index

• Constants
• func NewAction(entityType, entityID string) types.Action
• func NewContext(ctx context.Context) types.ActionContent
• func Registered(name string, ac types.ActionBuilder)
• func SinkNames() []string
• type ActionBehavior
  • func UnmarshalBehavior(typ string) ActionBehavior
• type ActionManager
• type CheckpointedFunction
• type DBImpl
• type EntityInfo
• type EntityMeta

Constants

const (
	ActionModePanic = iota
	ActionModeRedeliver
	ActionModeContinue
)

const DefaultActionEntityID = "default"

Functions

func NewAction

func NewAction(entityType, entityID string) types.Action

func NewContext

func NewContext(ctx context.Context) types.ActionContent

func Registered

func Registered(name string, ac types.ActionBuilder)

func SinkNames

func SinkNames() []string

Types

type ActionBehavior

type ActionBehavior int32

func UnmarshalBehavior

func UnmarshalBehavior(typ string) ActionBehavior

type ActionManager

type ActionManager interface {
	Invoke(ctx context.Context, entityID string, messages stream.Message) error
}

type CheckpointedFunction

type CheckpointedFunction = stypes.CheckpointedFunction

type DBImpl

type DBImpl interface {
	BatchCreate(ctx context.Context, sqlCreate string, values interface{}) error
	Close() error
}

type EntityInfo

type EntityInfo struct {
	Id       string
	Metadata map[string]string
}

type EntityMeta

type EntityMeta struct {
	LastTime time.Time
	Type     string
	Metadata map[string]string
}