api

type AccessControl struct {
	Resource string
	Action   string
	Deny     bool
}

type ClientInfo struct {
	ClientId  string
	PublicKey []byte
	Deleted   bool
}

type CollectorSink struct {
	Entities          []*Entity
	ContinuationToken string
	Context           *Entity
}

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

type Dataset struct {
	Name  string   `json:"name"`
	Type  []string `json:"type"`
	Items int      `json:"items"`
}

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

type DatasetType string

type Entity struct {
	ID         string                 `json:"id"`
	Recorded   uint64                 `json:"recorded"`
	IsDeleted  bool                   `json:"deleted"`
	References map[string]interface{} `json:"refs"`
	Properties map[string]interface{} `json:"props"`
}

type EntityListDatasource struct {
	Entities []*Entity
}

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

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

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

type HistoryView struct {
	LastRun      string
	LastDuration string
}

type Job struct {
	Title       string                 `json:"title"`
	Id          string                 `json:"id"`
	Description string                 `json:"description"`
	Tags        []string               `json:"tags"`
	Source      map[string]interface{} `json:"source"`
	Sink        map[string]interface{} `json:"sink"`
	Transform   map[string]interface{} `json:"transform"`
	Triggers    []JobTrigger           `json:"triggers"`
	Paused      bool                   `json:"paused"`
	BatchSize   int                    `json:"batchSize"`
}

type JobHistory struct {
	Id        string    `json:"id"`
	Title     string    `json:"title"`
	Start     time.Time `json:"start"`
	End       time.Time `json:"end"`
	LastError string    `json:"lastError"`
}

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

type JobOutput struct {
	Job     Job
	History *JobHistory
}

type JobOutputViewItem struct {
	Job         Job          `json:"job"`
	History     *JobHistory  `json:"history"`
	HistoryView *HistoryView `json:"historyView"`
}

type JobStatus struct {
	JobId    string    `json:"jobId"`
	JobTitle string    `json:"jobTitle"`
	Started  time.Time `json:"started"`
}

type JobTrigger struct {
	TriggerType      string `json:"triggerType"`
	JobType          string `json:"jobType"`
	Schedule         string `json:"schedule"`
	MonitoredDataset string `json:"monitoredDataset"`
}

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

type PrettySink struct{}

type ProviderConfig struct {
	Name         string       `json:"name"`
	Type         string       `json:"type"`
	User         *ValueReader `json:"user,omitempty"`
	Password     *ValueReader `json:"password,omitempty"`
	ClientId     *ValueReader `json:"key,omitempty"`
	ClientSecret *ValueReader `json:"secret,omitempty"`
	Audience     *ValueReader `json:"audience,omitempty"`
	GrantType    *ValueReader `json:"grantType,omitempty"`
	Endpoint     *ValueReader `json:"endpoint,omitempty"`
}

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

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

type Sink interface {
	ProcessEntities(entities []*Entity) error
	Start()
	End()
}

type SinkExpander struct {
	Sink Sink
}

type Source interface {
	// contains filtered or unexported methods
}

type StdinDatasetSource struct{}

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

type ValueReader struct {
	Type  string `json:"type"`
	Value string `json:"value"`
}