coreapi

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Nov 2, 2018 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DeployServiceReply_Status_Type_name = map[int32]string{
	0: "RUNNING",
	1: "DONE_POSITIVE",
	2: "DONE_NEGATIVE",
}
View Source 
var DeployServiceReply_Status_Type_value = map[string]int32{
	"RUNNING":       0,
	"DONE_POSITIVE": 1,
	"DONE_NEGATIVE": 2,
}
View Source 
var LogData_Type_name = map[int32]string{
	0: "Standard",
	1: "Error",
}
View Source 
var LogData_Type_value = map[string]int32{
	"Standard": 0,
	"Error":    1,
}
View Source 
var Service_Status_name = map[int32]string{
	0: "UNKNOWN",
	1: "STOPPED",
	2: "STARTING",
	3: "PARTIAL",
	4: "RUNNING",
}
View Source 
var Service_Status_value = map[string]int32{
	"UNKNOWN":  0,
	"STOPPED":  1,
	"STARTING": 2,
	"PARTIAL":  3,
	"RUNNING":  4,
}

Functions

func RegisterCoreServer 

func RegisterCoreServer(s *grpc.Server, srv CoreServer)

Types

type CoreClient 

type CoreClient interface {
	// Subscribe to a stream that listens for events from a service.
	ListenEvent(ctx context.Context, in *ListenEventRequest, opts ...grpc.CallOption) (Core_ListenEventClient, error)
	// Subscribe to a stream that listens for task's result from a service.
	ListenResult(ctx context.Context, in *ListenResultRequest, opts ...grpc.CallOption) (Core_ListenResultClient, error)
	// Execute a service's task through [Core](../guide/start-here/core.md).
	ExecuteTask(ctx context.Context, in *ExecuteTaskRequest, opts ...grpc.CallOption) (*ExecuteTaskReply, error)
	// Start a service. The service must be already deployed to [Core](../guide/start-here/core.md).
	StartService(ctx context.Context, in *StartServiceRequest, opts ...grpc.CallOption) (*StartServiceReply, error)
	// Stop a service. The service must be already deployed to [Core](../guide/start-here/core.md).
	StopService(ctx context.Context, in *StopServiceRequest, opts ...grpc.CallOption) (*StopServiceReply, error)
	// Deploy a service to [Core](../guide/start-here/core.md). This will give you an unique identifier which is used to interact with the service.
	DeployService(ctx context.Context, opts ...grpc.CallOption) (Core_DeployServiceClient, error)
	// Delete a service from Core. This function only deletes a deployed service in [Core](../guide/start-here/core.md). If the service's code is on your computer, the source code will not be deleted.
	DeleteService(ctx context.Context, in *DeleteServiceRequest, opts ...grpc.CallOption) (*DeleteServiceReply, error)
	// List all services already deployed in [Core](../guide/start-here/core.md).
	ListServices(ctx context.Context, in *ListServicesRequest, opts ...grpc.CallOption) (*ListServicesReply, error)
	// Get the definition of an already-deployed service from its ID.
	GetService(ctx context.Context, in *GetServiceRequest, opts ...grpc.CallOption) (*GetServiceReply, error)
	// ServiceLogs gives a stream for dependency logs of a service.
	ServiceLogs(ctx context.Context, in *ServiceLogsRequest, opts ...grpc.CallOption) (Core_ServiceLogsClient, error)
}

CoreClient is the client API for Core service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewCoreClient 

func NewCoreClient(cc *grpc.ClientConn) CoreClient

type CoreServer 

type CoreServer interface {
	// Subscribe to a stream that listens for events from a service.
	ListenEvent(*ListenEventRequest, Core_ListenEventServer) error
	// Subscribe to a stream that listens for task's result from a service.
	ListenResult(*ListenResultRequest, Core_ListenResultServer) error
	// Execute a service's task through [Core](../guide/start-here/core.md).
	ExecuteTask(context.Context, *ExecuteTaskRequest) (*ExecuteTaskReply, error)
	// Start a service. The service must be already deployed to [Core](../guide/start-here/core.md).
	StartService(context.Context, *StartServiceRequest) (*StartServiceReply, error)
	// Stop a service. The service must be already deployed to [Core](../guide/start-here/core.md).
	StopService(context.Context, *StopServiceRequest) (*StopServiceReply, error)
	// Deploy a service to [Core](../guide/start-here/core.md). This will give you an unique identifier which is used to interact with the service.
	DeployService(Core_DeployServiceServer) error
	// Delete a service from Core. This function only deletes a deployed service in [Core](../guide/start-here/core.md). If the service's code is on your computer, the source code will not be deleted.
	DeleteService(context.Context, *DeleteServiceRequest) (*DeleteServiceReply, error)
	// List all services already deployed in [Core](../guide/start-here/core.md).
	ListServices(context.Context, *ListServicesRequest) (*ListServicesReply, error)
	// Get the definition of an already-deployed service from its ID.
	GetService(context.Context, *GetServiceRequest) (*GetServiceReply, error)
	// ServiceLogs gives a stream for dependency logs of a service.
	ServiceLogs(*ServiceLogsRequest, Core_ServiceLogsServer) error
}

CoreServer is the server API for Core service.

type Core_DeployServiceClient 

type Core_DeployServiceClient interface {
	Send(*DeployServiceRequest) error
	Recv() (*DeployServiceReply, error)
	grpc.ClientStream
}

type Core_DeployServiceServer 

type Core_DeployServiceServer interface {
	Send(*DeployServiceReply) error
	Recv() (*DeployServiceRequest, error)
	grpc.ServerStream
}

type Core_ListenEventClient 

type Core_ListenEventClient interface {
	Recv() (*EventData, error)
	grpc.ClientStream
}

type Core_ListenEventServer 

type Core_ListenEventServer interface {
	Send(*EventData) error
	grpc.ServerStream
}

type Core_ListenResultClient 

type Core_ListenResultClient interface {
	Recv() (*ResultData, error)
	grpc.ClientStream
}

type Core_ListenResultServer 

type Core_ListenResultServer interface {
	Send(*ResultData) error
	grpc.ServerStream
}

