service

package
v0.1.0-beta Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 7, 2018 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Overview

Package service is a generated protocol buffer package.

It is generated from these files: 

github.com/mesg-foundation/core/service/service.proto

It has these top-level messages: 

Service
Task
Fee
Event
Output
Parameter
Dependency

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Asset 

func Asset(name string) ([]byte, error)

Asset loads and returns the asset for the given name. It returns an error if the asset could not be found or could not be loaded.

func AssetDir 

func AssetDir(name string) ([]string, error)

AssetDir returns the file names below a certain directory embedded in the file by go-bindata. For example if you run go-bindata on data/... and data contains the following hierarchy: 

data/
  foo.txt
  img/
    a.png
    b.png

then AssetDir("data") would return []string{"foo.txt", "img"} AssetDir("data/img") would return []string{"a.png", "b.png"} AssetDir("foo.txt") and AssetDir("notexist") would return an error AssetDir("") will return []string{"data"}.

func AssetInfo 

func AssetInfo(name string) (os.FileInfo, error)

AssetInfo loads and returns the asset info for the given name. It returns an error if the asset could not be found or could not be loaded.

func AssetNames 

func AssetNames() []string

AssetNames returns the names of the assets.

func List 

func List() (res []string, err error)

List all the running services hashes

func MustAsset 

func MustAsset(name string) []byte

MustAsset is like Asset but panics when Asset would return an error. It simplifies safe initialization of global variables.

func RestoreAsset 

func RestoreAsset(dir, name string) error

RestoreAsset restores an asset under the given directory

func RestoreAssets 

func RestoreAssets(dir, name string) error

RestoreAssets restores an asset under the given directory recursively

func ValidService 

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

ValidService validates a service at a given path

Types

type Dependency 

type Dependency struct {
	Image       string   `protobuf:"bytes,1,opt,name=image" json:"image,omitempty"`
	Volumes     []string `protobuf:"bytes,2,rep,name=volumes" json:"volumes,omitempty"`
	Volumesfrom []string `protobuf:"bytes,3,rep,name=volumesfrom" json:"volumesfrom,omitempty"`
	Ports       []string `protobuf:"bytes,4,rep,name=ports" json:"ports,omitempty"`
	Command     string   `protobuf:"bytes,5,opt,name=command" json:"command,omitempty"`
}

func (*Dependency) Descriptor 

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

func (*Dependency) GetCommand 

func (m *Dependency) GetCommand() string

func (*Dependency) GetImage 

func (m *Dependency) GetImage() string

func (*Dependency) GetPorts 

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

func (*Dependency) GetVolumes 

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

func (*Dependency) GetVolumesfrom 

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

func (*Dependency) IsRunning 

func (dependency *Dependency) IsRunning(namespace string, name string) (running bool)

IsRunning returns true if the dependency is running, false otherwise

func (*Dependency) IsStopped 

func (dependency *Dependency) IsStopped(namespace string, name string) (running bool)

IsStopped returns true if the dependency is stopped, false otherwise

func (*Dependency) ProtoMessage 

func (*Dependency) ProtoMessage()

func (*Dependency) Reset 

func (m *Dependency) Reset()

func (*Dependency) Start added in v0.3.0 

func (dependency *Dependency) Start(service *Service, details dependencyDetails, networkID string) (serviceID string, err error)

Start will start a dependency container

func (*Dependency) Stop added in v0.3.0 

func (dependency *Dependency) Stop(name string, dependencyName string) (err error)

Stop a dependency

func (*Dependency) String 

func (m *Dependency) String() string

type Event 

type Event struct {
	Name        string                `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Description string                `protobuf:"bytes,2,opt,name=description" json:"description,omitempty"`
	Data        map[string]*Parameter `` /* 128-byte string literal not displayed */
}

func (*Event) Descriptor 

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

func (*Event) GetData 

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

func (*Event) GetDescription 

func (m *Event) GetDescription() string

func (*Event) GetName 

func (m *Event) GetName() string

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) String 

func (m *Event) String() string

type Fee 

type Fee struct {
	Developer string `protobuf:"bytes,1,opt,name=developer" json:"developer,omitempty"`
	Validator string `protobuf:"bytes,2,opt,name=validator" json:"validator,omitempty"`
	Executor  string `protobuf:"bytes,3,opt,name=executor" json:"executor,omitempty"`
	Emittors  string `protobuf:"bytes,4,opt,name=emittors" json:"emittors,omitempty"`
}

func (*Fee) Descriptor 

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

func (*Fee) GetDeveloper 

func (m *Fee) GetDeveloper() string

func (*Fee) GetEmittors 

func (m *Fee) GetEmittors() string

func (*Fee) GetExecutor 

func (m *Fee) GetExecutor() string

func (*Fee) GetValidator 

func (m *Fee) GetValidator() string

func (*Fee) ProtoMessage 

func (*Fee) ProtoMessage()

func (*Fee) Reset 

func (m *Fee) Reset()

func (*Fee) String 

func (m *Fee) String() string

type Output 

type Output struct {
	Name        string                `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Description string                `protobuf:"bytes,2,opt,name=description" json:"description,omitempty"`
	Data        map[string]*Parameter `` /* 128-byte string literal not displayed */
}

func (*Output) Descriptor 

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

func (*Output) GetData 

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

func (*Output) GetDescription 

func (m *Output) GetDescription() string

func (*Output) GetName 

func (m *Output) GetName() string

func (*Output) ProtoMessage 

func (*Output) ProtoMessage()

func (*Output) Reset 

func (m *Output) Reset()

func (*Output) String 

