service

Jun 9, 2020

Changes in this version

type Service_Task

+ Price *Service_Task_Price

+ type Service_Task_Price struct

+ PerCall github_com_cosmos_cosmos_sdk_types.Int

+ PerKB github_com_cosmos_cosmos_sdk_types.Int

+ PerSec github_com_cosmos_cosmos_sdk_types.Int

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Service_Task_Price) Descriptor() ([]byte, []int)

+ func (*Service_Task_Price) ProtoMessage()

+ func (m *Service_Task_Price) Reset()

+ func (m *Service_Task_Price) String() string

+ func (m *Service_Task_Price) XXX_DiscardUnknown()

+ func (m *Service_Task_Price) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Service_Task_Price) XXX_Merge(src proto.Message)

+ func (m *Service_Task_Price) XXX_Size() int

+ func (m *Service_Task_Price) XXX_Unmarshal(b []byte) error

+ func (this *Service_Task_Price) Equal(that interface{}) bool

Apr 19, 2020

Changes in this version

type Service

+ func (s *Service) Validate() error

Mar 17, 2020

Changes in this version

type Service

+ Address github_com_cosmos_cosmos_sdk_types.AccAddress

Nov 26, 2019

Changes in this version

type Service

+ func (this *Service) Equal(that interface{}) bool

type Service_Configuration

+ func (this *Service_Configuration) Equal(that interface{}) bool

type Service_Dependency

+ func (this *Service_Dependency) Equal(that interface{}) bool

type Service_Event

+ func (this *Service_Event) Equal(that interface{}) bool

type Service_Parameter

+ func (this *Service_Parameter) Equal(that interface{}) bool

type Service_Task

+ func (this *Service_Task) Equal(that interface{}) bool

Sep 11, 2019

Changes in this version

type Service_Parameter

+ func (p *Service_Parameter) Validate(value *types.Value) error

Sep 6, 2019

Changes in this version

type Service

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (m *Service) XXX_DiscardUnknown()

+ func (m *Service) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Service) XXX_Merge(src proto.Message)

+ func (m *Service) XXX_Size() int

+ func (m *Service) XXX_Unmarshal(b []byte) error

+ type Service_Configuration struct

+ Args []string

+ Command string

+ Env []string

+ Ports []string

+ Volumes []string

+ VolumesFrom []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Service_Configuration) Descriptor() ([]byte, []int)

+ func (*Service_Configuration) ProtoMessage()

+ func (m *Service_Configuration) Reset()

+ func (m *Service_Configuration) String() string

+ func (m *Service_Configuration) XXX_DiscardUnknown()

+ func (m *Service_Configuration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Service_Configuration) XXX_Merge(src proto.Message)

+ func (m *Service_Configuration) XXX_Size() int

+ func (m *Service_Configuration) XXX_Unmarshal(b []byte) error

+ type Service_Dependency struct

+ Args []string

+ Command string

+ Env []string

+ Image string

+ Key string

+ Ports []string

+ Volumes []string

+ VolumesFrom []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Service_Dependency) Descriptor() ([]byte, []int)

+ func (*Service_Dependency) ProtoMessage()

+ func (m *Service_Dependency) Reset()

+ func (m *Service_Dependency) String() string

+ func (m *Service_Dependency) XXX_DiscardUnknown()

+ func (m *Service_Dependency) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Service_Dependency) XXX_Merge(src proto.Message)

+ func (m *Service_Dependency) XXX_Size() int

+ func (m *Service_Dependency) XXX_Unmarshal(b []byte) error

+ type Service_Event struct

+ Data []*Service_Parameter

+ Description string

+ Key string

+ Name string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Service_Event) Descriptor() ([]byte, []int)

+ func (*Service_Event) ProtoMessage()

+ func (m *Service_Event) Reset()

+ func (m *Service_Event) String() string

+ func (m *Service_Event) XXX_DiscardUnknown()

+ func (m *Service_Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Service_Event) XXX_Merge(src proto.Message)

+ func (m *Service_Event) XXX_Size() int

+ func (m *Service_Event) XXX_Unmarshal(b []byte) error

+ type Service_Parameter struct

+ Description string

+ Key string

+ Name string

+ Object []*Service_Parameter

+ Optional bool

+ Repeated bool

+ Type string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Service_Parameter) Descriptor() ([]byte, []int)