type Core_ServiceLogsClient 

type Core_ServiceLogsClient interface {
	Recv() (*LogData, error)
	grpc.ClientStream
}

type Core_ServiceLogsServer 

type Core_ServiceLogsServer interface {
	Send(*LogData) error
	grpc.ServerStream
}

type DeleteServiceReply 

type DeleteServiceReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Reply of `DeleteService` API doesn't contain any data.

func (*DeleteServiceReply) Descriptor 

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

func (*DeleteServiceReply) ProtoMessage 

func (*DeleteServiceReply) ProtoMessage()

func (*DeleteServiceReply) Reset 

func (m *DeleteServiceReply) Reset()

func (*DeleteServiceReply) String 

func (m *DeleteServiceReply) String() string

func (*DeleteServiceReply) XXX_DiscardUnknown 

func (m *DeleteServiceReply) XXX_DiscardUnknown()

func (*DeleteServiceReply) XXX_Marshal 

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

func (*DeleteServiceReply) XXX_Merge 

func (dst *DeleteServiceReply) XXX_Merge(src proto.Message)

func (*DeleteServiceReply) XXX_Size 

func (m *DeleteServiceReply) XXX_Size() int

func (*DeleteServiceReply) XXX_Unmarshal 

func (m *DeleteServiceReply) XXX_Unmarshal(b []byte) error

type DeleteServiceRequest 

type DeleteServiceRequest struct {
	ServiceID            string   `protobuf:"bytes,1,opt,name=serviceID,proto3" json:"serviceID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Request's data of the `DeleteService` API.

**Example** ```json 

{
  "serviceID": "__SERVICE_ID__"
}

```

func (*DeleteServiceRequest) Descriptor 

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

func (*DeleteServiceRequest) GetServiceID 

func (m *DeleteServiceRequest) GetServiceID() string

func (*DeleteServiceRequest) ProtoMessage 

func (*DeleteServiceRequest) ProtoMessage()

func (*DeleteServiceRequest) Reset 

func (m *DeleteServiceRequest) Reset()

func (*DeleteServiceRequest) String 

func (m *DeleteServiceRequest) String() string

func (*DeleteServiceRequest) XXX_DiscardUnknown 

func (m *DeleteServiceRequest) XXX_DiscardUnknown()

func (*DeleteServiceRequest) XXX_Marshal 

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

func (*DeleteServiceRequest) XXX_Merge 

func (dst *DeleteServiceRequest) XXX_Merge(src proto.Message)

func (*DeleteServiceRequest) XXX_Size 

func (m *DeleteServiceRequest) XXX_Size() int

func (*DeleteServiceRequest) XXX_Unmarshal 

func (m *DeleteServiceRequest) XXX_Unmarshal(b []byte) error

type Dependency 

type Dependency struct {
	Key                  string   `protobuf:"bytes,8,opt,name=key,proto3" json:"key,omitempty"`
	Image                string   `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"`
	Volumes              []string `protobuf:"bytes,2,rep,name=volumes,proto3" json:"volumes,omitempty"`
	Volumesfrom          []string `protobuf:"bytes,3,rep,name=volumesfrom,proto3" json:"volumesfrom,omitempty"`
	Ports                []string `protobuf:"bytes,4,rep,name=ports,proto3" json:"ports,omitempty"`
	Command              string   `protobuf:"bytes,5,opt,name=command,proto3" json:"command,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A dependency is a configuration of an other Docker container that runs separately from the service.

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) GetKey 

func (m *Dependency) GetKey() 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) ProtoMessage 

func (*Dependency) ProtoMessage()

func (*Dependency) Reset 

func (m *Dependency) Reset()

func (*Dependency) String 

func (m *Dependency) String() string

func (*Dependency) XXX_DiscardUnknown 

func (m *Dependency) XXX_DiscardUnknown()

func (*Dependency) XXX_Marshal 

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

func (*Dependency) XXX_Merge 

func (dst *Dependency) XXX_Merge(src proto.Message)

func (*Dependency) XXX_Size 

func (m *Dependency) XXX_Size() int

func (*Dependency) XXX_Unmarshal 

func (m *Dependency) XXX_Unmarshal(b []byte) error

type DeployServiceReply 

type DeployServiceReply struct {
	// Types that are valid to be assigned to Value:
	//	*DeployServiceReply_Status_
	//	*DeployServiceReply_ServiceID
	//	*DeployServiceReply_ValidationError
	Value                isDeployServiceReply_Value `protobuf_oneof:"value"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

The data received from the reply stream of the `DeployService` API. Stream will be closed by server after deployment is done.

**Example** ```json 

{
  "status": {
    "message": "__STATUS_MESSAGE__",
    "type": "__STATUS_TYPE__",
  }
}

``` or ```json 

{
  "serviceID": "__SERVICE_ID__"
}

``` or ```json 

{
  "validationError": "__SERVICE_VALIDATION_ERROR__"
}

```

func (*DeployServiceReply) Descriptor 

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

func (*DeployServiceReply) GetServiceID 

func (m *DeployServiceReply) GetServiceID() string

func (*DeployServiceReply) GetStatus 

func (m *DeployServiceReply) GetStatus() *DeployServiceReply_Status

func (*DeployServiceReply) GetValidationError 

func (m *DeployServiceReply) GetValidationError() string

func (*DeployServiceReply) GetValue 

func (m *DeployServiceReply) GetValue() isDeployServiceReply_Value

func (*DeployServiceReply) ProtoMessage 

func (*DeployServiceReply) ProtoMessage()

func (*DeployServiceReply) Reset 

func (m *DeployServiceReply) Reset()

func (*DeployServiceReply) String 

func (m *DeployServiceReply) String() string

func (*DeployServiceReply) XXX_DiscardUnknown 

func (m *DeployServiceReply) XXX_DiscardUnknown()

func (*DeployServiceReply) XXX_Marshal 

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

func (*DeployServiceReply) XXX_Merge 

func (dst *DeployServiceReply) XXX_Merge(src proto.Message)

func (*DeployServiceReply) XXX_OneofFuncs 

func (*DeployServiceReply) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*DeployServiceReply) XXX_Size 