func (m *Output) String() string

type Parameter 

type Parameter struct {
	Name        string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Description string `protobuf:"bytes,2,opt,name=description" json:"description,omitempty"`
	Type        string `protobuf:"bytes,3,opt,name=type" json:"type,omitempty"`
	Optional    bool   `protobuf:"varint,4,opt,name=optional" json:"optional,omitempty"`
}

func (*Parameter) Descriptor 

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

func (*Parameter) GetDescription 

func (m *Parameter) GetDescription() string

func (*Parameter) GetName 

func (m *Parameter) GetName() string

func (*Parameter) GetOptional 

func (m *Parameter) GetOptional() bool

func (*Parameter) GetType 

func (m *Parameter) GetType() string

func (*Parameter) ProtoMessage 

func (*Parameter) ProtoMessage()

func (*Parameter) Reset 

func (m *Parameter) Reset()

func (*Parameter) String 

func (m *Parameter) String() string

type Publish 

type Publish string

Publish let you configure the part of your service you want to publish 

const (
	PublishAll       Publish = "ALL"
	PublishSource    Publish = "SOURCE"
	PublishContainer Publish = "CONTAINER"
	PublishNone      Publish = "NONE"
)

List of all publishes flags

type Service 

type Service struct {
	Name          string                 `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Description   string                 `protobuf:"bytes,2,opt,name=description" json:"description,omitempty"`
	Visibility    string                 `protobuf:"bytes,3,opt,name=visibility" json:"visibility,omitempty"`
	Publish       string                 `protobuf:"bytes,4,opt,name=publish" json:"publish,omitempty"`
	Tasks         map[string]*Task       `` /* 130-byte string literal not displayed */
	Events        map[string]*Event      `` /* 132-byte string literal not displayed */
	Dependencies  map[string]*Dependency `` /* 144-byte string literal not displayed */
	Configuration *Dependency            `protobuf:"bytes,8,opt,name=configuration" json:"configuration,omitempty"`
}

func ImportFromPath 

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

ImportFromPath returns the service of the given path

func (*Service) Descriptor 

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

func (*Service) EventSubscriptionChannel 

func (service *Service) EventSubscriptionChannel() string

EventSubscriptionChannel returns the channel to listen for events from this service

func (*Service) GetConfiguration 

func (m *Service) GetConfiguration() *Dependency

func (*Service) GetDependencies 

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

func (*Service) GetDescription 

func (m *Service) GetDescription() string

func (*Service) GetEvents 

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

func (*Service) GetName 

func (m *Service) GetName() string

func (*Service) GetPublish 

func (m *Service) GetPublish() string

func (*Service) GetTasks 

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

func (*Service) GetVisibility 

func (m *Service) GetVisibility() string

func (*Service) Hash 

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

Hash calculate and return the hash of the service

func (*Service) IsPartiallyRunning 

func (service *Service) IsPartiallyRunning() (running bool)

IsPartiallyRunning returns true if the service is running, false otherwise

func (*Service) IsRunning 

func (service *Service) IsRunning() (running bool)

IsRunning returns true if the service is running, false otherwise

func (*Service) IsStopped 

func (service *Service) IsStopped() (running bool)

IsStopped returns true if the service is stopped, false otherwise

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) Reset 

func (m *Service) Reset()

func (*Service) ResultSubscriptionChannel 

func (service *Service) ResultSubscriptionChannel() string

ResultSubscriptionChannel returns the channel to listen for tasks from this service

func (*Service) Start 

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

Start a service

func (*Service) Stop 

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

Stop a service

func (*Service) StopDependencies 

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

StopDependencies stops all dependencies

func (*Service) String 

func (m *Service) String() string

func (*Service) TaskSubscriptionChannel 

func (service *Service) TaskSubscriptionChannel() string

TaskSubscriptionChannel returns the channel to listen for tasks from this service

type StatusType 

type StatusType uint

StatusType of the service 

const (
	STOPPED StatusType = 0
	RUNNING StatusType = 1
	PARTIAL StatusType = 2
)

status for services

type Task 

type Task struct {
	Name        string                `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Description string                `protobuf:"bytes,2,opt,name=description" json:"description,omitempty"`
	Verifiable  bool                  `protobuf:"varint,3,opt,name=verifiable" json:"verifiable,omitempty"`
	Payable     bool                  `protobuf:"varint,4,opt,name=payable" json:"payable,omitempty"`
	Fees        *Fee                  `protobuf:"bytes,5,opt,name=fees" json:"fees,omitempty"`
	Inputs      map[string]*Parameter `` /* 132-byte string literal not displayed */
	Outputs     map[string]*Output    `` /* 134-byte string literal not displayed */
}

func (*Task) Descriptor 

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

func (*Task) GetDescription 

func (m *Task) GetDescription() string

func (*Task) GetFees 

func (m *Task) GetFees() *Fee

func (*Task) GetInputs 

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

func (*Task) GetName 

func (m *Task) GetName() string

func (*Task) GetOutputs 

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

func (*Task) GetPayable 

func (m *Task) GetPayable() bool

func (*Task) GetVerifiable 

func (m *Task) GetVerifiable() bool

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) Reset 

func (m *Task) Reset()

func (*Task) String 

func (m *Task) String() string

type Visibility 

type Visibility string

Visibility is the tags to set is the service is visible for whom 

const (
	VisibilityAll     Visibility = "ALL"
	VisibilityUsers   Visibility = "USERS"
	VisibilityWorkers Visibility = "WORKERS"
	VisibilityNone    Visibility = "NONE"
)

List of visibilities flags

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.