Versions in this module Expand all Collapse all v0 v0.0.3 Oct 30, 2024 v0.0.2 Oct 8, 2024 v0.0.1 Sep 13, 2024 Changes in this version + var DefaultClient = NewClient(ClientConfig{ ... }) + var DefaultNamespace = "default" + type BaseEvent struct + EventTime string + Producer string + SchemaURL string + type Client struct + Namespace string + func NewClient(cfg ClientConfig) (*Client, error) + func (olc *Client) Emit(ctx context.Context, event Emittable) error + type ClientConfig struct + Disabled bool + Namespace string + Transport transport.Config + func ConfigFromEnv() (ClientConfig, error) + func ConfigFromFile(location string) (ClientConfig, error) + type Dataset struct + Facets *facets.DatasetFacets + Name string + Namespace string + func NewDataset(name string, namespace string, datasetFacets ...facets.DatasetFacet) Dataset + type DatasetEvent struct + Dataset Dataset + func NewDatasetEvent(name string, namespace string, facets ...facets.DatasetFacet) DatasetEvent + func (e *DatasetEvent) AsEmittable() Event + func (e *DatasetEvent) Emit() + type Emittable interface + AsEmittable func() Event + type Event struct + Dataset *Dataset + EventTime string + EventType *EventType + Inputs []InputElement + Job *Job + Outputs []OutputElement + Producer string + Run *Run + SchemaURL string + type EventType string + const EventTypeAbort + const EventTypeComplete + const EventTypeFail + const EventTypeOther + const EventTypeRunning + const EventTypeStart + type InputElement struct + Facets *facets.DatasetFacets + InputFacets *facets.InputDatasetFacets + Name string + Namespace string + func NewInputElement(name string, namespace string) InputElement + func (ie InputElement) WithFacets(facets ...facets.DatasetFacet) InputElement + func (ie InputElement) WithInputFacets(facets ...facets.InputDatasetFacet) InputElement + type Job struct + Facets *facets.JobFacets + Name string + Namespace string + func NewJob(name string, jobFacets ...facets.JobFacet) Job + func NewNamespacedJob(name string, namespace string, jobFacets ...facets.JobFacet) Job + type JobEvent struct + Inputs []InputElement + Job Job + Outputs []OutputElement + func NewJobEvent(name string) *JobEvent + func NewNamespacedJobEvent(name, namespace string) *JobEvent + func (e *JobEvent) AsEmittable() Event + func (e *JobEvent) Emit() + func (j *JobEvent) WithFacets(facets ...facets.JobFacet) *JobEvent + func (j *JobEvent) WithInputs(inputs ...InputElement) *JobEvent + func (j *JobEvent) WithOutputs(inputs ...OutputElement) *JobEvent + type OutputElement struct + Facets *facets.DatasetFacets + Name string + Namespace string + OutputFacets *facets.OutputDatasetFacets + func NewOutputElement(name string, namespace string) OutputElement + func (oe OutputElement) WithFacets(facets ...facets.DatasetFacet) OutputElement + func (oe OutputElement) WithOutputFacets(facets ...facets.OutputDatasetFacet) OutputElement + type Run struct + Facets *facets.RunFacets + RunID string + type RunEvent struct + EventType EventType + Inputs []InputElement + Job Job + Outputs []OutputElement + Run Run + func NewNamespacedRunEvent(eventType EventType, runID uuid.UUID, jobName string, jobNamespace string) *RunEvent + func NewRunEvent(eventType EventType, runID uuid.UUID, jobName string) *RunEvent + func (e *RunEvent) AsEmittable() Event + func (e *RunEvent) Emit() + func (r *RunEvent) WithInputs(inputs ...InputElement) *RunEvent + func (r *RunEvent) WithJobFacets(jobFacets ...facets.JobFacet) *RunEvent + func (r *RunEvent) WithOutputs(outputs ...OutputElement) *RunEvent + func (r *RunEvent) WithParent(parentID uuid.UUID, jobName, namespace string) *RunEvent + func (r *RunEvent) WithRunFacets(runFacets ...facets.RunFacet) *RunEvent
Go to main page