+ func (*Service_Parameter) ProtoMessage()

+ func (m *Service_Parameter) Reset()

+ func (m *Service_Parameter) String() string

+ func (m *Service_Parameter) XXX_DiscardUnknown()

+ func (m *Service_Parameter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Service_Parameter) XXX_Merge(src proto.Message)

+ func (m *Service_Parameter) XXX_Size() int

+ func (m *Service_Parameter) XXX_Unmarshal(b []byte) error

+ type Service_Task struct

+ Description string

+ Inputs []*Service_Parameter

+ Key string

+ Name string

+ Outputs []*Service_Parameter

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Service_Task) Descriptor() ([]byte, []int)

+ func (*Service_Task) ProtoMessage()

+ func (m *Service_Task) Reset()

+ func (m *Service_Task) String() string

+ func (m *Service_Task) XXX_DiscardUnknown()

+ func (m *Service_Task) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Service_Task) XXX_Merge(src proto.Message)

+ func (m *Service_Task) XXX_Size() int

+ func (m *Service_Task) XXX_Unmarshal(b []byte) error

Aug 16, 2019

Changes in this version

+ type Configuration struct

+ Args []string

+ Command string

+ Env []string

+ Ports []string

+ Volumes []string

+ VolumesFrom []string

Jul 30, 2019

Changes in this version

type Service

+ Workflows []*Workflow

+ type TriggerType uint

+ const EVENT

+ const RESULT

+ type Workflow struct

+ Key string

+ Task *WorkflowTask

+ Trigger *WorkflowTrigger

+ type WorkflowPredicate uint

+ const EQ

+ type WorkflowTask struct

+ InstanceHash hash.Hash

+ TaskKey string

+ type WorkflowTrigger struct

+ Filters []*WorkflowTriggerFilter

+ InstanceHash hash.Hash

+ Key string

+ Type TriggerType

+ func (t *WorkflowTrigger) Match(trigger TriggerType, instanceHash hash.Hash, key string, ...) bool

+ type WorkflowTriggerFilter struct

+ Key string

+ Predicate WorkflowPredicate

+ Value interface{}

+ func (f *WorkflowTriggerFilter) Match(inputs map[string]interface{}) bool

Jul 5, 2019

Changes in this version

+ const MainServiceKey

+ func ValidateService(service *Service) error

type Dependency

+ Env []string

+ type ErrNotDefinedEnv struct

+ Env []string

+ func (e ErrNotDefinedEnv) Error() string

type Parameter

+ Object []*Parameter

+ Repeated bool

type Service

+ Sid string

+ Source string

+ func (s *Service) GetDependency(dependencyKey string) (*Dependency, 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)

Dec 7, 2018

Changes in this version

type Dependency

+ Args []string

+ func (d *Dependency) DeleteVolumes() error

type Service

+ SID string

+ func (s *Service) DeleteVolumes() error

Oct 5, 2018

Changes in this version

+ type DStatusType int

+ const DDoneNegative

+ const DDonePositive

+ const DRunning

type Dependency

+ Key string

+ VolumesFrom []string

+ func (d *Dependency) Logs() (rstd, rerr io.ReadCloser, err error)

+ func (d *Dependency) Start(networkID string) (containerServiceID string, err error)

+ func (d *Dependency) Status() (container.StatusType, error)

+ func (d *Dependency) Stop() error

+ type DeployStatus struct

+ Message string

+ Type DStatusType

type Event

+ Key string

+ func (e *Event) RequireData(eventData map[string]interface{}) error

+ func (e *Event) ValidateData(eventData map[string]interface{}) []*ParameterWarning

type EventNotFoundError

+ ServiceName string

type InvalidEventDataError

+ ServiceName string

+ Warnings []*ParameterWarning

type InvalidTaskInputError

+ ServiceName string

+ Warnings []*ParameterWarning

+ type InvalidTaskOutputError struct

+ ServiceName string

+ TaskKey string

+ TaskOutputKey string

+ Warnings []*ParameterWarning

+ func (e *InvalidTaskOutputError) Error() string

+ type Log struct

+ Dependency string

+ Error io.ReadCloser

+ Standard io.ReadCloser

+ type Option func(*Service)

+ func ContainerOption(container container.Container) Option

+ func DeployStatusOption(statuses chan DeployStatus) Option

type Output

+ Key string

