service

Documentation

Index

• Constants
• type Dependency
• type ErrNotDefinedEnv
  • func (e ErrNotDefinedEnv) Error() string
• type Event
• type EventNotFoundError
  • func (e *EventNotFoundError) Error() string
• type InvalidEventDataError
  • func (e *InvalidEventDataError) Error() string
• type InvalidTaskInputError
  • func (e *InvalidTaskInputError) Error() string
• type InvalidTaskOutputError
  • func (e *InvalidTaskOutputError) Error() string
• type Log
• type Parameter
• type ParameterWarning
  • func (p *ParameterWarning) String() string
• type Service
  • func (s *Service) GetDependency(dependencyKey string) (*Dependency, error)
  • func (s *Service) GetEvent(eventKey string) (*Event, error)
  • func (s *Service) GetTask(taskKey string) (*Task, error)
  • func (s *Service) RequireEventData(eventKey string, eventData map[string]interface{}) error
  • func (s *Service) RequireTaskInputs(taskKey string, taskInputs map[string]interface{}) error
  • func (s *Service) RequireTaskOutputs(taskKey string, taskOutputs map[string]interface{}) error
  • func (s *Service) ValidateConfigurationEnv(env map[string]string) error
  • func (s *Service) ValidateEventData(eventKey string, eventData map[string]interface{}) ([]*ParameterWarning, error)
  • func (s *Service) ValidateTaskInputs(taskKey string, taskInputs map[string]interface{}) ([]*ParameterWarning, error)
  • func (s *Service) ValidateTaskOutputs(taskKey string, taskOutputs map[string]interface{}) ([]*ParameterWarning, error)
• type StatusType
  • func (s StatusType) String() string
• type Task
• type TaskNotFoundError
  • func (e *TaskNotFoundError) Error() string

Constants

const MainServiceKey = importer.ConfigurationDependencyKey

MainServiceKey is key for main service.

Types

type Dependency

type Dependency struct {
	// Key is the key of dependency.
	Key string `hash:"1"`

	// Image is the Docker image.
	Image string `hash:"name:2"`

	// Volumes are the Docker volumes.
	Volumes []string `hash:"name:3"`

	// VolumesFrom are the docker volumes-from from.
	VolumesFrom []string `hash:"name:4"`

	// Ports holds ports configuration for container.
	Ports []string `hash:"name:5"`

	// Command is the Docker command which will be executed when container started.
	Command string `hash:"name:6"`

	// Argument holds the args to pass to the Docker container
	Args []string `hash:"name:7"`

	// Env is a slice of environment variables in key=value format.
	Env []string `hash:"name:8"`
}

Dependency represents a Docker container and it holds instructions about how it should run.

type ErrNotDefinedEnv

type ErrNotDefinedEnv struct {
	Env []string
}

ErrNotDefinedEnv error returned when optionally given env variables are not defined in the mesg.yml file.

func (ErrNotDefinedEnv) Error

func (e ErrNotDefinedEnv) Error() string

type Event

type Event struct {
	// Key is the key of event.
	Key string `hash:"name:1"`

	// Name is the name of event.
	Name string `hash:"name:2"`

	// Description is the description of event.
	Description string `hash:"name:3"`

	// Data holds the input parameters of event.
	Data []*Parameter `hash:"name:4"`
}

Event describes a service task.

type EventNotFoundError

type EventNotFoundError struct {
	EventKey    string
	ServiceName string
}

EventNotFoundError is an error returned when corresponding event cannot be found in service.

func (*EventNotFoundError) Error

func (e *EventNotFoundError) Error() string

type InvalidEventDataError

type InvalidEventDataError struct {
	EventKey    string
	ServiceName string
	Warnings    []*ParameterWarning
}

InvalidEventDataError is an error returned when the data of corresponding event is not valid.

func (*InvalidEventDataError) Error

func (e *InvalidEventDataError) Error() string

type InvalidTaskInputError

type InvalidTaskInputError struct {
	TaskKey     string
	ServiceName string
	Warnings    []*ParameterWarning
}

InvalidTaskInputError is an error returned when the inputs of corresponding task are not valid.

func (*InvalidTaskInputError) Error

func (e *InvalidTaskInputError) Error() string

type InvalidTaskOutputError

type InvalidTaskOutputError struct {
	TaskKey     string
	ServiceName string
	Warnings    []*ParameterWarning
}

InvalidTaskOutputError is an error returned when the outputs of corresponding task are not valid.

func (*InvalidTaskOutputError) Error

func (e *InvalidTaskOutputError) Error() string

type Log

type Log struct {
	Dependency string
	Standard   io.ReadCloser
	Error      io.ReadCloser
}

Log holds log streams of dependency.

type Parameter

