openapi

package

Go to main page

Versions in this module

v0

v0.4.0

Dec 15, 2023

v0.3.0

Sep 20, 2023

Changes in this version

+ func AssertCodeApiResponseConstraints(obj CodeApiResponse) error

+ func AssertCodeApiResponseRequired(obj CodeApiResponse) error

+ func AssertDesignConstraints(obj Design) error

+ func AssertDesignSchemaConstraints(obj DesignSchema) error

+ func AssertJobSpecConstraints(obj JobSpec) error

+ type CodeApiResponse struct

+ Revision int32

type Design

+ Schema DesignSchema

+ type DesignCodeApiController struct

+ func (c *DesignCodeApiController) CreateDesignCode(w http.ResponseWriter, r *http.Request)

+ func (c *DesignCodeApiController) DeleteDesignCode(w http.ResponseWriter, r *http.Request)

+ func (c *DesignCodeApiController) GetDesignCode(w http.ResponseWriter, r *http.Request)

+ func (c *DesignCodeApiController) GetDesignCodeRevision(w http.ResponseWriter, r *http.Request)

+ func (c *DesignCodeApiController) Routes() Routes

+ func (c *DesignCodeApiController) UpdateDesignCode(w http.ResponseWriter, r *http.Request)

+ type DesignCodeApiOption func(*DesignCodeApiController)

+ func WithDesignCodeApiErrorHandler(h ErrorHandler) DesignCodeApiOption

+ type DesignCodeApiRouter interface

+ CreateDesignCode func(http.ResponseWriter, *http.Request)

+ DeleteDesignCode func(http.ResponseWriter, *http.Request)

+ GetDesignCode func(http.ResponseWriter, *http.Request)

+ GetDesignCodeRevision func(http.ResponseWriter, *http.Request)

+ UpdateDesignCode func(http.ResponseWriter, *http.Request)

+ type DesignCodeApiServicer interface

+ CreateDesignCode func(context.Context, string, string, string, *os.File) (ImplResponse, error)

+ DeleteDesignCode func(context.Context, string, string) (ImplResponse, error)

+ GetDesignCode func(context.Context, string, string) (ImplResponse, error)

+ GetDesignCodeRevision func(context.Context, string, string) (ImplResponse, error)

+ UpdateDesignCode func(context.Context, string, string, string, *os.File) (ImplResponse, error)

type DesignSchema

+ Revision int32

+ type DesignSchemaApiController struct

+ func (c *DesignSchemaApiController) CreateDesignSchema(w http.ResponseWriter, r *http.Request)

+ func (c *DesignSchemaApiController) DeleteDesignSchema(w http.ResponseWriter, r *http.Request)

+ func (c *DesignSchemaApiController) GetDesignSchema(w http.ResponseWriter, r *http.Request)

+ func (c *DesignSchemaApiController) Routes() Routes

+ func (c *DesignSchemaApiController) UpdateDesignSchema(w http.ResponseWriter, r *http.Request)

+ type DesignSchemaApiOption func(*DesignSchemaApiController)

+ func WithDesignSchemaApiErrorHandler(h ErrorHandler) DesignSchemaApiOption

+ type DesignSchemaApiRouter interface

+ CreateDesignSchema func(http.ResponseWriter, *http.Request)

+ DeleteDesignSchema func(http.ResponseWriter, *http.Request)

+ GetDesignSchema func(http.ResponseWriter, *http.Request)

+ UpdateDesignSchema func(http.ResponseWriter, *http.Request)

+ type DesignSchemaApiServicer interface

+ CreateDesignSchema func(context.Context, string, string, DesignSchema) (ImplResponse, error)

+ DeleteDesignSchema func(context.Context, string, string) (ImplResponse, error)

+ GetDesignSchema func(context.Context, string, string) (ImplResponse, error)

+ UpdateDesignSchema func(context.Context, string, string, DesignSchema) (ImplResponse, error)

type JobSpec

+ CodeRevision int32

+ SchemaRevision int32

type Router

+ func NewDesignCodeApiController(s DesignCodeApiServicer, opts ...DesignCodeApiOption) Router

