Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConveyorBelt ¶
type ConveyorBelt struct { DataDomain interface{} S *Streamline Ctx context.Context Logger log.Logger LogInfoGen func(*ConveyorBelt) string }
func NewConveyorBelt ¶
func NewConveyorBelt(s *Streamline, c context.Context, dataDomainRef interface{}, f func(*ConveyorBelt) string) *ConveyorBelt
func (*ConveyorBelt) Debugw ¶
func (c *ConveyorBelt) Debugw(args ...interface{})
func (*ConveyorBelt) Errorw ¶
func (c *ConveyorBelt) Errorw(args ...interface{})
func (*ConveyorBelt) Infow ¶
func (c *ConveyorBelt) Infow(args ...interface{})
func (*ConveyorBelt) Run ¶
func (c *ConveyorBelt) Run() (int, error)
func (*ConveyorBelt) Warnw ¶
func (c *ConveyorBelt) Warnw(args ...interface{})
type Factory ¶
type Factory struct {
// contains filtered or unexported fields
}
func (*Factory) Get ¶
func (f *Factory) Get(name string) *Streamline
func (*Factory) GetAllStreamlines ¶
func (f *Factory) GetAllStreamlines() map[string]*Streamline
func (*Factory) NewStreamline ¶
func (f *Factory) NewStreamline(name, action, resource string) *Streamline
type ProcFunc ¶
type ProcFunc func(*ConveyorBelt) int
type Streamline ¶
type Streamline struct { Name string Tags []string // These are for RBAC authentication // If any of them is nil, it means no authentication is enabled Action string Resource string // contains filtered or unexported fields }
func (*Streamline) Add ¶
func (s *Streamline) Add(procName string, f ProcFunc)
func (*Streamline) AddTag ¶
func (s *Streamline) AddTag(tag string)
func (*Streamline) Describe ¶
func (s *Streamline) Describe() []string
func (*Streamline) InsertFront ¶
func (s *Streamline) InsertFront(procName string, f ProcFunc) error
Click to show internal directories.
Click to hide internal directories.