api

package
v0.12.0 Latest Latest
Warning

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

 Go to latest Published: Jul 30, 2019 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterEventServer 

func RegisterEventServer(s *grpc.Server, srv EventServer)

func RegisterExecutionServer 

func RegisterExecutionServer(s *grpc.Server, srv ExecutionServer)

func RegisterInstanceServer 

func RegisterInstanceServer(s *grpc.Server, srv InstanceServer)

func RegisterServiceServer 

func RegisterServiceServer(s *grpc.Server, srv ServiceServer)

Types

type CreateEventRequest 

type CreateEventRequest struct {
	// instanceHash is hash of instance that can proceed an execution.
	InstanceHash string `protobuf:"bytes,1,opt,name=instanceHash,proto3" json:"instanceHash,omitempty"`
	// key is the key of the event.
	Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// data is the data for the event.
	Data                 *_struct.Struct `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

CreateEventRequest defines request for execution update.

func (*CreateEventRequest) Descriptor 

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

func (*CreateEventRequest) GetData 

func (m *CreateEventRequest) GetData() *_struct.Struct

func (*CreateEventRequest) GetInstanceHash 

func (m *CreateEventRequest) GetInstanceHash() string

func (*CreateEventRequest) GetKey 

func (m *CreateEventRequest) GetKey() string

func (*CreateEventRequest) ProtoMessage 

func (*CreateEventRequest) ProtoMessage()

func (*CreateEventRequest) Reset 

func (m *CreateEventRequest) Reset()

func (*CreateEventRequest) String 

func (m *CreateEventRequest) String() string

func (*CreateEventRequest) XXX_DiscardUnknown 

func (m *CreateEventRequest) XXX_DiscardUnknown()

func (*CreateEventRequest) XXX_Marshal 

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

func (*CreateEventRequest) XXX_Merge 

func (m *CreateEventRequest) XXX_Merge(src proto.Message)

func (*CreateEventRequest) XXX_Size 

func (m *CreateEventRequest) XXX_Size() int

func (*CreateEventRequest) XXX_Unmarshal 

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

type CreateEventResponse 

type CreateEventResponse struct {
	// Hash represents event.
	Hash                 string   `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CreateEventResponse defines response for execution update.

func (*CreateEventResponse) Descriptor 

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

func (*CreateEventResponse) GetHash 

func (m *CreateEventResponse) GetHash() string

func (*CreateEventResponse) ProtoMessage 

func (*CreateEventResponse) ProtoMessage()

func (*CreateEventResponse) Reset 

func (m *CreateEventResponse) Reset()

func (*CreateEventResponse) String 

func (m *CreateEventResponse) String() string

func (*CreateEventResponse) XXX_DiscardUnknown 

func (m *CreateEventResponse) XXX_DiscardUnknown()

func (*CreateEventResponse) XXX_Marshal 

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

func (*CreateEventResponse) XXX_Merge 

func (m *CreateEventResponse) XXX_Merge(src proto.Message)

func (*CreateEventResponse) XXX_Size 

func (m *CreateEventResponse) XXX_Size() int

func (*CreateEventResponse) XXX_Unmarshal 

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

type CreateExecutionRequest 

type CreateExecutionRequest struct {
	InstanceHash         string          `protobuf:"bytes,1,opt,name=instanceHash,proto3" json:"instanceHash,omitempty"`
	TaskKey              string          `protobuf:"bytes,2,opt,name=taskKey,proto3" json:"taskKey,omitempty"`
	Inputs               *_struct.Struct `protobuf:"bytes,3,opt,name=inputs,proto3" json:"inputs,omitempty"`
	Tags                 []string        `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

CreateExecutionRequest defines request to create a single execution.

func (*CreateExecutionRequest) Descriptor 

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

func (*CreateExecutionRequest) GetInputs 

func (m *CreateExecutionRequest) GetInputs() *_struct.Struct

func (*CreateExecutionRequest) GetInstanceHash 

func (m *CreateExecutionRequest) GetInstanceHash() string

func (*CreateExecutionRequest) GetTags 

func (m *CreateExecutionRequest) GetTags() []string

func (*CreateExecutionRequest) GetTaskKey 

func (m *CreateExecutionRequest) GetTaskKey() string

func (*CreateExecutionRequest) ProtoMessage 

func (*CreateExecutionRequest) ProtoMessage()

func (*CreateExecutionRequest) Reset 

func (m *CreateExecutionRequest) Reset()

func (*CreateExecutionRequest) String 

func (m *CreateExecutionRequest) String() string

func (*CreateExecutionRequest) XXX_DiscardUnknown 

func (m *CreateExecutionRequest) XXX_DiscardUnknown()

func (*CreateExecutionRequest) XXX_Marshal 

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

func (*CreateExecutionRequest) XXX_Merge 

func (m *CreateExecutionRequest) XXX_Merge(src proto.Message)

func (*CreateExecutionRequest) XXX_Size 

func (m *CreateExecutionRequest) XXX_Size() int

func (*CreateExecutionRequest) XXX_Unmarshal 

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

type CreateExecutionResponse 

type CreateExecutionResponse struct {
	// Execution's hash.
	Hash                 string   `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CreateExecutionResponse defines response for execution creation.

func (*CreateExecutionResponse) Descriptor 

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

func (*CreateExecutionResponse) GetHash 

func (m *CreateExecutionResponse) GetHash() string

func (*CreateExecutionResponse) ProtoMessage 

func (*CreateExecutionResponse) ProtoMessage()

func (*CreateExecutionResponse) Reset 

func (m *CreateExecutionResponse) Reset()

func (*CreateExecutionResponse) String 

func (m *CreateExecutionResponse) String() string

func (*CreateExecutionResponse) XXX_DiscardUnknown 

func (m *CreateExecutionResponse) XXX_DiscardUnknown()

func (*CreateExecutionResponse) XXX_Marshal 

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

func (*CreateExecutionResponse) XXX_Merge 

func (m *CreateExecutionResponse) XXX_Merge(src proto.Message)

func (*CreateExecutionResponse) XXX_Size 

func (m *CreateExecutionResponse) XXX_Size() int

func (*CreateExecutionResponse) XXX_Unmarshal 

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

type CreateInstanceRequest 

type CreateInstanceRequest struct {
	// Service's hash.
	ServiceHash string `protobuf:"bytes,1,opt,name=serviceHash,proto3" json:"serviceHash,omitempty"`
	// Environmental variables to apply to the Instance.
	Env                  []string `protobuf:"bytes,2,rep,name=env,proto3" json:"env,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*CreateInstanceRequest) Descriptor 

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

func (*CreateInstanceRequest) GetEnv 

func (m *CreateInstanceRequest) GetEnv() []string

func (*CreateInstanceRequest) GetServiceHash 

func (m *CreateInstanceRequest) GetServiceHash() string

func (*CreateInstanceRequest) ProtoMessage 

func (*CreateInstanceRequest) ProtoMessage()

func (*CreateInstanceRequest) Reset 

func (m *CreateInstanceRequest) Reset()

func (*CreateInstanceRequest) String 

func (m *CreateInstanceRequest) String() string

func (*CreateInstanceRequest) XXX_DiscardUnknown 

func (m *CreateInstanceRequest) XXX_DiscardUnknown()

func (*CreateInstanceRequest) XXX_Marshal 

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

func (*CreateInstanceRequest) XXX_Merge 

func (m *CreateInstanceRequest) XXX_Merge(src proto.Message)

func (*CreateInstanceRequest) XXX_Size 

func (m *CreateInstanceRequest) XXX_Size() int

func (*CreateInstanceRequest) XXX_Unmarshal 

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

type CreateInstanceResponse 

type CreateInstanceResponse struct {
	// The instance's hash created.
	Hash                 string   `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The response's data for the `Create` API.

func (*CreateInstanceResponse) Descriptor 

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

func (*CreateInstanceResponse) GetHash 

func (m *CreateInstanceResponse) GetHash() string

func (*CreateInstanceResponse) ProtoMessage 

func (*CreateInstanceResponse) ProtoMessage()

func (*CreateInstanceResponse) Reset 

func (m *CreateInstanceResponse) Reset()

func (*CreateInstanceResponse) String 

func (m *CreateInstanceResponse) String() string

func (*CreateInstanceResponse) XXX_DiscardUnknown 

func (m *CreateInstanceResponse) XXX_DiscardUnknown()

func (*CreateInstanceResponse) XXX_Marshal 

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

func (*CreateInstanceResponse) XXX_Merge 

func (m *CreateInstanceResponse) XXX_Merge(src proto.Message)

func (*CreateInstanceResponse) XXX_Size 

func (m *CreateInstanceResponse) XXX_Size() int

func (*CreateInstanceResponse) XXX_Unmarshal 

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

type CreateServiceRequest 

type CreateServiceRequest struct {
	// Service's sid.
	Sid string `protobuf:"bytes,1,opt,name=sid,proto3" json:"sid,omitempty"`
	// Service's name.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Service's description.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Configurations related to the service
	Configuration *types.Service_Configuration `protobuf:"bytes,4,opt,name=configuration,proto3" json:"configuration,omitempty"`
	// The list of tasks this service can execute.
	Tasks []*types.Service_Task `protobuf:"bytes,5,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// The list of events this service can emit.
	Events []*types.Service_Event `protobuf:"bytes,6,rep,name=events,proto3" json:"events,omitempty"`
	// The container dependencies this service requires.
	Dependencies []*types.Service_Dependency `protobuf:"bytes,7,rep,name=dependencies,proto3" json:"dependencies,omitempty"`
	// Service's repository url.
	Repository string `protobuf:"bytes,8,opt,name=repository,proto3" json:"repository,omitempty"`
	// The hash id of service's source code on IPFS.
	Source string `protobuf:"bytes,9,opt,name=source,proto3" json:"source,omitempty"`
	// List of workflows associated to the service
	Workflows            []*types.Service_Workflow `protobuf:"bytes,10,rep,name=workflows,proto3" json:"workflows,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

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

func (*CreateServiceRequest) Descriptor 

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

func (*CreateServiceRequest) GetConfiguration 

func (m *CreateServiceRequest) GetConfiguration() *types.Service_Configuration

func (*CreateServiceRequest) GetDependencies 

func (m *CreateServiceRequest) GetDependencies() []*types.Service_Dependency

func (*CreateServiceRequest) GetDescription 

func (m *CreateServiceRequest) GetDescription() string

func (*CreateServiceRequest) GetEvents 

func (m *CreateServiceRequest) GetEvents() []*types.Service_Event

func (*CreateServiceRequest) GetName 

func (m *CreateServiceRequest) GetName() string

func (*CreateServiceRequest) GetRepository 

func (m *CreateServiceRequest) GetRepository() string

func (*CreateServiceRequest) GetSid 

func (m *CreateServiceRequest) GetSid() string

func (*CreateServiceRequest) GetSource 

func (m *CreateServiceRequest) GetSource() string

func (*CreateServiceRequest) GetTasks 

func (m *CreateServiceRequest) GetTasks() []*types.Service_Task

func (*CreateServiceRequest) GetWorkflows added in v0.12.0 

func (m *CreateServiceRequest) GetWorkflows() []*types.Service_Workflow

func (*CreateServiceRequest) ProtoMessage 

func (*CreateServiceRequest) ProtoMessage()

func (*CreateServiceRequest) Reset 

func (m *CreateServiceRequest) Reset()

func (*CreateServiceRequest) String 

func (m *CreateServiceRequest) String() string

func (*CreateServiceRequest) XXX_DiscardUnknown 

func (m *CreateServiceRequest) XXX_DiscardUnknown()

func (*CreateServiceRequest) XXX_Marshal 

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

func (*CreateServiceRequest) XXX_Merge 

func (m *CreateServiceRequest) XXX_Merge(src proto.Message)

func (*CreateServiceRequest) XXX_Size 

func (m *CreateServiceRequest) XXX_Size() int

func (*CreateServiceRequest) XXX_Unmarshal 

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

type CreateServiceResponse 

type CreateServiceResponse struct {
	// The service's hash created.
	Hash                 string   `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The response's data for the `Create` API.

func (*CreateServiceResponse) Descriptor 

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

func (*CreateServiceResponse) GetHash 

func (m *CreateServiceResponse) GetHash() string

func (*CreateServiceResponse) ProtoMessage 

func (*CreateServiceResponse) ProtoMessage()

func (*CreateServiceResponse) Reset 

func (m *CreateServiceResponse) Reset()

func (*CreateServiceResponse) String 

func (m *CreateServiceResponse) String() string

func (*CreateServiceResponse) XXX_DiscardUnknown 

func (m *CreateServiceResponse) XXX_DiscardUnknown()

func (*CreateServiceResponse) XXX_Marshal 

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

func (*CreateServiceResponse) XXX_Merge 

func (m *CreateServiceResponse) XXX_Merge(src proto.Message)

func (*CreateServiceResponse) XXX_Size 

func (m *CreateServiceResponse) XXX_Size() int

func (*CreateServiceResponse) XXX_Unmarshal 

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

type DeleteInstanceRequest 

type DeleteInstanceRequest struct {
	// Instance's hash
	Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	// If true, any persistent data (volumes) that belongs to the instance and its dependencies will also be deleted.
	DeleteData           bool     `protobuf:"varint,2,opt,name=deleteData,proto3" json:"deleteData,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*DeleteInstanceRequest) Descriptor 

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

func (*DeleteInstanceRequest) GetDeleteData 

func (m *DeleteInstanceRequest) GetDeleteData() bool

func (*DeleteInstanceRequest) GetHash 

func (m *DeleteInstanceRequest) GetHash() string

func (*DeleteInstanceRequest) ProtoMessage 

func (*DeleteInstanceRequest) ProtoMessage()

func (*DeleteInstanceRequest) Reset 

func (m *DeleteInstanceRequest) Reset()

func (*DeleteInstanceRequest) String 

func (m *DeleteInstanceRequest) String() string

func (*DeleteInstanceRequest) XXX_DiscardUnknown 

func (m *DeleteInstanceRequest) XXX_DiscardUnknown()

func (*DeleteInstanceRequest) XXX_Marshal 

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

func (*DeleteInstanceRequest) XXX_Merge 

func (m *DeleteInstanceRequest) XXX_Merge(src proto.Message)

func (*DeleteInstanceRequest) XXX_Size 

func (m *DeleteInstanceRequest) XXX_Size() int

func (*DeleteInstanceRequest) XXX_Unmarshal 

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

type DeleteInstanceResponse 

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

The response's data for the `Delete` API.

func (*DeleteInstanceResponse) Descriptor 

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

func (*DeleteInstanceResponse) ProtoMessage 

func (*DeleteInstanceResponse) ProtoMessage()

func (*DeleteInstanceResponse) Reset 

func (m *DeleteInstanceResponse) Reset()

func (*DeleteInstanceResponse) String 

func (m *DeleteInstanceResponse) String() string

func (*DeleteInstanceResponse) XXX_DiscardUnknown 

func (m *DeleteInstanceResponse) XXX_DiscardUnknown()

func (*DeleteInstanceResponse) XXX_Marshal 

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

func (*DeleteInstanceResponse) XXX_Merge 

func (m *DeleteInstanceResponse) XXX_Merge(src proto.Message)

func (*DeleteInstanceResponse) XXX_Size 

func (m *DeleteInstanceResponse) XXX_Size() int

func (*DeleteInstanceResponse) XXX_Unmarshal 

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

type DeleteServiceRequest 

type DeleteServiceRequest struct {
	// The service's hash to delete.
	Hash                 string   `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*DeleteServiceRequest) Descriptor 

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

func (*DeleteServiceRequest) GetHash 

func (m *DeleteServiceRequest) GetHash() 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 (m *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 DeleteServiceResponse 

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

The response's data for the `Delete` API, doesn't contain anything.

func (*DeleteServiceResponse) Descriptor 

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

func (*DeleteServiceResponse) ProtoMessage 

func (*DeleteServiceResponse) ProtoMessage()

func (*DeleteServiceResponse) Reset 

func (m *DeleteServiceResponse) Reset()

func (*DeleteServiceResponse) String 

func (m *DeleteServiceResponse) String() string

func (*DeleteServiceResponse) XXX_DiscardUnknown 

func (m *DeleteServiceResponse) XXX_DiscardUnknown()

func (*DeleteServiceResponse) XXX_Marshal 

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

func (*DeleteServiceResponse) XXX_Merge 

func (m *DeleteServiceResponse) XXX_Merge(src proto.Message)

func (*DeleteServiceResponse) XXX_Size 

func (m *DeleteServiceResponse) XXX_Size() int

func (*DeleteServiceResponse) XXX_Unmarshal 

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

type EventClient 

type EventClient interface {
	// Create creates event with data.
	Create(ctx context.Context, in *CreateEventRequest, opts ...grpc.CallOption) (*CreateEventResponse, error)
	// Stream returns a stream of events that satisfy criteria
	// specified in a request.
	Stream(ctx context.Context, in *StreamEventRequest, opts ...grpc.CallOption) (Event_StreamClient, error)
}

EventClient is the client API for Event service.

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

func NewEventClient 

func NewEventClient(cc *grpc.ClientConn) EventClient

type EventServer 

type EventServer interface {
	// Create creates event with data.
	Create(context.Context, *CreateEventRequest) (*CreateEventResponse, error)
	// Stream returns a stream of events that satisfy criteria
	// specified in a request.
	Stream(*StreamEventRequest, Event_StreamServer) error
}

EventServer is the server API for Event service.

type Event_StreamClient 

type Event_StreamClient interface {
	Recv() (*types.Event, error)
	grpc.ClientStream
}

type Event_StreamServer 

type Event_StreamServer interface {
	Send(*types.Event) error
	grpc.ServerStream
}

type ExecutionClient 

type ExecutionClient interface {
	// Create creates a single Execution specified in a request.
	Create(ctx context.Context, in *CreateExecutionRequest, opts ...grpc.CallOption) (*CreateExecutionResponse, error)
	// Get returns a single Execution specified in a request.
	Get(ctx context.Context, in *GetExecutionRequest, opts ...grpc.CallOption) (*types.Execution, error)
	// Stream returns a stream of executions that satisfy criteria
	// specified in a request.
	Stream(ctx context.Context, in *StreamExecutionRequest, opts ...grpc.CallOption) (Execution_StreamClient, error)
	// Update updates execution with outputs or an error.
	Update(ctx context.Context, in *UpdateExecutionRequest, opts ...grpc.CallOption) (*UpdateExecutionResponse, error)
}

ExecutionClient is the client API for Execution service.

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

func NewExecutionClient 

func NewExecutionClient(cc *grpc.ClientConn) ExecutionClient

type ExecutionServer 

type ExecutionServer interface {
	// Create creates a single Execution specified in a request.
	Create(context.Context, *CreateExecutionRequest) (*CreateExecutionResponse, error)
	// Get returns a single Execution specified in a request.
	Get(context.Context, *GetExecutionRequest) (*types.Execution, error)
	// Stream returns a stream of executions that satisfy criteria
	// specified in a request.
	Stream(*StreamExecutionRequest, Execution_StreamServer) error
	// Update updates execution with outputs or an error.
	Update(context.Context, *UpdateExecutionRequest) (*UpdateExecutionResponse, error)
}

ExecutionServer is the server API for Execution service.

type Execution_StreamClient 

type Execution_StreamClient interface {
	Recv() (*types.Execution, error)
	grpc.ClientStream
}

type Execution_StreamServer 

type Execution_StreamServer interface {
	Send(*types.Execution) error
	grpc.ServerStream
}

type GetExecutionRequest 

type GetExecutionRequest struct {
	// Execution's hash to fetch.
	Hash                 string   `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetExecutionRequest defines request to retrieve a single execution.

func (*GetExecutionRequest) Descriptor 

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

func (*GetExecutionRequest) GetHash 

func (m *GetExecutionRequest) GetHash() string

func (*GetExecutionRequest) ProtoMessage 

func (*GetExecutionRequest) ProtoMessage()

func (*GetExecutionRequest) Reset 

func (m *GetExecutionRequest) Reset()

func (*GetExecutionRequest) String 

func (m *GetExecutionRequest) String() string

func (*GetExecutionRequest) XXX_DiscardUnknown 

func (m *GetExecutionRequest) XXX_DiscardUnknown()

func (*GetExecutionRequest) XXX_Marshal 

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

func (*GetExecutionRequest) XXX_Merge 

func (m *GetExecutionRequest) XXX_Merge(src proto.Message)

func (*GetExecutionRequest) XXX_Size 

func (m *GetExecutionRequest) XXX_Size() int

func (*GetExecutionRequest) XXX_Unmarshal 

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

type GetInstanceRequest 

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

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

func (*GetInstanceRequest) Descriptor 

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

func (*GetInstanceRequest) GetHash 

func (m *GetInstanceRequest) GetHash() string

func (*GetInstanceRequest) ProtoMessage 

func (*GetInstanceRequest) ProtoMessage()

func (*GetInstanceRequest) Reset 

func (m *GetInstanceRequest) Reset()

func (*GetInstanceRequest) String 

func (m *GetInstanceRequest) String() string

func (*GetInstanceRequest) XXX_DiscardUnknown 

func (m *GetInstanceRequest) XXX_DiscardUnknown()

func (*GetInstanceRequest) XXX_Marshal 

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

func (*GetInstanceRequest) XXX_Merge 

func (m *GetInstanceRequest) XXX_Merge(src proto.Message)

func (*GetInstanceRequest) XXX_Size 

func (m *GetInstanceRequest) XXX_Size() int

func (*GetInstanceRequest) XXX_Unmarshal 

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

type GetServiceRequest 

type GetServiceRequest struct {
	// The service's hash to fetch.
	Hash                 string   `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*GetServiceRequest) Descriptor 

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

func (*GetServiceRequest) GetHash 

func (m *GetServiceRequest) GetHash() 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 (m *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 InstanceClient 

type InstanceClient interface {
	// Get returns an Instance matching the criteria of the request.
	Get(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*types.Instance, error)
	// List returns all Instances matching the criteria of the request.
	List(ctx context.Context, in *ListInstancesRequest, opts ...grpc.CallOption) (*ListInstancesResponse, error)
	// Create an Instance from a Service's hash and custom environmental variables.
	// It will return an unique identifier which is used to interact with the Instance.
	Create(ctx context.Context, in *CreateInstanceRequest, opts ...grpc.CallOption) (*CreateInstanceResponse, error)
	// Delete an Instance.
	Delete(ctx context.Context, in *DeleteInstanceRequest, opts ...grpc.CallOption) (*DeleteInstanceResponse, error)
}

InstanceClient is the client API for Instance service.

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

func NewInstanceClient 

func NewInstanceClient(cc *grpc.ClientConn) InstanceClient

type InstanceServer 

type InstanceServer interface {
	// Get returns an Instance matching the criteria of the request.
	Get(context.Context, *GetInstanceRequest) (*types.Instance, error)
	// List returns all Instances matching the criteria of the request.
	List(context.Context, *ListInstancesRequest) (*ListInstancesResponse, error)
	// Create an Instance from a Service's hash and custom environmental variables.
	// It will return an unique identifier which is used to interact with the Instance.
	Create(context.Context, *CreateInstanceRequest) (*CreateInstanceResponse, error)
	// Delete an Instance.
	Delete(context.Context, *DeleteInstanceRequest) (*DeleteInstanceResponse, error)
}

InstanceServer is the server API for Instance service.

type ListInstancesRequest 

type ListInstancesRequest struct {
	// Filter by Services' hash.
	ServiceHash          string   `protobuf:"bytes,1,opt,name=serviceHash,proto3" json:"serviceHash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*ListInstancesRequest) Descriptor 

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

func (*ListInstancesRequest) GetServiceHash 

func (m *ListInstancesRequest) GetServiceHash() string

func (*ListInstancesRequest) ProtoMessage 

func (*ListInstancesRequest) ProtoMessage()

func (*ListInstancesRequest) Reset 

func (m *ListInstancesRequest) Reset()

func (*ListInstancesRequest) String 

func (m *ListInstancesRequest) String() string

func (*ListInstancesRequest) XXX_DiscardUnknown 

func (m *ListInstancesRequest) XXX_DiscardUnknown()

func (*ListInstancesRequest) XXX_Marshal 

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

func (*ListInstancesRequest) XXX_Merge 

func (m *ListInstancesRequest) XXX_Merge(src proto.Message)

func (*ListInstancesRequest) XXX_Size 

func (m *ListInstancesRequest) XXX_Size() int

func (*ListInstancesRequest) XXX_Unmarshal 

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

type ListInstancesResponse 

type ListInstancesResponse struct {
	// List of instances that match the request's filters.
	Instances            []*types.Instance `protobuf:"bytes,1,rep,name=instances,proto3" json:"instances,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

The response's data for the `List` API.

func (*ListInstancesResponse) Descriptor 

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

func (*ListInstancesResponse) GetInstances 

func (m *ListInstancesResponse) GetInstances() []*types.Instance

func (*ListInstancesResponse) ProtoMessage 

func (*ListInstancesResponse) ProtoMessage()

func (*ListInstancesResponse) Reset 

func (m *ListInstancesResponse) Reset()

func (*ListInstancesResponse) String 

func (m *ListInstancesResponse) String() string

func (*ListInstancesResponse) XXX_DiscardUnknown 

func (m *ListInstancesResponse) XXX_DiscardUnknown()

func (*ListInstancesResponse) XXX_Marshal 

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

func (*ListInstancesResponse) XXX_Merge 

func (m *ListInstancesResponse) XXX_Merge(src proto.Message)

func (*ListInstancesResponse) XXX_Size 

func (m *ListInstancesResponse) XXX_Size() int

func (*ListInstancesResponse) XXX_Unmarshal 

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

type ListServiceRequest 

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

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

func (*ListServiceRequest) Descriptor 

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

func (*ListServiceRequest) ProtoMessage 

func (*ListServiceRequest) ProtoMessage()

func (*ListServiceRequest) Reset 

func (m *ListServiceRequest) Reset()

func (*ListServiceRequest) String 

func (m *ListServiceRequest) String() string

func (*ListServiceRequest) XXX_DiscardUnknown 

func (m *ListServiceRequest) XXX_DiscardUnknown()

func (*ListServiceRequest) XXX_Marshal 

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

func (*ListServiceRequest) XXX_Merge 

func (m *ListServiceRequest) XXX_Merge(src proto.Message)

func (*ListServiceRequest) XXX_Size 

func (m *ListServiceRequest) XXX_Size() int

func (*ListServiceRequest) XXX_Unmarshal 

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

type ListServiceResponse 

type ListServiceResponse struct {
	// List of services that match the request's filters.
	Services             []*types.Service `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

The response's data for the `List` API.

func (*ListServiceResponse) Descriptor 

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

func (*ListServiceResponse) GetServices 

func (m *ListServiceResponse) GetServices() []*types.Service

func (*ListServiceResponse) ProtoMessage 

func (*ListServiceResponse) ProtoMessage()

func (*ListServiceResponse) Reset 

func (m *ListServiceResponse) Reset()

func (*ListServiceResponse) String 

func (m *ListServiceResponse) String() string

func (*ListServiceResponse) XXX_DiscardUnknown 

func (m *ListServiceResponse) XXX_DiscardUnknown()

func (*ListServiceResponse) XXX_Marshal 

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

func (*ListServiceResponse) XXX_Merge 

func (m *ListServiceResponse) XXX_Merge(src proto.Message)

func (*ListServiceResponse) XXX_Size 

func (m *ListServiceResponse) XXX_Size() int

func (*ListServiceResponse) XXX_Unmarshal 

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

type ServiceClient 

type ServiceClient interface {
	// Create a Service from a Service Definition.
	// It will return an unique identifier which is used to interact with the Service.
	Create(ctx context.Context, in *CreateServiceRequest, opts ...grpc.CallOption) (*CreateServiceResponse, error)
	// Delete a Service.
	// An error is returned if one or more Instances of the Service are running.
	Delete(ctx context.Context, in *DeleteServiceRequest, opts ...grpc.CallOption) (*DeleteServiceResponse, error)
	// Get returns a Service matching the criteria of the request.
	Get(ctx context.Context, in *GetServiceRequest, opts ...grpc.CallOption) (*types.Service, error)
	// List returns services specified in a request.
	List(ctx context.Context, in *ListServiceRequest, opts ...grpc.CallOption) (*ListServiceResponse, error)
}

ServiceClient is the client API for Service service.

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

func NewServiceClient 

func NewServiceClient(cc *grpc.ClientConn) ServiceClient

type ServiceServer 

type ServiceServer interface {
	// Create a Service from a Service Definition.
	// It will return an unique identifier which is used to interact with the Service.
	Create(context.Context, *CreateServiceRequest) (*CreateServiceResponse, error)
	// Delete a Service.
	// An error is returned if one or more Instances of the Service are running.
	Delete(context.Context, *DeleteServiceRequest) (*DeleteServiceResponse, error)
	// Get returns a Service matching the criteria of the request.
	Get(context.Context, *GetServiceRequest) (*types.Service, error)
	// List returns services specified in a request.
	List(context.Context, *ListServiceRequest) (*ListServiceResponse, error)
}

ServiceServer is the server API for Service service.

type StreamEventRequest 

type StreamEventRequest struct {
	// Filter used to filter a stream of events.
	Filter               *StreamEventRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

StreamEventRequest defines request to retrieve a stream of events.

func (*StreamEventRequest) Descriptor 

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

func (*StreamEventRequest) GetFilter 

func (m *StreamEventRequest) GetFilter() *StreamEventRequest_Filter

func (*StreamEventRequest) ProtoMessage 

func (*StreamEventRequest) ProtoMessage()

func (*StreamEventRequest) Reset 

func (m *StreamEventRequest) Reset()

func (*StreamEventRequest) String 

func (m *StreamEventRequest) String() string

func (*StreamEventRequest) XXX_DiscardUnknown 

func (m *StreamEventRequest) XXX_DiscardUnknown()

func (*StreamEventRequest) XXX_Marshal 

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

func (*StreamEventRequest) XXX_Merge 

func (m *StreamEventRequest) XXX_Merge(src proto.Message)

func (*StreamEventRequest) XXX_Size 

func (m *StreamEventRequest) XXX_Size() int

func (*StreamEventRequest) XXX_Unmarshal 

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

type StreamEventRequest_Filter 

type StreamEventRequest_Filter struct {
	// hash to filter events.
	Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	// instance's hash to filter events.
	InstanceHash string `protobuf:"bytes,2,opt,name=instanceHash,proto3" json:"instanceHash,omitempty"`
	// key is the key of the event.
	Key                  string   `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Filter contains filtering criteria.

func (*StreamEventRequest_Filter) Descriptor 

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

func (*StreamEventRequest_Filter) GetHash 

func (m *StreamEventRequest_Filter) GetHash() string

func (*StreamEventRequest_Filter) GetInstanceHash 

func (m *StreamEventRequest_Filter) GetInstanceHash() string

func (*StreamEventRequest_Filter) GetKey 

func (m *StreamEventRequest_Filter) GetKey() string

func (*StreamEventRequest_Filter) ProtoMessage 

func (*StreamEventRequest_Filter) ProtoMessage()

func (*StreamEventRequest_Filter) Reset 

func (m *StreamEventRequest_Filter) Reset()

func (*StreamEventRequest_Filter) String 

func (m *StreamEventRequest_Filter) String() string

func (*StreamEventRequest_Filter) XXX_DiscardUnknown 

func (m *StreamEventRequest_Filter) XXX_DiscardUnknown()

func (*StreamEventRequest_Filter) XXX_Marshal 

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

func (*StreamEventRequest_Filter) XXX_Merge 

func (m *StreamEventRequest_Filter) XXX_Merge(src proto.Message)

func (*StreamEventRequest_Filter) XXX_Size 

func (m *StreamEventRequest_Filter) XXX_Size() int

func (*StreamEventRequest_Filter) XXX_Unmarshal 

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

type StreamExecutionRequest 

type StreamExecutionRequest struct {
	// Filter used to filter a stream of executions.
	Filter               *StreamExecutionRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

StreamExecutionRequest defines request to retrieve a stream of executions.

func (*StreamExecutionRequest) Descriptor 

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

func (*StreamExecutionRequest) GetFilter 

func (m *StreamExecutionRequest) GetFilter() *StreamExecutionRequest_Filter

func (*StreamExecutionRequest) ProtoMessage 

func (*StreamExecutionRequest) ProtoMessage()

func (*StreamExecutionRequest) Reset 

func (m *StreamExecutionRequest) Reset()

func (*StreamExecutionRequest) String 

func (m *StreamExecutionRequest) String() string

func (*StreamExecutionRequest) XXX_DiscardUnknown 

func (m *StreamExecutionRequest) XXX_DiscardUnknown()

func (*StreamExecutionRequest) XXX_Marshal 

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

func (*StreamExecutionRequest) XXX_Merge 

func (m *StreamExecutionRequest) XXX_Merge(src proto.Message)

func (*StreamExecutionRequest) XXX_Size 

func (m *StreamExecutionRequest) XXX_Size() int

func (*StreamExecutionRequest) XXX_Unmarshal 

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

type StreamExecutionRequest_Filter 

type StreamExecutionRequest_Filter struct {
	// Statuses to filter executions. One status needs to be present in the execution.
	Statuses []types.Status `protobuf:"varint,1,rep,packed,name=statuses,proto3,enum=types.Status" json:"statuses,omitempty"`
	// Instance's hash to filter executions.
	InstanceHash string `protobuf:"bytes,2,opt,name=instanceHash,proto3" json:"instanceHash,omitempty"`
	// taskKey to filter executions.
	TaskKey string `protobuf:"bytes,3,opt,name=taskKey,proto3" json:"taskKey,omitempty"`
	// tags to filter executions. All tags needs to be present in the execution.
	Tags                 []string `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Filter contains filtering criteria.

func (*StreamExecutionRequest_Filter) Descriptor 

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

func (*StreamExecutionRequest_Filter) GetInstanceHash 

func (m *StreamExecutionRequest_Filter) GetInstanceHash() string

func (*StreamExecutionRequest_Filter) GetStatuses 

func (m *StreamExecutionRequest_Filter) GetStatuses() []types.Status

func (*StreamExecutionRequest_Filter) GetTags 

func (m *StreamExecutionRequest_Filter) GetTags() []string

func (*StreamExecutionRequest_Filter) GetTaskKey 

func (m *StreamExecutionRequest_Filter) GetTaskKey() string

func (*StreamExecutionRequest_Filter) ProtoMessage 

func (*StreamExecutionRequest_Filter) ProtoMessage()

func (*StreamExecutionRequest_Filter) Reset 

func (m *StreamExecutionRequest_Filter) Reset()

func (*StreamExecutionRequest_Filter) String 

func (m *StreamExecutionRequest_Filter) String() string

func (*StreamExecutionRequest_Filter) XXX_DiscardUnknown 

func (m *StreamExecutionRequest_Filter) XXX_DiscardUnknown()

func (*StreamExecutionRequest_Filter) XXX_Marshal 

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

func (*StreamExecutionRequest_Filter) XXX_Merge 

func (m *StreamExecutionRequest_Filter) XXX_Merge(src proto.Message)

func (*StreamExecutionRequest_Filter) XXX_Size 

func (m *StreamExecutionRequest_Filter) XXX_Size() int

func (*StreamExecutionRequest_Filter) XXX_Unmarshal 

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

type UpdateExecutionRequest 

type UpdateExecutionRequest struct {
	// Hash represents execution.
	Hash string `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	// result pass to execution
	//
	// Types that are valid to be assigned to Result:
	//	*UpdateExecutionRequest_Outputs
	//	*UpdateExecutionRequest_Error
	Result               isUpdateExecutionRequest_Result `protobuf_oneof:"result"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

UpdateExecutionRequest defines request for execution update.

func (*UpdateExecutionRequest) Descriptor 

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

func (*UpdateExecutionRequest) GetError 

func (m *UpdateExecutionRequest) GetError() string

func (*UpdateExecutionRequest) GetHash 

func (m *UpdateExecutionRequest) GetHash() string

func (*UpdateExecutionRequest) GetOutputs 

func (m *UpdateExecutionRequest) GetOutputs() *_struct.Struct

func (*UpdateExecutionRequest) GetResult 

func (m *UpdateExecutionRequest) GetResult() isUpdateExecutionRequest_Result

func (*UpdateExecutionRequest) ProtoMessage 

func (*UpdateExecutionRequest) ProtoMessage()

func (*UpdateExecutionRequest) Reset 

func (m *UpdateExecutionRequest) Reset()

func (*UpdateExecutionRequest) String 

func (m *UpdateExecutionRequest) String() string

func (*UpdateExecutionRequest) XXX_DiscardUnknown 

func (m *UpdateExecutionRequest) XXX_DiscardUnknown()

func (*UpdateExecutionRequest) XXX_Marshal 

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

func (*UpdateExecutionRequest) XXX_Merge 

func (m *UpdateExecutionRequest) XXX_Merge(src proto.Message)

func (*UpdateExecutionRequest) XXX_OneofWrappers 

func (*UpdateExecutionRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*UpdateExecutionRequest) XXX_Size 

func (m *UpdateExecutionRequest) XXX_Size() int

func (*UpdateExecutionRequest) XXX_Unmarshal 

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

type UpdateExecutionRequest_Error 

type UpdateExecutionRequest_Error struct {
	Error string `protobuf:"bytes,3,opt,name=error,proto3,oneof"`
}

type UpdateExecutionRequest_Outputs 

type UpdateExecutionRequest_Outputs struct {
	Outputs *_struct.Struct `protobuf:"bytes,2,opt,name=outputs,proto3,oneof"`
}

type UpdateExecutionResponse 

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

UpdateExecutionResponse defines response for execution update.

func (*UpdateExecutionResponse) Descriptor 

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

func (*UpdateExecutionResponse) ProtoMessage 

func (*UpdateExecutionResponse) ProtoMessage()

func (*UpdateExecutionResponse) Reset 

func (m *UpdateExecutionResponse) Reset()

func (*UpdateExecutionResponse) String 

func (m *UpdateExecutionResponse) String() string

func (*UpdateExecutionResponse) XXX_DiscardUnknown 

func (m *UpdateExecutionResponse) XXX_DiscardUnknown()

func (*UpdateExecutionResponse) XXX_Marshal 

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

func (*UpdateExecutionResponse) XXX_Merge 

func (m *UpdateExecutionResponse) XXX_Merge(src proto.Message)

func (*UpdateExecutionResponse) XXX_Size 

func (m *UpdateExecutionResponse) XXX_Size() int

func (*UpdateExecutionResponse) XXX_Unmarshal 

func (m *UpdateExecutionResponse) 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.