Documentation ¶
Index ¶
- type Config
- type LitterBox
- func (lb *LitterBox) EventSourceID() apieventsrc.EventSourceID
- func (lb *LitterBox) Get(ctx context.Context, id litterbox.LitterBoxID) ([]byte, error)
- func (lb *LitterBox) Loader(ctx context.Context, path *apiprogram.Path) ([]byte, string, error)
- func (lb *LitterBox) Run(ctx context.Context, id litterbox.LitterBoxID, ...) (err error)
- func (lb *LitterBox) RunEvent(ctx context.Context, id litterbox.LitterBoxID, event *litterbox.LitterBoxEvent, ...) (err error)
- func (lb *LitterBox) Scoop(ctx context.Context, id litterbox.LitterBoxID) error
- func (lb *LitterBox) Setup(ctx context.Context, id litterbox.LitterBoxID, files []byte) (litterbox.LitterBoxID, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
AccountName string `envconfig:"ACCOUNT_NAME" default:"litterbox" json:"account_name"`
}
type LitterBox ¶
type LitterBox struct { Config Config Projects projectsstore.Store Events *events.Events EventSrcs eventsrcsstore.Store PubSub pubsub.PubSub ProgramsStore kvstore.Store L L.Nullable }
func (*LitterBox) EventSourceID ¶
func (lb *LitterBox) EventSourceID() apieventsrc.EventSourceID
func (*LitterBox) Run ¶ added in v0.10.0
func (lb *LitterBox) Run( ctx context.Context, id litterbox.LitterBoxID, ch chan<- *apievent.TrackIngestEventUpdate, ) (err error)
func (*LitterBox) RunEvent ¶
func (lb *LitterBox) RunEvent( ctx context.Context, id litterbox.LitterBoxID, event *litterbox.LitterBoxEvent, ch chan<- *apievent.TrackIngestEventUpdate, ) (err error)
Click to show internal directories.
Click to hide internal directories.