+ func (o *Output) RequireData(outputData map[string]interface{}) error

+ func (o *Output) ValidateData(outputData map[string]interface{}) []*ParameterWarning

type Parameter

+ Key string

type ParameterWarning

+ Key string

+ Parameter *Parameter

+ Warning string

type Service

+ DeployedAt time.Time

+ ID string

+ func FromService(s *Service, options ...Option) (*Service, error)

+ func New(tarball io.Reader, options ...Option) (*Service, error)

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

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

type StatusType

+ const STARTING

+ const UNKNOWN

+ func (s StatusType) String() string

type Task

+ Key string

+ func (t *Task) GetInputParameter(inputKey string) (*Parameter, error)

+ func (t *Task) GetOutput(outputKey string) (*Output, error)

+ func (t *Task) RequireInputs(taskInputs map[string]interface{}) error

+ func (t *Task) ValidateInputs(taskInputs map[string]interface{}) []*ParameterWarning

+ type TaskInputNotFoundError struct

+ ServiceName string

+ TaskInputKey string

+ TaskKey string

+ func (e *TaskInputNotFoundError) Error() string

type TaskNotFoundError

+ ServiceName string

+ type TaskOutputNotFoundError struct

+ ServiceName string

+ TaskKey string

+ TaskOutputKey string

+ func (e *TaskOutputNotFoundError) Error() string

Aug 20, 2018

Changes in this version

type Event

+ func (e *Event) IsValid(data map[string]interface{}) bool

+ func (e *Event) Validate(data map[string]interface{}) []*ParameterWarning

+ type EventNotFoundError struct

+ EventKey string

+ Service *Service

+ func (e *EventNotFoundError) Error() string

+ type InputNotFoundError struct

+ InputKey string

+ Service *Service

+ TaskKey string

+ func (e *InputNotFoundError) Error() string

+ type InvalidEventDataError struct

+ Event *Event

+ EventData map[string]interface{}

+ EventKey string

+ func (e *InvalidEventDataError) Error() string

+ type InvalidOutputDataError struct

+ Output *Output

+ OutputData map[string]interface{}

+ OutputKey string

+ TaskKey string

+ func (e *InvalidOutputDataError) Error() string

+ type InvalidTaskInputError struct

+ InputData map[string]interface{}

+ Task *Task

+ TaskKey string

+ func (e *InvalidTaskInputError) Error() string

type Output

+ func (o *Output) IsValid(data map[string]interface{}) bool

+ func (o *Output) Validate(data map[string]interface{}) []*ParameterWarning

+ type OutputNotFoundError struct

+ OutputKey string

+ Service *Service

+ TaskKey string

+ func (e *OutputNotFoundError) Error() string

type Parameter

+ func (p *Parameter) Validate(data interface{}) *ParameterWarning

+ type ParameterWarning struct

+ func (p *ParameterWarning) String() string

type Service

+ func (s *Service) Cast(taskKey string, taskData map[string]string) (map[string]interface{}, error)

type Task

+ func (t *Task) IsValid(data map[string]interface{}) bool

+ func (t *Task) Validate(data map[string]interface{}) []*ParameterWarning

+ type TaskNotFoundError struct

+ Service *Service

+ TaskKey string

+ func (e *TaskNotFoundError) Error() string

Jul 4, 2018

Changes in this version

+ func ListRunning() (res []string, err error)

+ func ValidService(path string) (warnings []gojsonschema.ResultError, err error)

+ type Dependency struct

+ Command string

+ Image string

+ Ports []string

+ Volumes []string

+ Volumesfrom []string

+ func (*Dependency) Descriptor() ([]byte, []int)

+ func (*Dependency) ProtoMessage()

+ func (m *Dependency) GetCommand() string

+ func (m *Dependency) GetImage() string

+ func (m *Dependency) GetPorts() []string

+ func (m *Dependency) GetVolumes() []string

+ func (m *Dependency) GetVolumesfrom() []string

+ func (m *Dependency) Reset()

+ func (m *Dependency) String() string

+ type DependencyFromService struct

+ Name string

+ Service *Service

+ func (dependency *DependencyFromService) Start(networkID string) (containerServiceID string, err error)

+ func (dependency *DependencyFromService) Status() (status container.StatusType, err error)

+ func (dependency *DependencyFromService) Stop() (err error)

+ type Event struct

