coreapi

package
v0.10.1 Latest Latest
Warning

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

 Go to latest Published: Jun 14, 2019 License: Apache-2.0 Imports: 6 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.
	ExecuteTask(ctx context.Context, in *ExecuteTaskRequest, opts ...grpc.CallOption) (*ExecuteTaskReply, error)
	// Start a service. The service must be already deployed to Core.
	StartService(ctx context.Context, in *StartServiceRequest, opts ...grpc.CallOption) (*StartServiceReply, error)
	// Stop a service. The service must be already deployed to Core.
	StopService(ctx context.Context, in *StopServiceRequest, opts ...grpc.CallOption) (*StopServiceReply, error)
	// Deploy a service to Core. 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. 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.
	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)
	// Info returns all necessary information from the core.
	Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoReply, 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.
	ExecuteTask(context.Context, *ExecuteTaskRequest) (*ExecuteTaskReply, error)
	// Start a service. The service must be already deployed to Core.
	StartService(context.Context, *StartServiceRequest) (*StartServiceReply, error)
	// Stop a service. The service must be already deployed to Core.
	StopService(context.Context, *StopServiceRequest) (*StopServiceReply, error)
	// Deploy a service to Core. 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. 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.
	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
	// Info returns all necessary information from the core.
	Info(context.Context, *InfoRequest) (*InfoReply, 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"`
	DeleteData           bool     `protobuf:"varint,2,opt,name=deleteData,proto3" json:"deleteData,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) GetDeleteData added in v0.5.0 

func (m *DeleteServiceRequest) GetDeleteData() bool

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 DeployServiceReply 

type DeployServiceReply struct {
	// Types that are valid to be assigned to Value:
	//	*DeployServiceReply_Status_
	//	*DeployServiceReply_ValidationError
	//	*DeployServiceReply_Service_
	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) GetService added in v0.9.0 

func (m *DeployServiceReply) GetService() *DeployServiceReply_Service

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_Service added in v0.9.0 

type DeployServiceReply_Service struct {
	Sid                  string   `protobuf:"bytes,1,opt,name=sid,proto3" json:"sid,omitempty"`
	Hash                 string   `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeployServiceReply_Service) Descriptor added in v0.9.0 

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

func (*DeployServiceReply_Service) GetHash added in v0.9.0 

func (m *DeployServiceReply_Service) GetHash() string

func (*DeployServiceReply_Service) GetSid added in v0.9.0 

func (m *DeployServiceReply_Service) GetSid() string

func (*DeployServiceReply_Service) ProtoMessage added in v0.9.0 

func (*DeployServiceReply_Service) ProtoMessage()

func (*DeployServiceReply_Service) Reset added in v0.9.0 

func (m *DeployServiceReply_Service) Reset()

func (*DeployServiceReply_Service) String added in v0.9.0 

func (m *DeployServiceReply_Service) String() string

func (*DeployServiceReply_Service) XXX_DiscardUnknown added in v0.9.0 

func (m *DeployServiceReply_Service) XXX_DiscardUnknown()

func (*DeployServiceReply_Service) XXX_Marshal added in v0.9.0 

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

func (*DeployServiceReply_Service) XXX_Merge added in v0.9.0 

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

func (*DeployServiceReply_Service) XXX_Size added in v0.9.0 

func (m *DeployServiceReply_Service) XXX_Size() int

func (*DeployServiceReply_Service) XXX_Unmarshal added in v0.9.0 

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

type DeployServiceReply_Service_ added in v0.9.0 