+ func NewDesignSchemaApiController(s DesignSchemaApiServicer, opts ...DesignSchemaApiOption) Router

v0.2.4

Aug 30, 2023

Changes in this version

type JobSpec

+ Name string

type JobStatus

+ Name string

type TaskInfo

+ GroupAssociation map[string]string

v0.2.3

Jun 5, 2023

Changes in this version

+ func AssertRecurseRoleDatasetGroupsRequired(objSlice interface{}) error

+ func AssertRoleDatasetGroupsRequired(obj RoleDatasetGroups) error

type Channel

+ Backend CommBackend

+ BrokerHost string

type JobsApiController

+ func (c *JobsApiController) GetJobsByCompute(w http.ResponseWriter, r *http.Request)

type JobsApiRouter

+ GetTasksInfoGeneric func(context.Context, string, string, int32) (ImplResponse, error)

type JobsApiServicer

+ GetJobsByCompute func(ctx context.Context, computeId string) (ImplResponse, error)

+ GetTasksInfoGeneric func(context.Context, string, string, int32) (ImplResponse, error)

+ type RoleDatasetGroups struct

+ DatasetGroups map[string][]string

+ Role string

v0.2.2

Mar 20, 2023

Changes in this version

+ func AssertBasicJobInfoRequired(obj BasicJobInfo) error

+ func AssertModelSpecRequired(obj ModelSpec) error

+ func AssertRecurseBasicJobInfoRequired(objSlice interface{}) error

+ func AssertRecurseModelSpecRequired(objSlice interface{}) error

+ type BasicJobInfo struct

+ CodeVersion string

+ DesignId string

+ Id string

+ MaxRunTime int32

+ Priority JobPriority

+ SchemaVersion string

+ UserId string

type JobSpec

+ ModelSpec ModelSpec

+ type ModelSpec struct

+ BaseModel BaseModel

+ Dependencies []string

+ Hyperparameters map[string]interface{}

+ Optimizer Optimizer

+ Selector Selector

v0.2.1

Mar 6, 2023

Changes in this version

+ func AssertChannelGroupByRequired(obj ChannelGroupBy) error

+ func AssertChannelRequired(obj Channel) error

+ func AssertCommBackendRequired(obj CommBackend) error

+ func AssertConnectorRequired(obj Connector) error

+ func AssertDatasetInfoRequired(obj DatasetInfo) error

+ func AssertDesignInfoRequired(obj DesignInfo) error

+ func AssertDesignRequired(obj Design) error

+ func AssertDesignSchemaRequired(obj DesignSchema) error

+ func AssertDesignSchemasRequired(obj DesignSchemas) error

+ func AssertErrorRequired(obj Error) error

+ func AssertJobPriorityRequired(obj JobPriority) error

+ func AssertJobStateRequired(obj JobState) error

+ func AssertRecurseChannelGroupByRequired(objSlice interface{}) error

+ func AssertRecurseChannelRequired(objSlice interface{}) error

+ func AssertRecurseCommBackendRequired(objSlice interface{}) error

+ func AssertRecurseConnectorRequired(objSlice interface{}) error

+ func AssertRecurseDatasetInfoRequired(objSlice interface{}) error

+ func AssertRecurseDesignInfoRequired(objSlice interface{}) error

+ func AssertRecurseDesignRequired(objSlice interface{}) error

+ func AssertRecurseDesignSchemaRequired(objSlice interface{}) error

+ func AssertRecurseDesignSchemasRequired(objSlice interface{}) error

+ func AssertRecurseErrorRequired(objSlice interface{}) error

+ func AssertRecurseJobPriorityRequired(objSlice interface{}) error

+ func AssertRecurseJobStateRequired(objSlice interface{}) error

+ func AssertRecurseRoleRequired(objSlice interface{}) error

+ func AssertRoleRequired(obj Role) error

+ type DatasetsApiOption func(*DatasetsApiController)

+ func WithDatasetsApiErrorHandler(h ErrorHandler) DatasetsApiOption

+ type DesignCodesApiOption func(*DesignCodesApiController)

+ func WithDesignCodesApiErrorHandler(h ErrorHandler) DesignCodesApiOption