+ Data map[string]*Parameter

+ Description string

+ Name string

+ func (*Event) Descriptor() ([]byte, []int)

+ func (*Event) ProtoMessage()

+ func (m *Event) GetData() map[string]*Parameter

+ func (m *Event) GetDescription() string

+ func (m *Event) GetName() string

+ func (m *Event) Reset()

+ func (m *Event) String() string

+ type Fee struct

+ Developer string

+ Emittors string

+ Executor string

+ Validator string

+ func (*Fee) Descriptor() ([]byte, []int)

+ func (*Fee) ProtoMessage()

+ func (m *Fee) GetDeveloper() string

+ func (m *Fee) GetEmittors() string

+ func (m *Fee) GetExecutor() string

+ func (m *Fee) GetValidator() string

+ func (m *Fee) Reset()

+ func (m *Fee) String() string

+ type Output struct

+ Data map[string]*Parameter

+ Description string

+ Name string

+ func (*Output) Descriptor() ([]byte, []int)

+ func (*Output) ProtoMessage()

+ func (m *Output) GetData() map[string]*Parameter

+ func (m *Output) GetDescription() string

+ func (m *Output) GetName() string

+ func (m *Output) Reset()

+ func (m *Output) String() string

+ type Parameter struct

+ Description string

+ Name string

+ Optional bool

+ Type string

+ func (*Parameter) Descriptor() ([]byte, []int)

+ func (*Parameter) ProtoMessage()

+ func (m *Parameter) GetDescription() string

+ func (m *Parameter) GetName() string

+ func (m *Parameter) GetOptional() bool

+ func (m *Parameter) GetType() string

+ func (m *Parameter) Reset()

+ func (m *Parameter) String() string

+ type Publish string

+ const PublishAll

+ const PublishContainer

+ const PublishNone

+ const PublishSource

+ type Service struct

+ Configuration *Dependency

+ Dependencies map[string]*Dependency

+ Description string

+ Events map[string]*Event

+ Name string

+ Publish string

+ Repository string

+ Tasks map[string]*Task

+ Visibility string

+ func ImportFromPath(path string) (service *Service, err error)

+ func (*Service) Descriptor() ([]byte, []int)

+ func (*Service) ProtoMessage()

+ func (m *Service) GetConfiguration() *Dependency

+ func (m *Service) GetDependencies() map[string]*Dependency

+ func (m *Service) GetDescription() string

+ func (m *Service) GetEvents() map[string]*Event

+ func (m *Service) GetName() string

+ func (m *Service) GetPublish() string

+ func (m *Service) GetRepository() string

+ func (m *Service) GetTasks() map[string]*Task

+ func (m *Service) GetVisibility() string

+ func (m *Service) Reset()

+ func (m *Service) String() string

+ func (s *Service) DependenciesFromService() (d []*DependencyFromService)

+ func (service *Service) EventSubscriptionChannel() string

+ func (service *Service) Hash() (hash string)

+ func (service *Service) Logs(onlyForDependency string) (readers []io.ReadCloser, err error)

+ func (service *Service) ResultSubscriptionChannel() string

+ func (service *Service) Start() (serviceIDs []string, err error)

+ func (service *Service) Status() (status StatusType, err error)

+ func (service *Service) Stop() (err error)

+ func (service *Service) StopDependencies() (err error)

+ func (service *Service) TaskSubscriptionChannel() string

+ type StatusType uint

+ const PARTIAL

+ const RUNNING

+ const STOPPED

+ type Task struct

+ Description string

+ Fees *Fee

+ Inputs map[string]*Parameter

+ Name string

+ Outputs map[string]*Output

+ Payable bool

+ Verifiable bool

+ func (*Task) Descriptor() ([]byte, []int)

+ func (*Task) ProtoMessage()

+ func (m *Task) GetDescription() string

+ func (m *Task) GetFees() *Fee

+ func (m *Task) GetInputs() map[string]*Parameter

+ func (m *Task) GetName() string

+ func (m *Task) GetOutputs() map[string]*Output

+ func (m *Task) GetPayable() bool

+ func (m *Task) GetVerifiable() bool

+ func (m *Task) Reset()

+ func (m *Task) String() string

+ type Visibility string

+ const VisibilityAll

+ const VisibilityNone

+ const VisibilityUsers

+ const VisibilityWorkers