func (m *DeployServiceReply) XXX_Size() int

func (*DeployServiceReply) XXX_Unmarshal 

func (m *DeployServiceReply) XXX_Unmarshal(b []byte) error

type DeployServiceReply_ServiceID 

type DeployServiceReply_ServiceID struct {
	ServiceID string `protobuf:"bytes,3,opt,name=serviceID,proto3,oneof"`
}

type DeployServiceReply_Status 

type DeployServiceReply_Status struct {
	Message              string                         `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Type                 DeployServiceReply_Status_Type `protobuf:"varint,2,opt,name=type,proto3,enum=api.DeployServiceReply_Status_Type" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*DeployServiceReply_Status) Descriptor 

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

func (*DeployServiceReply_Status) GetMessage 

func (m *DeployServiceReply_Status) GetMessage() string

func (*DeployServiceReply_Status) GetType 

func (m *DeployServiceReply_Status) GetType() DeployServiceReply_Status_Type

func (*DeployServiceReply_Status) ProtoMessage 

func (*DeployServiceReply_Status) ProtoMessage()

func (*DeployServiceReply_Status) Reset 

func (m *DeployServiceReply_Status) Reset()

func (*DeployServiceReply_Status) String 

func (m *DeployServiceReply_Status) String() string

func (*DeployServiceReply_Status) XXX_DiscardUnknown 

func (m *DeployServiceReply_Status) XXX_DiscardUnknown()

func (*DeployServiceReply_Status) XXX_Marshal 

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

func (*DeployServiceReply_Status) XXX_Merge 

func (dst *DeployServiceReply_Status) XXX_Merge(src proto.Message)

func (*DeployServiceReply_Status) XXX_Size 

func (m *DeployServiceReply_Status) XXX_Size() int

func (*DeployServiceReply_Status) XXX_Unmarshal 

func (m *DeployServiceReply_Status) XXX_Unmarshal(b []byte) error

type DeployServiceReply_Status_ 

type DeployServiceReply_Status_ struct {
	Status *DeployServiceReply_Status `protobuf:"bytes,2,opt,name=status,proto3,oneof"`
}

type DeployServiceReply_Status_Type 

type DeployServiceReply_Status_Type int32
const (
	DeployServiceReply_Status_RUNNING       DeployServiceReply_Status_Type = 0
	DeployServiceReply_Status_DONE_POSITIVE DeployServiceReply_Status_Type = 1
	DeployServiceReply_Status_DONE_NEGATIVE DeployServiceReply_Status_Type = 2
)

func (DeployServiceReply_Status_Type) EnumDescriptor 

func (DeployServiceReply_Status_Type) EnumDescriptor() ([]byte, []int)

func (DeployServiceReply_Status_Type) String 

func (x DeployServiceReply_Status_Type) String() string

type DeployServiceReply_ValidationError 

type DeployServiceReply_ValidationError struct {
	ValidationError string `protobuf:"bytes,4,opt,name=validationError,proto3,oneof"`
}

type DeployServiceRequest 

