eventing

type BlobEventData struct {
	Bucket  string    `json:"bucket"`
	Key     string    `json:"key"`
	Size    int64     `json:"size"`
	Version string    `json:"version"`
	Time    time.Time `json:"time"`
}

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

type BucketLister interface {
	List(ctx context.Context, ns v1.NamespaceName, bucket v1.ObjectName, prefix string) ([]blob.Attributes, error)
}

type CloudEvent struct {
	SpecVersion     string          `json:"specversion"`
	ID              string          `json:"id"`
	Source          string          `json:"source"` // funcd://<ns>/eventsource/<name>
	Type            string          `json:"type"`   // the event name (ADR-0108)
	Time            time.Time       `json:"time"`
	DataContentType string          `json:"datacontenttype,omitempty"`
	Data            json.RawMessage `json:"data,omitempty"`
}

type Cursor struct {
	MaxModTime time.Time `json:"maxModTime"`
	KeysAtMax  []string  `json:"keysAtMax"`
}

type Deps struct {
	Store     store.Store  // required
	Publisher Publisher    // where a firing emits its named CloudEvent (required)
	Blob      *BlobWatcher // ADR-0119: the poll watcher a `blob:` source registers on; nil ⇒ no blob support
	Logger    *slog.Logger // default slog.Default()
}

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

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

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

type Publisher interface {
	Publish(ctx context.Context, ev CloudEvent) error
}

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

type Watermark interface {
	Load(ctx context.Context, ns v1.NamespaceName, source, event v1.ObjectName) (Cursor, error)
	Save(ctx context.Context, ns v1.NamespaceName, source, event v1.ObjectName, c Cursor) error
}