+ type DesignSchemasApiOption func(*DesignSchemasApiController)

+ func WithDesignSchemasApiErrorHandler(h ErrorHandler) DesignSchemasApiOption

type DesignSchemasApiRouter

+ DeleteDesignSchema func(http.ResponseWriter, *http.Request)

+ type DesignsApiOption func(*DesignsApiController)

+ func WithDesignsApiErrorHandler(h ErrorHandler) DesignsApiOption

type Role

+ GroupAssociation []map[string]string

v0.2.0

Feb 28, 2023

v0.1.7

Jan 4, 2023

v0.1.6

Nov 16, 2022

Changes in this version

type AgentState

+ const AGENT_DEPLOY_FAILED

+ const AGENT_DEPLOY_SUCCESS

+ const AGENT_REVOKE_FAILED

+ const AGENT_REVOKE_SUCCESS

type DesignCodesApiController

+ func (c *DesignCodesApiController) DeleteDesignCode(w http.ResponseWriter, r *http.Request)

type DesignCodesApiRouter

+ DeleteDesignCode func(http.ResponseWriter, *http.Request)

type DesignCodesApiServicer

+ DeleteDesignCode func(context.Context, string, string, string) (ImplResponse, error)

type DesignSchemasApiController

+ func (c *DesignSchemasApiController) DeleteDesignSchema(w http.ResponseWriter, r *http.Request)

type DesignSchemasApiServicer

+ DeleteDesignSchema func(context.Context, string, string, string) (ImplResponse, error)

type DesignsApiController

+ func (c *DesignsApiController) DeleteDesign(w http.ResponseWriter, r *http.Request)

type DesignsApiRouter

+ DeleteDesign func(http.ResponseWriter, *http.Request)

type DesignsApiServicer

+ DeleteDesign func(context.Context, string, string) (ImplResponse, error)

v0.1.5

Sep 1, 2022

Changes in this version

+ func AssertAgentStateRequired(obj AgentState) error

+ func AssertBaseModelRequired(obj BaseModel) error

+ func AssertComputeSpecRequired(obj ComputeSpec) error

+ func AssertComputeStateRequired(obj ComputeState) error

+ func AssertComputeStatusRequired(obj ComputeStatus) error

+ func AssertDeploymentConfigRequired(obj DeploymentConfig) error

+ func AssertDeploymentStatusRequired(obj DeploymentStatus) error

+ func AssertRecurseAgentStateRequired(objSlice interface{}) error

+ func AssertRecurseBaseModelRequired(objSlice interface{}) error

+ func AssertRecurseComputeSpecRequired(objSlice interface{}) error

+ func AssertRecurseComputeStateRequired(objSlice interface{}) error

+ func AssertRecurseComputeStatusRequired(objSlice interface{}) error

+ func AssertRecurseDeploymentConfigRequired(objSlice interface{}) error

+ func AssertRecurseDeploymentStatusRequired(objSlice interface{}) error

+ type AgentState string

+ const AGENT_DEPLOYED

+ const AGENT_FAILED

+ const AGENT_REVOKED

+ type ComputeSpec struct

+ AdminId string

+ ApiKey string

+ ComputeId string

+ Region string

+ type ComputeState string

+ const DOWN

+ const MAINTENANCE

+ const UP

+ type ComputeStatus struct

+ ComputeId string

+ RegisteredAt time.Time

+ State ComputeState

+ UpdatedAt time.Time

+ type ComputesApiController struct

+ func (c *ComputesApiController) DeleteCompute(w http.ResponseWriter, r *http.Request)

+ func (c *ComputesApiController) GetComputeConfig(w http.ResponseWriter, r *http.Request)

+ func (c *ComputesApiController) GetComputeStatus(w http.ResponseWriter, r *http.Request)

+ func (c *ComputesApiController) GetDeploymentConfig(w http.ResponseWriter, r *http.Request)

+ func (c *ComputesApiController) GetDeploymentStatus(w http.ResponseWriter, r *http.Request)

+ func (c *ComputesApiController) GetDeployments(w http.ResponseWriter, r *http.Request)