type DeployServiceRequest struct {
	// Types that are valid to be assigned to Value:
	//	*DeployServiceRequest_Url
	//	*DeployServiceRequest_Chunk
	Value                isDeployServiceRequest_Value `protobuf_oneof:"value"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

The data sent to the request stream of the `DeployService` API. Stream should be closed after url or all chunks sent to server.

**Example** ```json 

{
  "url": "__SERVICE_GIT_URL__"
}

``` or ```json 

{
  "chunk": "__SERVICE_GZIPPED_TAR_FILE_CHUNK__"
}

```

func (*DeployServiceRequest) Descriptor 

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

func (*DeployServiceRequest) GetChunk 

func (m *DeployServiceRequest) GetChunk() []byte

func (*DeployServiceRequest) GetUrl 

func (m *DeployServiceRequest) GetUrl() string

func (*DeployServiceRequest) GetValue 

func (m *DeployServiceRequest) GetValue() isDeployServiceRequest_Value

func (*DeployServiceRequest) ProtoMessage 

func (*DeployServiceRequest) ProtoMessage()

func (*DeployServiceRequest) Reset 

func (m *DeployServiceRequest) Reset()

func (*DeployServiceRequest) String 

func (m *DeployServiceRequest) String() string

func (*DeployServiceRequest) XXX_DiscardUnknown 

func (m *DeployServiceRequest) XXX_DiscardUnknown()

func (*DeployServiceRequest) XXX_Marshal 

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

func (*DeployServiceRequest) XXX_Merge 

func (dst *DeployServiceRequest) XXX_Merge(src proto.Message)

func (*DeployServiceRequest) XXX_OneofFuncs 

func (*DeployServiceRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*DeployServiceRequest) XXX_Size 

func (m *DeployServiceRequest) XXX_Size() int

func (*DeployServiceRequest) XXX_Unmarshal 

func (m *DeployServiceRequest) XXX_Unmarshal(b []byte) error

type DeployServiceRequest_Chunk 

type DeployServiceRequest_Chunk struct {
	Chunk []byte `protobuf:"bytes,3,opt,name=chunk,proto3,oneof"`
}

type DeployServiceRequest_Url 

type DeployServiceRequest_Url struct {
	Url string `protobuf:"bytes,2,opt,name=url,proto3,oneof"`
}

type Event 

type Event struct {
	Key                  string       `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	Name                 string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description          string       `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Data                 []*Parameter `protobuf:"bytes,3,rep,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Events are emitted by the service whenever the service wants.

func (*Event) Descriptor 

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

func (*Event) GetData 

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

func (*Event) GetDescription 

func (m *Event) GetDescription() string

func (*Event) GetKey 

func (m *Event) GetKey() 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

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

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

func (*Event) XXX_Merge 

func (dst *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

func (m *Event) XXX_Unmarshal(b []byte) error

type EventData 

type EventData struct {
	EventKey             string   `protobuf:"bytes,1,opt,name=eventKey,proto3" json:"eventKey,omitempty"`
	EventData            string   `protobuf:"bytes,2,opt,name=eventData,proto3" json:"eventData,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The data received from the stream of the `ListenEvent` API. The data will be received over time as long as the stream is open.

**Example** ```json 

{
  "eventKey":  "__EVENT_KEY__",
  "eventData": "{\"foo\":\"bar\"}"
}

```

func (*EventData) Descriptor 

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

func (*EventData) GetEventData 

func (m *EventData) GetEventData() string

func (*EventData) GetEventKey 

func (m *EventData) GetEventKey() string

func (*EventData) ProtoMessage 

func (*EventData) ProtoMessage()

func (*EventData) Reset 

func (m *EventData) Reset()

func (*EventData) String 

func (m *EventData) String() string

func (*EventData) XXX_DiscardUnknown 

func (m *EventData) XXX_DiscardUnknown()

func (*EventData) XXX_Marshal 

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

func (*EventData) XXX_Merge 

func (dst *EventData) XXX_Merge(src proto.Message)

func (*EventData) XXX_Size 

func (m *EventData) XXX_Size() int

func (*EventData) XXX_Unmarshal 

func (m *EventData) XXX_Unmarshal(b []byte) error

type ExecuteTaskReply 

type ExecuteTaskReply struct {
	ExecutionID          string   `protobuf:"bytes,1,opt,name=executionID,proto3" json:"executionID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The reply's data of the `ExecuteTask` API.

**Example** ```json 

{
  "executionID": "__EXECUTION_ID__"
}

```

func (*ExecuteTaskReply) Descriptor 

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

func (*ExecuteTaskReply) GetExecutionID 

func (m *ExecuteTaskReply) GetExecutionID() string

func (*ExecuteTaskReply) ProtoMessage 

func (*ExecuteTaskReply) ProtoMessage()

func (*ExecuteTaskReply) Reset 

func (m *ExecuteTaskReply) Reset()

func (*ExecuteTaskReply) String 

func (m *ExecuteTaskReply) String() string

func (*ExecuteTaskReply) XXX_DiscardUnknown 

func (m *ExecuteTaskReply) XXX_DiscardUnknown()

func (*ExecuteTaskReply) XXX_Marshal 

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

func (*ExecuteTaskReply) XXX_Merge 

func (dst *ExecuteTaskReply) XXX_Merge(src proto.Message)

func (*ExecuteTaskReply) XXX_Size 

func (m *ExecuteTaskReply) XXX_Size() int

func (*ExecuteTaskReply) XXX_Unmarshal 

func (m *ExecuteTaskReply) XXX_Unmarshal(b []byte) error

type ExecuteTaskRequest 

type ExecuteTaskRequest struct {
	ServiceID            string   `protobuf:"bytes,1,opt,name=serviceID,proto3" json:"serviceID,omitempty"`
	TaskKey              string   `protobuf:"bytes,2,opt,name=taskKey,proto3" json:"taskKey,omitempty"`
	InputData            string   `protobuf:"bytes,3,opt,name=inputData,proto3" json:"inputData,omitempty"`
	ExecutionTags        []string `protobuf:"bytes,4,rep,name=executionTags,proto3" json:"executionTags,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The request's data for the `ExecuteTask` API.

**Example** ```json 

{
  "serviceID":     "__SERVICE_ID__",
  "taskKey":       "__TASK_KEY__",
  "inputData":     "{\"foo\":\"bar\"}",
  "executionTags": ["executionX", "test"]
}

```

func (*ExecuteTaskRequest) Descriptor 

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

func (*ExecuteTaskRequest) GetExecutionTags 

func (m *ExecuteTaskRequest) GetExecutionTags() []string

func (*ExecuteTaskRequest) GetInputData 

func (m *ExecuteTaskRequest) GetInputData() string

func (*ExecuteTaskRequest) GetServiceID 

func (m *ExecuteTaskRequest) GetServiceID() string

func (*ExecuteTaskRequest) GetTaskKey 

func (m *ExecuteTaskRequest) GetTaskKey() string

func (*ExecuteTaskRequest) ProtoMessage 

func (*ExecuteTaskRequest) ProtoMessage()

func (*ExecuteTaskRequest) Reset 

func (m *ExecuteTaskRequest) Reset()

func (*ExecuteTaskRequest) String 

func (m *ExecuteTaskRequest) String() string

func (*ExecuteTaskRequest) XXX_DiscardUnknown 

func (m *ExecuteTaskRequest) XXX_DiscardUnknown()

func (*ExecuteTaskRequest) XXX_Marshal 

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

func (*ExecuteTaskRequest) XXX_Merge 

func (dst *ExecuteTaskRequest) XXX_Merge(src proto.Message)

func (*ExecuteTaskRequest) XXX_Size 

func (m *ExecuteTaskRequest) XXX_Size() int

func (*ExecuteTaskRequest) XXX_Unmarshal 

func (m *ExecuteTaskRequest) XXX_Unmarshal(b []byte) error

type GetServiceReply 

type GetServiceReply struct {
	Service              *Service `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The reply's data of the `GetService` API.

**Example** ```json 

{
  "service": {
    "id": "idX",
    "name": "serviceX",
    "description": "descriptionX",
    "status": "statusX",
    "events": [{
      "key": "eventX",
      "name": "nameX",
      "description": "descriptionX",
      "data": [{
        "key": "dataX",
        "name": "nameX",
        "description": "descriptionX",
        "type": "String",
        "optional": true
      }]
    }],
    "tasks": [{
      "key": "taskX",
      "name": "nameX",
      "description": "descriptionX",
      "inputs": [{
        "key": "foo",
        "name": "nameX",
        "description": "descriptionX",
        "type": "String",
        "optional": true
      }],
      "outputs": [{
        "key": "outputX",
        "name": "nameX",
        "description": "descriptionX",
        "data": [{
          "key": "resX",
          "name": "nameX",
          "description": "descriptionX",
          "type": "String",
          "optional": false
        }]
      }]
    }]
  }
}

```

func (*GetServiceReply) Descriptor 

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

func (*GetServiceReply) GetService 

func (m *GetServiceReply) GetService() *Service

func (*GetServiceReply) ProtoMessage 

func (*GetServiceReply) ProtoMessage()

func (*GetServiceReply) Reset 

func (m *GetServiceReply) Reset()

func (*GetServiceReply) String 

func (m *GetServiceReply) String() string

func (*GetServiceReply) XXX_DiscardUnknown 

func (m *GetServiceReply) XXX_DiscardUnknown()

func (*GetServiceReply) XXX_Marshal 

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

func (*GetServiceReply) XXX_Merge 

func (dst *GetServiceReply) XXX_Merge(src proto.Message)

func (*GetServiceReply) XXX_Size 

func (m *GetServiceReply) XXX_Size() int

func (*GetServiceReply) XXX_Unmarshal 

func (m *GetServiceReply) XXX_Unmarshal(b []byte) error

type GetServiceRequest 

type GetServiceRequest struct {
	ServiceID            string   `protobuf:"bytes,1,opt,name=serviceID,proto3" json:"serviceID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The request's data for the `GetService` API.

**Example** ```json 

{
  "serviceID": "__SERVICE_ID__"
}

```

func (*GetServiceRequest) Descriptor 

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

func (*GetServiceRequest) GetServiceID 

func (m *GetServiceRequest) GetServiceID() string

func (*GetServiceRequest) ProtoMessage 

func (*GetServiceRequest) ProtoMessage()

func (*GetServiceRequest) Reset 

func (m *GetServiceRequest) Reset()

func (*GetServiceRequest) String 

func (m *GetServiceRequest) String() string

func (*GetServiceRequest) XXX_DiscardUnknown 

func (m *GetServiceRequest) XXX_DiscardUnknown()

func (*GetServiceRequest) XXX_Marshal 

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

func (*GetServiceRequest) XXX_Merge 

func (dst *GetServiceRequest) XXX_Merge(src proto.Message)

func (*GetServiceRequest) XXX_Size 

func (m *GetServiceRequest) XXX_Size() int

func (*GetServiceRequest) XXX_Unmarshal 

func (m *GetServiceRequest) XXX_Unmarshal(b []byte) error

type ListServicesReply 

type ListServicesReply struct {
	Services             []*Service `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

The reply's data of the `ListServices` API.

**Example** ```json 

{
  "services": [{
    "id": "idX",
    "name": "serviceX",
    "description": "descriptionX",
    "status": "statusX",
    "events": [{
      "key": "eventX",
      "name": "nameX",
      "description": "descriptionX",
      "data": [{
        "key": "dataX",
        "name": "nameX",
        "description": "descriptionX",
        "type": "String",
        "optional": true
      }]
    }],
    "tasks": [{
      "key": "taskX",
      "name": "nameX",
      "description": "descriptionX",
      "inputs": [{
        "key": "foo",
        "name": "nameX",
        "description": "descriptionX",
        "type": "String",
        "optional": true
      }],
      "outputs": [{
        "key": "outputX",
        "name": "nameX",
        "description": "descriptionX",
        "data": [{
          "key": "resX",
          "name": "nameX",
          "description": "descriptionX",
          "type": "String",
          "optional": false
        }]
      }]
    }]
  }]
}

```

func (*ListServicesReply) Descriptor 

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

func (*ListServicesReply) GetServices 

func (m *ListServicesReply) GetServices() []*Service

func (*ListServicesReply) ProtoMessage 

func (*ListServicesReply) ProtoMessage()

func (*ListServicesReply) Reset 

func (m *ListServicesReply) Reset()

func (*ListServicesReply) String 

func (m *ListServicesReply) String() string

func (*ListServicesReply) XXX_DiscardUnknown 

func (m *ListServicesReply) XXX_DiscardUnknown()

func (*ListServicesReply) XXX_Marshal 

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

func (*ListServicesReply) XXX_Merge 

func (dst *ListServicesReply) XXX_Merge(src proto.Message)

func (*ListServicesReply) XXX_Size 

func (m *ListServicesReply) XXX_Size() int

func (*ListServicesReply) XXX_Unmarshal 

func (m *ListServicesReply) XXX_Unmarshal(b []byte) error

type ListServicesRequest 

type ListServicesRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Reply of `ListServices` API doesn't contain any data.

func (*ListServicesRequest) Descriptor 

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

func (*ListServicesRequest) ProtoMessage 

func (*ListServicesRequest) ProtoMessage()

func (*ListServicesRequest) Reset 

func (m *ListServicesRequest) Reset()

func (*ListServicesRequest) String 

func (m *ListServicesRequest) String() string

func (*ListServicesRequest) XXX_DiscardUnknown 

func (m *ListServicesRequest) XXX_DiscardUnknown()

func (*ListServicesRequest) XXX_Marshal 

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

func (*ListServicesRequest) XXX_Merge 

func (dst *ListServicesRequest) XXX_Merge(src proto.Message)

func (*ListServicesRequest) XXX_Size 

func (m *ListServicesRequest) XXX_Size() int

func (*ListServicesRequest) XXX_Unmarshal 

func (m *ListServicesRequest) XXX_Unmarshal(b []byte) error

type ListenEventRequest 

type ListenEventRequest struct {
	ServiceID            string   `protobuf:"bytes,1,opt,name=serviceID,proto3" json:"serviceID,omitempty"`
	EventFilter          string   `protobuf:"bytes,2,opt,name=eventFilter,proto3" json:"eventFilter,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The request's data for the `ListenEvent` stream's API.

**Example** ```json 

{
  "serviceID":   "__SERVICE_ID__",
  "eventFilter": "__EVENT_KEY_TO_MATCH__"
}

```

func (*ListenEventRequest) Descriptor 

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

func (*ListenEventRequest) GetEventFilter 

func (m *ListenEventRequest) GetEventFilter() string

func (*ListenEventRequest) GetServiceID 

func (m *ListenEventRequest) GetServiceID() string

func (*ListenEventRequest) ProtoMessage 

func (*ListenEventRequest) ProtoMessage()

func (*ListenEventRequest) Reset 

func (m *ListenEventRequest) Reset()

func (*ListenEventRequest) String 

func (m *ListenEventRequest) String() string

func (*ListenEventRequest) XXX_DiscardUnknown 

func (m *ListenEventRequest) XXX_DiscardUnknown()

func (*ListenEventRequest) XXX_Marshal 

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

func (*ListenEventRequest) XXX_Merge 

func (dst *ListenEventRequest) XXX_Merge(src proto.Message)

func (*ListenEventRequest) XXX_Size 

func (m *ListenEventRequest) XXX_Size() int

func (*ListenEventRequest) XXX_Unmarshal 

func (m *ListenEventRequest) XXX_Unmarshal(b []byte) error

type ListenResultRequest 

type ListenResultRequest struct {
	ServiceID            string   `protobuf:"bytes,1,opt,name=serviceID,proto3" json:"serviceID,omitempty"`
	TaskFilter           string   `protobuf:"bytes,2,opt,name=taskFilter,proto3" json:"taskFilter,omitempty"`
	OutputFilter         string   `protobuf:"bytes,3,opt,name=outputFilter,proto3" json:"outputFilter,omitempty"`
	TagFilters           []string `protobuf:"bytes,4,rep,name=tagFilters,proto3" json:"tagFilters,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The request's data for the `ListenResult` stream API.

**Example** ```json 

{
  "serviceID":     "__SERVICE_ID__",
  "taskFilter":    "__TASK_KEY_TO_MATCH__",
  "outputFilter":  "__OUTPUT_KEY_TO_MATCH__",
  "tagFilters":     ["tagX"]
}

```

func (*ListenResultRequest) Descriptor 

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

func (*ListenResultRequest) GetOutputFilter 

func (m *ListenResultRequest) GetOutputFilter() string

func (*ListenResultRequest) GetServiceID 

func (m *ListenResultRequest) GetServiceID() string

func (*ListenResultRequest) GetTagFilters 

func (m *ListenResultRequest) GetTagFilters() []string

func (*ListenResultRequest) GetTaskFilter 

func (m *ListenResultRequest) GetTaskFilter() string

func (*ListenResultRequest) ProtoMessage 

func (*ListenResultRequest) ProtoMessage()

func (*ListenResultRequest) Reset 

func (m *ListenResultRequest) Reset()

func (*ListenResultRequest) String 

func (m *ListenResultRequest) String() string

func (*ListenResultRequest) XXX_DiscardUnknown 

func (m *ListenResultRequest) XXX_DiscardUnknown()

func (*ListenResultRequest) XXX_Marshal 

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

func (*ListenResultRequest) XXX_Merge 

func (dst *ListenResultRequest) XXX_Merge(src proto.Message)

func (*ListenResultRequest) XXX_Size 

func (m *ListenResultRequest) XXX_Size() int

func (*ListenResultRequest) XXX_Unmarshal 

func (m *ListenResultRequest) XXX_Unmarshal(b []byte) error

type LogData 

type LogData struct {
	Dependency           string       `protobuf:"bytes,1,opt,name=dependency,proto3" json:"dependency,omitempty"`
	Type                 LogData_Type `protobuf:"varint,2,opt,name=type,proto3,enum=api.LogData_Type" json:"type,omitempty"`
	Data                 []byte       `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

The data received from the stream of the `ServiceLogs` API. The data will be received over time as long as the stream is open.

**Example** ```json 

{
  "dependency":  "__SERVICE_DEPENDENCY__",
  "type": "__LOG_TYPE__",
  "data":  "__LOG_CHUNK__",
}

```

func (*LogData) Descriptor 

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

func (*LogData) GetData 

func (m *LogData) GetData() []byte

func (*LogData) GetDependency 

func (m *LogData) GetDependency() string

func (*LogData) GetType 

func (m *LogData) GetType() LogData_Type

func (*LogData) ProtoMessage 

func (*LogData) ProtoMessage()

func (*LogData) Reset 

func (m *LogData) Reset()

func (*LogData) String 

func (m *LogData) String() string

func (*LogData) XXX_DiscardUnknown 

func (m *LogData) XXX_DiscardUnknown()

func (*LogData) XXX_Marshal 

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

func (*LogData) XXX_Merge 

func (dst *LogData) XXX_Merge(src proto.Message)

func (*LogData) XXX_Size 

func (m *LogData) XXX_Size() int

func (*LogData) XXX_Unmarshal 

func (m *LogData) XXX_Unmarshal(b []byte) error

type LogData_Type 

type LogData_Type int32
const (
	LogData_Standard LogData_Type = 0
	LogData_Error    LogData_Type = 1
)

func (LogData_Type) EnumDescriptor 

func (LogData_Type) EnumDescriptor() ([]byte, []int)

func (LogData_Type) String 

func (x LogData_Type) String() string

type Output 

type Output struct {
	Key                  string       `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	Name                 string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description          string       `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Data                 []*Parameter `protobuf:"bytes,3,rep,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

A output is the data a task must return.

func (*Output) Descriptor 

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

func (*Output) GetData 

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

func (*Output) GetDescription 

func (m *Output) GetDescription() string

func (*Output) GetKey 

func (m *Output) GetKey() 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

func (*Output) XXX_DiscardUnknown 

func (m *Output) XXX_DiscardUnknown()

func (*Output) XXX_Marshal 

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

func (*Output) XXX_Merge 

func (dst *Output) XXX_Merge(src proto.Message)

func (*Output) XXX_Size 

func (m *Output) XXX_Size() int

func (*Output) XXX_Unmarshal 

func (m *Output) XXX_Unmarshal(b []byte) error

type Parameter 

type Parameter struct {
	Key                  string   `protobuf:"bytes,8,opt,name=key,proto3" json:"key,omitempty"`
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description          string   `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Type                 string   `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Optional             bool     `protobuf:"varint,4,opt,name=optional,proto3" json:"optional,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A parameter is the definition of a specific value.

func (*Parameter) Descriptor 

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

func (*Parameter) GetDescription 

func (m *Parameter) GetDescription() string

func (*Parameter) GetKey 

func (m *Parameter) GetKey() 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

func (*Parameter) XXX_DiscardUnknown 

func (m *Parameter) XXX_DiscardUnknown()

func (*Parameter) XXX_Marshal 

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

func (*Parameter) XXX_Merge 

func (dst *Parameter) XXX_Merge(src proto.Message)

func (*Parameter) XXX_Size 

func (m *Parameter) XXX_Size() int

func (*Parameter) XXX_Unmarshal 

func (m *Parameter) XXX_Unmarshal(b []byte) error

type ResultData 

type ResultData struct {
	ExecutionID          string   `protobuf:"bytes,1,opt,name=executionID,proto3" json:"executionID,omitempty"`
	TaskKey              string   `protobuf:"bytes,2,opt,name=taskKey,proto3" json:"taskKey,omitempty"`
	OutputKey            string   `protobuf:"bytes,3,opt,name=outputKey,proto3" json:"outputKey,omitempty"`
	OutputData           string   `protobuf:"bytes,4,opt,name=outputData,proto3" json:"outputData,omitempty"`
	ExecutionTags        []string `protobuf:"bytes,5,rep,name=executionTags,proto3" json:"executionTags,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The data received from the stream of the `ListenResult` API. The data will be received over time as long as the stream is open.

**Example** ```json 

{
  "executionID":   "__EXECUTION_ID__",
  "taskKey":       "__TASK_KEY__",
  "outputKey":     "__OUTPUT_KEY__",
  "outputData":    "{\"foo\":\"bar\"}",
  "executionTags": ["executionX", "test"]
}

```

func (*ResultData) Descriptor 

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

func (*ResultData) GetExecutionID 

func (m *ResultData) GetExecutionID() string

func (*ResultData) GetExecutionTags 

func (m *ResultData) GetExecutionTags() []string

func (*ResultData) GetOutputData 

func (m *ResultData) GetOutputData() string

func (*ResultData) GetOutputKey 

func (m *ResultData) GetOutputKey() string

func (*ResultData) GetTaskKey 

func (m *ResultData) GetTaskKey() string

func (*ResultData) ProtoMessage 

func (*ResultData) ProtoMessage()

func (*ResultData) Reset 

func (m *ResultData) Reset()

func (*ResultData) String 

func (m *ResultData) String() string

func (*ResultData) XXX_DiscardUnknown 

func (m *ResultData) XXX_DiscardUnknown()

func (*ResultData) XXX_Marshal 

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

func (*ResultData) XXX_Merge 

func (dst *ResultData) XXX_Merge(src proto.Message)

func (*ResultData) XXX_Size 

func (m *ResultData) XXX_Size() int

func (*ResultData) XXX_Unmarshal 

func (m *ResultData) XXX_Unmarshal(b []byte) error

type Service 

type Service struct {
	ID                   string         `protobuf:"bytes,10,opt,name=ID,proto3" json:"ID,omitempty"`
	Name                 string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description          string         `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Tasks                []*Task        `protobuf:"bytes,5,rep,name=tasks,proto3" json:"tasks,omitempty"`
	Events               []*Event       `protobuf:"bytes,6,rep,name=events,proto3" json:"events,omitempty"`
	Dependencies         []*Dependency  `protobuf:"bytes,7,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	Configuration        *Dependency    `protobuf:"bytes,8,opt,name=configuration,proto3" json:"configuration,omitempty"`
	Repository           string         `protobuf:"bytes,9,opt,name=repository,proto3" json:"repository,omitempty"`
	Status               Service_Status `protobuf:"varint,11,opt,name=status,proto3,enum=api.Service_Status" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

This is the definition of a MESG Service.

func (*Service) Descriptor 

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

func (*Service) GetConfiguration 

func (m *Service) GetConfiguration() *Dependency

func (*Service) GetDependencies 

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

func (*Service) GetDescription 

func (m *Service) GetDescription() string

func (*Service) GetEvents 

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

func (*Service) GetID 

func (m *Service) GetID() string

func (*Service) GetName 

func (m *Service) GetName() string

func (*Service) GetRepository 

func (m *Service) GetRepository() string

func (*Service) GetStatus 

func (m *Service) GetStatus() Service_Status

func (*Service) GetTasks 

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

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) Reset 

func (m *Service) Reset()

func (*Service) String 

func (m *Service) String() string

func (*Service) XXX_DiscardUnknown 

func (m *Service) XXX_DiscardUnknown()

func (*Service) XXX_Marshal 

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

func (*Service) XXX_Merge 

func (dst *Service) XXX_Merge(src proto.Message)

func (*Service) XXX_Size 

func (m *Service) XXX_Size() int

func (*Service) XXX_Unmarshal 

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

type ServiceLogsRequest 

type ServiceLogsRequest struct {
	ServiceID            string   `protobuf:"bytes,1,opt,name=serviceID,proto3" json:"serviceID,omitempty"`
	Dependencies         []string `protobuf:"bytes,2,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The request's data for `ServiceLogs` API.

**Example** ```json 

{
  "serviceID": "__SERVICE_ID__",
  "dependencies": ["__SERVICE_DEPENDENCY__"]
}

```

func (*ServiceLogsRequest) Descriptor 

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

func (*ServiceLogsRequest) GetDependencies 

func (m *ServiceLogsRequest) GetDependencies() []string

func (*ServiceLogsRequest) GetServiceID 

func (m *ServiceLogsRequest) GetServiceID() string

func (*ServiceLogsRequest) ProtoMessage 

func (*ServiceLogsRequest) ProtoMessage()

func (*ServiceLogsRequest) Reset 

func (m *ServiceLogsRequest) Reset()

func (*ServiceLogsRequest) String 

func (m *ServiceLogsRequest) String() string

func (*ServiceLogsRequest) XXX_DiscardUnknown 

func (m *ServiceLogsRequest) XXX_DiscardUnknown()

func (*ServiceLogsRequest) XXX_Marshal 

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

func (*ServiceLogsRequest) XXX_Merge 

func (dst *ServiceLogsRequest) XXX_Merge(src proto.Message)

func (*ServiceLogsRequest) XXX_Size 

func (m *ServiceLogsRequest) XXX_Size() int

func (*ServiceLogsRequest) XXX_Unmarshal 

func (m *ServiceLogsRequest) XXX_Unmarshal(b []byte) error

type Service_Status 

type Service_Status int32
const (
	Service_UNKNOWN  Service_Status = 0
	Service_STOPPED  Service_Status = 1
	Service_STARTING Service_Status = 2
	Service_PARTIAL  Service_Status = 3
	Service_RUNNING  Service_Status = 4
)

func (Service_Status) EnumDescriptor 

func (Service_Status) EnumDescriptor() ([]byte, []int)

func (Service_Status) String 

func (x Service_Status) String() string

type StartServiceReply 

type StartServiceReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Reply of `StartService` API doesn't contain any data.

func (*StartServiceReply) Descriptor 

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

func (*StartServiceReply) ProtoMessage 

func (*StartServiceReply) ProtoMessage()

func (*StartServiceReply) Reset 

func (m *StartServiceReply) Reset()

func (*StartServiceReply) String 

func (m *StartServiceReply) String() string

func (*StartServiceReply) XXX_DiscardUnknown 

func (m *StartServiceReply) XXX_DiscardUnknown()

func (*StartServiceReply) XXX_Marshal 

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

func (*StartServiceReply) XXX_Merge 

func (dst *StartServiceReply) XXX_Merge(src proto.Message)

func (*StartServiceReply) XXX_Size 

func (m *StartServiceReply) XXX_Size() int

func (*StartServiceReply) XXX_Unmarshal 

func (m *StartServiceReply) XXX_Unmarshal(b []byte) error

type StartServiceRequest 

type StartServiceRequest struct {
	ServiceID            string   `protobuf:"bytes,1,opt,name=serviceID,proto3" json:"serviceID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The request's data for the `StartService` API.

**Example** ```json 

{
  "serviceID": "__SERVICE_ID__"
}

```

func (*StartServiceRequest) Descriptor 

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

func (*StartServiceRequest) GetServiceID 

func (m *StartServiceRequest) GetServiceID() string

func (*StartServiceRequest) ProtoMessage 

func (*StartServiceRequest) ProtoMessage()

func (*StartServiceRequest) Reset 

func (m *StartServiceRequest) Reset()

func (*StartServiceRequest) String 

func (m *StartServiceRequest) String() string

func (*StartServiceRequest) XXX_DiscardUnknown 

func (m *StartServiceRequest) XXX_DiscardUnknown()

func (*StartServiceRequest) XXX_Marshal 

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

func (*StartServiceRequest) XXX_Merge 

func (dst *StartServiceRequest) XXX_Merge(src proto.Message)

func (*StartServiceRequest) XXX_Size 

func (m *StartServiceRequest) XXX_Size() int

func (*StartServiceRequest) XXX_Unmarshal 

func (m *StartServiceRequest) XXX_Unmarshal(b []byte) error

type StopServiceReply 

type StopServiceReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Reply of `StopService` API doesn't contain any data.

func (*StopServiceReply) Descriptor 

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

func (*StopServiceReply) ProtoMessage 

func (*StopServiceReply) ProtoMessage()

func (*StopServiceReply) Reset 

func (m *StopServiceReply) Reset()

func (*StopServiceReply) String 

func (m *StopServiceReply) String() string

func (*StopServiceReply) XXX_DiscardUnknown 

func (m *StopServiceReply) XXX_DiscardUnknown()

func (*StopServiceReply) XXX_Marshal 

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

func (*StopServiceReply) XXX_Merge 

func (dst *StopServiceReply) XXX_Merge(src proto.Message)

func (*StopServiceReply) XXX_Size 

func (m *StopServiceReply) XXX_Size() int

func (*StopServiceReply) XXX_Unmarshal 

func (m *StopServiceReply) XXX_Unmarshal(b []byte) error

type StopServiceRequest 

type StopServiceRequest struct {
	ServiceID            string   `protobuf:"bytes,1,opt,name=serviceID,proto3" json:"serviceID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The request's data for the `StopService` API.

**Example** ```json 

{
  "serviceID": "__SERVICE_ID__"
}

```

func (*StopServiceRequest) Descriptor 

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

func (*StopServiceRequest) GetServiceID 

func (m *StopServiceRequest) GetServiceID() string

func (*StopServiceRequest) ProtoMessage 

func (*StopServiceRequest) ProtoMessage()

func (*StopServiceRequest) Reset 

func (m *StopServiceRequest) Reset()

func (*StopServiceRequest) String 

func (m *StopServiceRequest) String() string

func (*StopServiceRequest) XXX_DiscardUnknown 

func (m *StopServiceRequest) XXX_DiscardUnknown()

func (*StopServiceRequest) XXX_Marshal 

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

func (*StopServiceRequest) XXX_Merge 

func (dst *StopServiceRequest) XXX_Merge(src proto.Message)

func (*StopServiceRequest) XXX_Size 

func (m *StopServiceRequest) XXX_Size() int

func (*StopServiceRequest) XXX_Unmarshal 

func (m *StopServiceRequest) XXX_Unmarshal(b []byte) error

type Task 

type Task struct {
	Key                  string       `protobuf:"bytes,8,opt,name=key,proto3" json:"key,omitempty"`
	Name                 string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description          string       `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Inputs               []*Parameter `protobuf:"bytes,6,rep,name=inputs,proto3" json:"inputs,omitempty"`
	Outputs              []*Output    `protobuf:"bytes,7,rep,name=outputs,proto3" json:"outputs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

A task is a function that requires inputs and returns output.

func (*Task) Descriptor 

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

func (*Task) GetDescription 

func (m *Task) GetDescription() string

func (*Task) GetInputs 

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

func (*Task) GetKey 

func (m *Task) GetKey() string

func (*Task) GetName 

func (m *Task) GetName() string

func (*Task) GetOutputs 

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

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) Reset 

func (m *Task) Reset()

func (*Task) String 

func (m *Task) String() string

func (*Task) XXX_DiscardUnknown 

func (m *Task) XXX_DiscardUnknown()

func (*Task) XXX_Marshal 

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

func (*Task) XXX_Merge 

func (dst *Task) XXX_Merge(src proto.Message)

func (*Task) XXX_Size 

func (m *Task) XXX_Size() int

func (*Task) XXX_Unmarshal 

func (m *Task) XXX_Unmarshal(b []byte) error

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.