type Parameter struct {
	// Key is the key of parameter.
	Key string `hash:"name:1"`

	// Name is the name of parameter.
	Name string `hash:"name:2"`

	// Description is the description of parameter.
	Description string `hash:"name:3"`

	// Type is the data type of parameter.
	Type string `hash:"name:4"`

	// Optional indicates if parameter is optional.
	Optional bool `hash:"name:5"`

	// Repeated is to have an array of this parameter
	Repeated bool `hash:"name:6"`

	// Definition of the structure of the object when the type is object
	Object []*Parameter `hash:"name:7"`
}

Parameter describes task input parameters, output parameters of a task output and input parameters of an event.

type ParameterWarning

type ParameterWarning struct {
	Key       string
	Warning   string
	Parameter *Parameter
}

ParameterWarning contains a specific warning related to a parameter.

func (*ParameterWarning) String

func (p *ParameterWarning) String() string

type Service

type Service struct {
	// Hash is calculated from the combination of service's source and mesg.yml.
	// It represents the service uniquely.
	Hash string `hash:"-"`

	// Sid is the service id.
	// It needs to be unique and can be used to access to service.
	Sid string `hash:"name:1"`

	// Name is the service name.
	Name string `hash:"name:2"`

	// Description is service description.
	Description string `hash:"name:3"`

	// Tasks are the list of tasks that service can execute.
	Tasks []*Task `hash:"name:4"`

	// Events are the list of events that service can emit.
	Events []*Event `hash:"name:5"`

	// Dependencies are the Docker containers that service can depend on.
	Dependencies []*Dependency `hash:"name:6"`

	// Configuration of the service
	Configuration *Dependency `hash:"name:8"`

	// Repository holds the service's repository url if it's living on
	// a Git host.
	Repository string `hash:"name:7"`

	// Source is the hash id of service's source code on IPFS.
	Source string `hash:"name:9"`

	// DeployedAt holds the creation time of service.
	DeployedAt time.Time `hash:"-"`
}

Service represents a MESG service.

func (*Service) GetDependency

func (s *Service) GetDependency(dependencyKey string) (*Dependency, error)

GetDependency returns dependency dependencyKey or a not found error.

func (*Service) GetEvent

func (s *Service) GetEvent(eventKey string) (*Event, error)

GetEvent returns event eventKey of service.

func (*Service) GetTask

func (s *Service) GetTask(taskKey string) (*Task, error)

GetTask returns task taskKey of service.

func (*Service) RequireEventData

func (s *Service) RequireEventData(eventKey string, eventData map[string]interface{}) error

RequireEventData requires event datas to be matched with parameter schemas.

func (*Service) RequireTaskInputs

func (s *Service) RequireTaskInputs(taskKey string, taskInputs map[string]interface{}) error

RequireTaskInputs requires task inputs to match with parameter schemas.

func (*Service) RequireTaskOutputs

func (s *Service) RequireTaskOutputs(taskKey string, taskOutputs map[string]interface{}) error

RequireTaskOutputs requires task outputs to match with parameter schemas.

func (*Service) ValidateConfigurationEnv

func (s *Service) ValidateConfigurationEnv(env map[string]string) error

ValidateConfigurationEnv checks presence of env variables in mesg.yml under env section.

func (*Service) ValidateEventData

func (s *Service) ValidateEventData(eventKey string, eventData map[string]interface{}) ([]*ParameterWarning, error)

ValidateEventData produces warnings for event datas that doesn't satisfy their parameter schemas.

func (*Service) ValidateTaskInputs

func (s *Service) ValidateTaskInputs(taskKey string, taskInputs map[string]interface{}) ([]*ParameterWarning, error)

ValidateTaskInputs produces warnings for task inputs that doesn't satisfy their parameter schemas.

func (*Service) ValidateTaskOutputs

func (s *Service) ValidateTaskOutputs(taskKey string, taskOutputs map[string]interface{}) ([]*ParameterWarning, error)

ValidateTaskOutputs produces warnings for task outputs that doesn't satisfy their parameter schemas.

type StatusType

type StatusType uint

StatusType of the service.

const (
	UNKNOWN StatusType = iota
	STOPPED
	STARTING
	PARTIAL
	RUNNING
)

Possible statuses for service.

func (StatusType) String

func (s StatusType) String() string

type Task

type Task struct {
	// Key is the key of task.
	Key string `hash:"name:1"`

	// Name is the name of task.
	Name string `hash:"name:2"`

	// Description is the description of task.
	Description string `hash:"name:3"`

	// Inputs are the definition of the execution inputs of task.
	Inputs []*Parameter `hash:"name:4"`

	// Outputs are the definition of the execution results of task.
	Outputs []*Parameter `hash:"name:5"`
}

Task describes a service task.

type TaskNotFoundError

type TaskNotFoundError struct {
	TaskKey     string
	ServiceName string
}

TaskNotFoundError is an error returned when corresponding task cannot be found in service.

func (*TaskNotFoundError) Error

func (e *TaskNotFoundError) Error() string