+ func (c *ComputesApiController) PutDeploymentStatus(w http.ResponseWriter, r *http.Request)

+ func (c *ComputesApiController) RegisterCompute(w http.ResponseWriter, r *http.Request)

+ func (c *ComputesApiController) Routes() Routes

+ func (c *ComputesApiController) UpdateCompute(w http.ResponseWriter, r *http.Request)

+ type ComputesApiOption func(*ComputesApiController)

+ func WithComputesApiErrorHandler(h ErrorHandler) ComputesApiOption

+ type ComputesApiRouter interface

+ DeleteCompute func(http.ResponseWriter, *http.Request)

+ GetComputeConfig func(http.ResponseWriter, *http.Request)

+ GetComputeStatus func(http.ResponseWriter, *http.Request)

+ GetDeploymentConfig func(http.ResponseWriter, *http.Request)

+ GetDeploymentStatus func(http.ResponseWriter, *http.Request)

+ GetDeployments func(http.ResponseWriter, *http.Request)

+ PutDeploymentStatus func(http.ResponseWriter, *http.Request)

+ RegisterCompute func(http.ResponseWriter, *http.Request)

+ UpdateCompute func(http.ResponseWriter, *http.Request)

+ type ComputesApiServicer interface

+ DeleteCompute func(context.Context, string, string) (ImplResponse, error)

+ GetComputeConfig func(context.Context, string, string) (ImplResponse, error)

+ GetComputeStatus func(context.Context, string, string) (ImplResponse, error)

+ GetDeploymentConfig func(context.Context, string, string, string) (ImplResponse, error)

+ GetDeploymentStatus func(context.Context, string, string, string) (ImplResponse, error)

+ GetDeployments func(context.Context, string, string) (ImplResponse, error)

+ PutDeploymentStatus func(context.Context, string, string, string, DeploymentStatus) (ImplResponse, error)

+ RegisterCompute func(context.Context, ComputeSpec) (ImplResponse, error)

+ UpdateCompute func(context.Context, string, string, ComputeSpec) (ImplResponse, error)

type DatasetInfo

+ ComputeId string

+ type DeploymentConfig struct

+ AgentKVs map[string]string

+ ImageLoc string

+ JobId string

+ type DeploymentStatus struct

+ AgentStatuses []map[string]AgentState

+ JobId string

type Router

+ func NewComputesApiController(s ComputesApiServicer, opts ...ComputesApiOption) Router

type TaskInfo

+ ComputeId string

v0.1.5-alpha

Aug 12, 2022

v0.1.4

Jun 24, 2022

v0.1.3

Jun 10, 2022

v0.1.2

Apr 26, 2022

Changes in this version

+ func AssertJobStatusRequired(obj JobStatus) error

+ func AssertOptimizerRequired(obj Optimizer) error

+ func AssertRecurseJobStatusRequired(objSlice interface{}) error

+ func AssertRecurseOptimizerRequired(objSlice interface{}) error

+ func AssertRecurseTaskStatusRequired(objSlice interface{}) error

+ func AssertTaskStatusRequired(obj TaskStatus) error

type JobSpec

+ Optimizer Optimizer

type JobsApiController

+ func (c *JobsApiController) GetTaskInfo(w http.ResponseWriter, r *http.Request)

type JobsApiRouter

+ GetTaskInfo func(http.ResponseWriter, *http.Request)

type JobsApiServicer

+ GetTaskInfo func(context.Context, string, string, string) (ImplResponse, error)

+ type Optimizer struct

+ Kwargs map[string]interface{}

+ Sort string

type TaskInfo

+ Log string

+ TaskId string

type TaskStatus

+ Log string

v0.1.1

Apr 21, 2022

v0.1.0

Apr 5, 2022

Changes in this version

+ var ErrTypeAssertionError = errors.New("unable to assert type")

+ func AssertDataSpecRequired(obj DataSpec) error

+ func AssertJobSpecRequired(obj JobSpec) error

+ func AssertRecurseDataSpecRequired(objSlice interface{}) error

+ func AssertRecurseInterfaceRequired(obj interface{}, callback func(interface{}) error) error

