api

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

type CreateServiceResponse 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:"-"`
}

type ExecutionClient interface {
	// Get returns a single Execution specified in a request.
	Get(ctx context.Context, in *GetExecutionRequest, opts ...grpc.CallOption) (*definition.Execution, error)
	// Stream returns a stream of exeuction that satisfy createria
	// specified in a request.
	Stream(ctx context.Context, in *StreamExecutionRequest, opts ...grpc.CallOption) (Execution_StreamClient, error)
}

type ExecutionServer interface {
	// Get returns a single Execution specified in a request.
	Get(context.Context, *GetExecutionRequest) (*definition.Execution, error)
	// Stream returns a stream of exeuction that satisfy createria
	// specified in a request.
	Stream(*StreamExecutionRequest, Execution_StreamServer) error
}

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

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

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

type ServiceXClient interface {
	Create(ctx context.Context, in *CreateServiceRequest, opts ...grpc.CallOption) (*CreateServiceResponse, error)
}

type ServiceXServer interface {
	Create(context.Context, *CreateServiceRequest) (*CreateServiceResponse, error)
}

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:"-"`
}

type StreamExecutionRequest_Filter struct {
	// Status for filtering execution by status.
	// Note: to filter multiple statues or flags, eg:
	// Failed | Completed
	Status               definition.Status `protobuf:"varint,1,opt,name=status,proto3,enum=definition.Status" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}