type DeployServiceReply_Service_ struct {
	Service *DeployServiceReply_Service `protobuf:"bytes,5,opt,name=service,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"`
	Env                  map[string]string            `` /* 147-byte string literal not displayed */
	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 

{
  "env": {
    "key": "value"
  },
  "url": "__SERVICE_GIT_URL__"
}

``` or ```json 

{
  "env": {
    "key": "value"
  },
  "chunk": "__SERVICE_GZIPPED_TAR_FILE_CHUNK__"
}

```

func (*DeployServiceRequest) Descriptor 

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

func (*DeployServiceRequest) GetChunk 

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

func (*DeployServiceRequest) GetEnv added in v0.6.0 

func (m *DeployServiceRequest) GetEnv() map[string]string

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 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 {
	ExecutionHash        string   `protobuf:"bytes,1,opt,name=executionHash,proto3" json:"executionHash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

**Example** ```json 

{
  "executionHash": "__EXECUTION_HASH__"
}

```

func (*ExecuteTaskReply) Descriptor 

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

func (*ExecuteTaskReply) GetExecutionHash added in v0.10.0 

func (m *ExecuteTaskReply) GetExecutionHash() 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": {
    "definition": {
      "dependencies": [{
        "image": "sha256:dfb1b6be0001c2f64822917ee8462585e43941376db887b83167413230117af9",
        "key": "service"
      }],
      "description": "Description of my service",
      "events": [{
        "data": [{
          "key": "x",
          "type": "Boolean"
        }],
        "key": "started"
      }],
      "hash": "e8de3872762ec68f22a82ddeecac49d07cef17dbf7f2dbdb1c97f36d7cfce91a",
      "name": "myservice",
      "sid": "myservice",
      "tasks": [{
        "inputs": [{
            "key": "bar",
            "type": "String"
          },
          {
            "key": "foo",
            "type": "String"
          }
        ],
        "key": "taskX",
        "outputs": [{
            "data": [{
              "key": "error",
              "type": "String"
            }],
            "key": "error"
          },
          {
            "data": [{
              "key": "message",
              "type": "String"
            }],
            "key": "success"
          }
        ]
      }]
    },
    "status": 1
  }
}

```

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 InfoReply added in v0.9.0 

type InfoReply struct {
	Services             []*InfoReply_CoreService `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	Version              string                   `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

Information concerning the Core from the `info` API.

func (*InfoReply) Descriptor added in v0.9.0 

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

func (*InfoReply) GetServices added in v0.9.0 

func (m *InfoReply) GetServices() []*InfoReply_CoreService

func (*InfoReply) GetVersion added in v0.9.0 

func (m *InfoReply) GetVersion() string

func (*InfoReply) ProtoMessage added in v0.9.0 

func (*InfoReply) ProtoMessage()

func (*InfoReply) Reset added in v0.9.0 

func (m *InfoReply) Reset()

func (*InfoReply) String added in v0.9.0 

func (m *InfoReply) String() string

func (*InfoReply) XXX_DiscardUnknown added in v0.9.0 

func (m *InfoReply) XXX_DiscardUnknown()

func (*InfoReply) XXX_Marshal added in v0.9.0 

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

func (*InfoReply) XXX_Merge added in v0.9.0 

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

func (*InfoReply) XXX_Size added in v0.9.0 

func (m *InfoReply) XXX_Size() int

func (*InfoReply) XXX_Unmarshal added in v0.9.0 

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

type InfoReply_CoreService added in v0.9.0 

type InfoReply_CoreService struct {
	Sid                  string   `protobuf:"bytes,1,opt,name=sid,proto3" json:"sid,omitempty"`
	Hash                 string   `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	Url                  string   `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	Key                  string   `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InfoReply_CoreService) Descriptor added in v0.9.0 

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

func (*InfoReply_CoreService) GetHash added in v0.9.0 

func (m *InfoReply_CoreService) GetHash() string

func (*InfoReply_CoreService) GetKey added in v0.9.0 

func (m *InfoReply_CoreService) GetKey() string

func (*InfoReply_CoreService) GetSid added in v0.9.0 

func (m *InfoReply_CoreService) GetSid() string

func (*InfoReply_CoreService) GetUrl added in v0.9.0 

func (m *InfoReply_CoreService) GetUrl() string

func (*InfoReply_CoreService) ProtoMessage added in v0.9.0 

func (*InfoReply_CoreService) ProtoMessage()

func (*InfoReply_CoreService) Reset added in v0.9.0 

func (m *InfoReply_CoreService) Reset()

func (*InfoReply_CoreService) String added in v0.9.0 

func (m *InfoReply_CoreService) String() string

func (*InfoReply_CoreService) XXX_DiscardUnknown added in v0.9.0 