+ func AssertRecurseJobSpecRequired(objSlice interface{}) error

+ func AssertRecurseSelectorRequired(objSlice interface{}) error

+ func AssertRecurseTaskInfoRequired(objSlice interface{}) error

+ func AssertRecurseTaskTypeRequired(objSlice interface{}) error

+ func AssertRecurseValueRequired(value reflect.Value, callback func(interface{}) error) error

+ func AssertSelectorRequired(obj Selector) error

+ func AssertTaskInfoRequired(obj TaskInfo) error

+ func AssertTaskTypeRequired(obj TaskType) error

+ func DefaultErrorHandler(w http.ResponseWriter, r *http.Request, err error, result *ImplResponse)

+ func EncodeJSONResponse(i interface{}, status *int, w http.ResponseWriter) error

+ func IsZeroValue(val interface{}) bool

+ func Logger(inner http.Handler, name string) http.Handler

+ func NewRouter(routers ...Router) *mux.Router

+ func ReadFormFileToTempFile(r *http.Request, key string) (*os.File, error)

+ func ReadFormFilesToTempFiles(r *http.Request, key string) ([]*os.File, error)

+ type BaseModel struct

+ Name string

+ Version int32

+ type Channel struct

+ Description string

+ FuncTags map[string][]string

+ GroupBy ChannelGroupBy

+ IsUnidirectional bool

+ Name string

+ Pair []string

+ type ChannelGroupBy struct

+ Type string

+ Value []string

+ type CommBackend string

+ const MQTT

+ const P2P

+ type Connector struct

+ Connection map[string]interface{}

+ Description string

+ Name string

+ type DataSpec struct

+ FromSystem []string

+ FromUser map[string]int32

+ type DatasetInfo struct

+ DataFormat string

+ Description string

+ Id string

+ IsPublic bool

+ Name string

+ Realm string

+ Url string

+ UserId string

+ type DatasetsApiController struct

+ func (c *DatasetsApiController) CreateDataset(w http.ResponseWriter, r *http.Request)

+ func (c *DatasetsApiController) GetAllDatasets(w http.ResponseWriter, r *http.Request)

+ func (c *DatasetsApiController) GetDataset(w http.ResponseWriter, r *http.Request)

+ func (c *DatasetsApiController) GetDatasets(w http.ResponseWriter, r *http.Request)

+ func (c *DatasetsApiController) Routes() Routes

+ func (c *DatasetsApiController) UpdateDataset(w http.ResponseWriter, r *http.Request)

+ type DatasetsApiRouter interface

+ CreateDataset func(http.ResponseWriter, *http.Request)

+ GetAllDatasets func(http.ResponseWriter, *http.Request)

+ GetDataset func(http.ResponseWriter, *http.Request)

+ GetDatasets func(http.ResponseWriter, *http.Request)

+ UpdateDataset func(http.ResponseWriter, *http.Request)

+ type DatasetsApiServicer interface

+ CreateDataset func(context.Context, string, DatasetInfo) (ImplResponse, error)

+ GetAllDatasets func(context.Context, int32) (ImplResponse, error)

+ GetDataset func(context.Context, string, string) (ImplResponse, error)

+ GetDatasets func(context.Context, string, int32) (ImplResponse, error)

+ UpdateDataset func(context.Context, string, string, DatasetInfo) (ImplResponse, error)

+ type Design struct

+ Description string

+ Id string

+ Name string

+ Schemas []DesignSchema

+ UserId string

+ type DesignCodesApiController struct

+ func (c *DesignCodesApiController) CreateDesignCode(w http.ResponseWriter, r *http.Request)

+ func (c *DesignCodesApiController) GetDesignCode(w http.ResponseWriter, r *http.Request)

+ func (c *DesignCodesApiController) Routes() Routes

+ func (c *DesignCodesApiController) UpdateDesignCode(w http.ResponseWriter, r *http.Request)

+ type DesignCodesApiRouter interface

+ CreateDesignCode func(http.ResponseWriter, *http.Request)

+ GetDesignCode func(http.ResponseWriter, *http.Request)

