stream

Documentation

Index

• Constants
• func CheckPollInterval(where string, d time.Duration) error
• func ParsePollInterval(where, raw string) (time.Duration, error)
• func Poll(ctx context.Context, name string, interval time.Duration, ...) <-chan plugin.Event
• func PollAdaptive(ctx context.Context, name string, interval time.Duration, ...) <-chan plugin.Event
• func PollInterval(params map[string]string, signal string, def time.Duration) (time.Duration, error)
• type Seen
  • func (s *Seen) Unseen(ctx context.Context, items []plugin.Item, key func(plugin.Item) string) []plugin.Item
• type State
  • func NewState(store sysstream.KV) *State
  • func StateOf(bc plugin.BuildContext) *State
  • func (s *State) Cursor(namespace, key string) *sysstream.Cursor
  • func (s *State) KV() sysstream.KV
  • func (s *State) Seen(namespace string) *Seen

Constants

const MinPollInterval = time.Second

Functions

func CheckPollInterval

func CheckPollInterval(where string, d time.Duration) error

func ParsePollInterval

func ParsePollInterval(where, raw string) (time.Duration, error)

func Poll

func Poll(ctx context.Context, name string, interval time.Duration, step func(ctx context.Context) ([]plugin.Item, error)) <-chan plugin.Event

func PollAdaptive

func PollAdaptive(ctx context.Context, name string, interval time.Duration, step func(ctx context.Context) ([]plugin.Item, time.Duration, error)) <-chan plugin.Event

func PollInterval

func PollInterval(params map[string]string, signal string, def time.Duration) (time.Duration, error)

Types

type Seen

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

func (*Seen) Unseen

func (s *Seen) Unseen(ctx context.Context, items []plugin.Item, key func(plugin.Item) string) []plugin.Item

type State

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

func NewState

func NewState(store sysstream.KV) *State

func StateOf

func StateOf(bc plugin.BuildContext) *State

func (*State) Cursor

func (s *State) Cursor(namespace, key string) *sysstream.Cursor

func (*State) KV

func (s *State) KV() sysstream.KV

func (*State) Seen

func (s *State) Seen(namespace string) *Seen