func (m *InfoReply_CoreService) XXX_DiscardUnknown()

func (*InfoReply_CoreService) XXX_Marshal added in v0.9.0 

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

func (*InfoReply_CoreService) XXX_Merge added in v0.9.0 

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

func (*InfoReply_CoreService) XXX_Size added in v0.9.0 

func (m *InfoReply_CoreService) XXX_Size() int

func (*InfoReply_CoreService) XXX_Unmarshal added in v0.9.0 

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

type InfoRequest added in v0.9.0 

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

The request to fetch all informations of the Core

func (*InfoRequest) Descriptor added in v0.9.0 

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

func (*InfoRequest) ProtoMessage added in v0.9.0 

func (*InfoRequest) ProtoMessage()

func (*InfoRequest) Reset added in v0.9.0 

func (m *InfoRequest) Reset()

func (*InfoRequest) String added in v0.9.0 

func (m *InfoRequest) String() string

func (*InfoRequest) XXX_DiscardUnknown added in v0.9.0 

func (m *InfoRequest) XXX_DiscardUnknown()

func (*InfoRequest) XXX_Marshal added in v0.9.0 

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

func (*InfoRequest) XXX_Merge added in v0.9.0 

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

func (*InfoRequest) XXX_Size added in v0.9.0 

func (m *InfoRequest) XXX_Size() int

func (*InfoRequest) XXX_Unmarshal added in v0.9.0 

func (m *InfoRequest) 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": [{
    "definition": {
      "dependencies": [{
        "image": "sha256:dfb1b6be0001c2f64822917ee8462585e43941376db887b83167413230117af9",
        "key": "service"
      }],
      "description": "Description of my service",
      "events": [{
        "data": [{
          "key": "x",
          "type": "Boolean"
        }],
        "key": "started"
      }],
      "hash": "e8de3872762ec68f22a82ddeecac49d07cef17dbf7f2dbdb1c97f36d7cfce91a",
      "name": "myservice",
      "sid": "myservice",
      "tasks": [{
        "inputs": [{
            "key": "bar",
            "type": "String"
          },
          {
            "key": "foo",
            "type": "String"
          }
        ],
        "key": "taskX",
        "outputs": [{
            "data": [{
              "key": "error",
              "type": "String"
            }],
            "key": "error"
          },
          {
            "data": [{
              "key": "message",
              "type": "String"
            }],
            "key": "success"
          }
        ]
      }]
    },
    "status": 1
  }]
}

```

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"`
	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__",
  "tagFilters":     ["tagX"]
}

```

func (*ListenResultRequest) Descriptor 

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

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 ResultData 

type ResultData struct {
	ExecutionHash        string   `protobuf:"bytes,1,opt,name=executionHash,proto3" json:"executionHash,omitempty"`
	TaskKey              string   `protobuf:"bytes,2,opt,name=taskKey,proto3" json:"taskKey,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"`
	Error                string   `protobuf:"bytes,6,opt,name=error,proto3" json:"error,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 

{
  "executionHash":   "__EXECUTION_HASH__",
  "taskKey":       "__TASK_KEY__",
  "outputData":    "{\"foo\":\"bar\"}",
  "executionTags": ["executionX", "test"],
  "error":         "error from the execution if something went wrong",
}

```

func (*ResultData) Descriptor 

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

func (*ResultData) GetError added in v0.6.0 

func (m *ResultData) GetError() string

func (*ResultData) GetExecutionHash added in v0.10.0 

func (m *ResultData) GetExecutionHash() string

func (*ResultData) GetExecutionTags 

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

func (*ResultData) GetOutputData 

func (m *ResultData) GetOutputData() 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 {
	Status               Service_Status      `protobuf:"varint,1,opt,name=status,proto3,enum=api.Service_Status" json:"status,omitempty"`
	Definition           *definition.Service `protobuf:"bytes,2,opt,name=definition,proto3" json:"definition,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

Service return all information related to the service

func (*Service) Descriptor 

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

func (*Service) GetDefinition added in v0.9.0 

func (m *Service) GetDefinition() *definition.Service

func (*Service) GetStatus 

func (m *Service) GetStatus() Service_Status

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

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.