+ UpdateDesignCode func(http.ResponseWriter, *http.Request)

+ type DesignCodesApiServicer interface

+ CreateDesignCode func(context.Context, string, string, string, string, *os.File) (ImplResponse, error)

+ GetDesignCode func(context.Context, string, string, string) (ImplResponse, error)

+ UpdateDesignCode func(context.Context, string, string, string, string, string, *os.File) (ImplResponse, error)

+ type DesignInfo struct

+ Description string

+ Id string

+ Name string

+ UserId string

+ type DesignSchema struct

+ Channels []Channel

+ Connectors []Connector

+ Description string

+ Name string

+ Roles []Role

+ Version string

+ type DesignSchemas struct

+ Schemas []DesignSchema

+ type DesignSchemasApiController struct

+ func (c *DesignSchemasApiController) CreateDesignSchema(w http.ResponseWriter, r *http.Request)

+ func (c *DesignSchemasApiController) GetDesignSchema(w http.ResponseWriter, r *http.Request)

+ func (c *DesignSchemasApiController) GetDesignSchemas(w http.ResponseWriter, r *http.Request)

+ func (c *DesignSchemasApiController) Routes() Routes

+ func (c *DesignSchemasApiController) UpdateDesignSchema(w http.ResponseWriter, r *http.Request)

+ type DesignSchemasApiRouter interface

+ CreateDesignSchema func(http.ResponseWriter, *http.Request)

+ GetDesignSchema func(http.ResponseWriter, *http.Request)

+ GetDesignSchemas func(http.ResponseWriter, *http.Request)

+ UpdateDesignSchema func(http.ResponseWriter, *http.Request)

+ type DesignSchemasApiServicer interface

+ CreateDesignSchema func(context.Context, string, string, DesignSchema) (ImplResponse, error)

+ GetDesignSchema func(context.Context, string, string, string) (ImplResponse, error)

+ GetDesignSchemas func(context.Context, string, string) (ImplResponse, error)

+ UpdateDesignSchema func(context.Context, string, string, string, DesignSchema) (ImplResponse, error)

+ type DesignsApiController struct

+ func (c *DesignsApiController) CreateDesign(w http.ResponseWriter, r *http.Request)

+ func (c *DesignsApiController) GetDesign(w http.ResponseWriter, r *http.Request)

+ func (c *DesignsApiController) GetDesigns(w http.ResponseWriter, r *http.Request)

+ func (c *DesignsApiController) Routes() Routes

+ type DesignsApiRouter interface

+ CreateDesign func(http.ResponseWriter, *http.Request)

+ GetDesign func(http.ResponseWriter, *http.Request)

+ GetDesigns func(http.ResponseWriter, *http.Request)

+ type DesignsApiServicer interface

+ CreateDesign func(context.Context, string, DesignInfo) (ImplResponse, error)

+ GetDesign func(context.Context, string, string) (ImplResponse, error)

+ GetDesigns func(context.Context, string, int32) (ImplResponse, error)

+ type Error struct

+ Code int32

+ Message string

+ type ErrorHandler func(w http.ResponseWriter, r *http.Request, err error, result *ImplResponse)

+ type ImplResponse struct

+ Body interface{}

+ Code int

+ func Response(code int, body interface{}) ImplResponse

+ type JobPriority string

+ const HIGH

+ const LOW

+ const MEDIUM

+ type JobSpec struct

+ Backend CommBackend

+ BaseModel BaseModel

+ CodeVersion string

+ DataSpec DataSpec

+ Dependencies []string

+ DesignId string

+ Hyperparameters map[string]interface{}

+ Id string

+ MaxRunTime int32

+ Priority JobPriority

+ SchemaVersion string

+ Selector Selector

+ UserId string

+ type JobState string

+ const APPLYING

+ const COMPLETED

+ const DEPLOYING

+ const FAILED

+ const READY

+ const RUNNING

+ const STARTING

+ const STOPPING

+ const TERMINATED

+ type JobStatus struct

+ CreatedAt time.Time

+ EndedAt time.Time

+ Id string

+ StartedAt time.Time

+ State JobState

+ UpdatedAt time.Time

+ type JobsApiController struct

+ func (c *JobsApiController) CreateJob(w http.ResponseWriter, r *http.Request)

+ func (c *JobsApiController) DeleteJob(w http.ResponseWriter, r *http.Request)

+ func (c *JobsApiController) GetJob(w http.ResponseWriter, r *http.Request)

+ func (c *JobsApiController) GetJobStatus(w http.ResponseWriter, r *http.Request)

+ func (c *JobsApiController) GetJobs(w http.ResponseWriter, r *http.Request)

+ func (c *JobsApiController) GetTask(w http.ResponseWriter, r *http.Request)

+ func (c *JobsApiController) GetTasksInfo(w http.ResponseWriter, r *http.Request)

+ func (c *JobsApiController) Routes() Routes

+ func (c *JobsApiController) UpdateJob(w http.ResponseWriter, r *http.Request)

+ func (c *JobsApiController) UpdateJobStatus(w http.ResponseWriter, r *http.Request)

+ func (c *JobsApiController) UpdateTaskStatus(w http.ResponseWriter, r *http.Request)

+ type JobsApiOption func(*JobsApiController)

+ func WithJobsApiErrorHandler(h ErrorHandler) JobsApiOption

+ type JobsApiRouter interface

+ CreateJob func(http.ResponseWriter, *http.Request)

+ DeleteJob func(http.ResponseWriter, *http.Request)

+ GetJob func(http.ResponseWriter, *http.Request)

+ GetJobStatus func(http.ResponseWriter, *http.Request)

+ GetJobs func(http.ResponseWriter, *http.Request)

+ GetTask func(http.ResponseWriter, *http.Request)

+ GetTasksInfo func(http.ResponseWriter, *http.Request)

+ UpdateJob func(http.ResponseWriter, *http.Request)

+ UpdateJobStatus func(http.ResponseWriter, *http.Request)

+ UpdateTaskStatus func(http.ResponseWriter, *http.Request)

+ type JobsApiServicer interface

+ CreateJob func(context.Context, string, JobSpec) (ImplResponse, error)

+ DeleteJob func(context.Context, string, string) (ImplResponse, error)

+ GetJob func(context.Context, string, string) (ImplResponse, error)

+ GetJobStatus func(context.Context, string, string) (ImplResponse, error)

+ GetJobs func(context.Context, string, int32) (ImplResponse, error)

+ GetTask func(context.Context, string, string, string) (ImplResponse, error)

+ GetTasksInfo func(context.Context, string, string, int32) (ImplResponse, error)

+ UpdateJob func(context.Context, string, string, JobSpec) (ImplResponse, error)

+ UpdateJobStatus func(context.Context, string, string, JobStatus) (ImplResponse, error)

+ UpdateTaskStatus func(context.Context, string, string, TaskStatus) (ImplResponse, error)

+ type ParsingError struct

+ Err error

+ func (e *ParsingError) Error() string

+ func (e *ParsingError) Unwrap() error

+ type RequiredError struct

+ Field string

+ func (e *RequiredError) Error() string

+ type Role struct

+ Description string

+ IsDataConsumer bool

+ Name string

+ Replica int32

+ type Route struct

+ HandlerFunc http.HandlerFunc

+ Method string

+ Name string

+ Pattern string

+ type Router interface

+ Routes func() Routes

+ func NewDatasetsApiController(s DatasetsApiServicer) Router

+ func NewDesignCodesApiController(s DesignCodesApiServicer) Router

+ func NewDesignSchemasApiController(s DesignSchemasApiServicer) Router

+ func NewDesignsApiController(s DesignsApiServicer) Router

+ func NewJobsApiController(s JobsApiServicer, opts ...JobsApiOption) Router

+ type Routes []Route

+ type Selector struct

+ Kwargs map[string]interface{}

+ Sort string

+ type TaskInfo struct

+ AgentId string

+ JobId string

+ Key string

+ Role string

+ State JobState

+ Timestamp time.Time

+ Type TaskType

+ type TaskStatus struct

+ State JobState

+ Timestamp time.Time

+ type TaskType string

+ const SYSTEM

+ const USER

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL