Documentation ¶
Index ¶
- func RegisterExecutionServer(s *grpc.Server, srv ExecutionServer)
- func RegisterServiceXServer(s *grpc.Server, srv ServiceXServer)
- type CreateServiceRequest
- func (*CreateServiceRequest) Descriptor() ([]byte, []int)
- func (m *CreateServiceRequest) GetDefinition() *definition.Service
- func (*CreateServiceRequest) ProtoMessage()
- func (m *CreateServiceRequest) Reset()
- func (m *CreateServiceRequest) String() string
- func (m *CreateServiceRequest) XXX_DiscardUnknown()
- func (m *CreateServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *CreateServiceRequest) XXX_Merge(src proto.Message)
- func (m *CreateServiceRequest) XXX_Size() int
- func (m *CreateServiceRequest) XXX_Unmarshal(b []byte) error
- type CreateServiceResponse
- func (*CreateServiceResponse) Descriptor() ([]byte, []int)
- func (m *CreateServiceResponse) GetHash() string
- func (m *CreateServiceResponse) GetSid() string
- func (*CreateServiceResponse) ProtoMessage()
- func (m *CreateServiceResponse) Reset()
- func (m *CreateServiceResponse) String() string
- func (m *CreateServiceResponse) XXX_DiscardUnknown()
- func (m *CreateServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *CreateServiceResponse) XXX_Merge(src proto.Message)
- func (m *CreateServiceResponse) XXX_Size() int
- func (m *CreateServiceResponse) XXX_Unmarshal(b []byte) error
- type ExecutionClient
- type ExecutionServer
- type Execution_StreamClient
- type Execution_StreamServer
- type GetExecutionRequest
- func (*GetExecutionRequest) Descriptor() ([]byte, []int)
- func (m *GetExecutionRequest) GetHash() []byte
- func (*GetExecutionRequest) ProtoMessage()
- func (m *GetExecutionRequest) Reset()
- func (m *GetExecutionRequest) String() string
- func (m *GetExecutionRequest) XXX_DiscardUnknown()
- func (m *GetExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *GetExecutionRequest) XXX_Merge(src proto.Message)
- func (m *GetExecutionRequest) XXX_Size() int
- func (m *GetExecutionRequest) XXX_Unmarshal(b []byte) error
- type ServiceXClient
- type ServiceXServer
- type StreamExecutionRequest
- func (*StreamExecutionRequest) Descriptor() ([]byte, []int)
- func (m *StreamExecutionRequest) GetFilter() *StreamExecutionRequest_Filter
- func (*StreamExecutionRequest) ProtoMessage()
- func (m *StreamExecutionRequest) Reset()
- func (m *StreamExecutionRequest) String() string
- func (m *StreamExecutionRequest) XXX_DiscardUnknown()
- func (m *StreamExecutionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *StreamExecutionRequest) XXX_Merge(src proto.Message)
- func (m *StreamExecutionRequest) XXX_Size() int
- func (m *StreamExecutionRequest) XXX_Unmarshal(b []byte) error
- type StreamExecutionRequest_Filter
- func (*StreamExecutionRequest_Filter) Descriptor() ([]byte, []int)
- func (m *StreamExecutionRequest_Filter) GetStatus() definition.Status
- func (*StreamExecutionRequest_Filter) ProtoMessage()
- func (m *StreamExecutionRequest_Filter) Reset()
- func (m *StreamExecutionRequest_Filter) String() string
- func (m *StreamExecutionRequest_Filter) XXX_DiscardUnknown()
- func (m *StreamExecutionRequest_Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *StreamExecutionRequest_Filter) XXX_Merge(src proto.Message)
- func (m *StreamExecutionRequest_Filter) XXX_Size() int
- func (m *StreamExecutionRequest_Filter) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterExecutionServer ¶
func RegisterExecutionServer(s *grpc.Server, srv ExecutionServer)
func RegisterServiceXServer ¶
func RegisterServiceXServer(s *grpc.Server, srv ServiceXServer)
Types ¶
type CreateServiceRequest ¶
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:"-"` }
func (*CreateServiceRequest) Descriptor ¶
func (*CreateServiceRequest) Descriptor() ([]byte, []int)
func (*CreateServiceRequest) GetDefinition ¶
func (m *CreateServiceRequest) GetDefinition() *definition.Service
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 (dst *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 { 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 (*CreateServiceResponse) Descriptor ¶
func (*CreateServiceResponse) Descriptor() ([]byte, []int)
func (*CreateServiceResponse) GetHash ¶
func (m *CreateServiceResponse) GetHash() string
func (*CreateServiceResponse) GetSid ¶
func (m *CreateServiceResponse) GetSid() 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 (dst *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 ExecutionClient ¶
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) }
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 { // 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 }
ExecutionServer is the server API for Execution service.
type Execution_StreamClient ¶
type Execution_StreamClient interface { Recv() (*definition.Execution, error) grpc.ClientStream }
type Execution_StreamServer ¶
type Execution_StreamServer interface { Send(*definition.Execution) error grpc.ServerStream }
type GetExecutionRequest ¶
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:"-"` }
GetRequest defines request to retrive a single execution.
func (*GetExecutionRequest) Descriptor ¶
func (*GetExecutionRequest) Descriptor() ([]byte, []int)
func (*GetExecutionRequest) GetHash ¶
func (m *GetExecutionRequest) GetHash() []byte
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 (dst *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 ServiceXClient ¶
type ServiceXClient interface {
Create(ctx context.Context, in *CreateServiceRequest, opts ...grpc.CallOption) (*CreateServiceResponse, error)
}
ServiceXClient is the client API for ServiceX service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewServiceXClient ¶
func NewServiceXClient(cc *grpc.ClientConn) ServiceXClient
type ServiceXServer ¶
type ServiceXServer interface {
Create(context.Context, *CreateServiceRequest) (*CreateServiceResponse, error)
}
ServiceXServer is the server API for ServiceX service.
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:"-"` }
StreamRequest defines request to retrive 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 (dst *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 { // 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:"-"` }
Filter contains filtering cryteria.
func (*StreamExecutionRequest_Filter) Descriptor ¶
func (*StreamExecutionRequest_Filter) Descriptor() ([]byte, []int)
func (*StreamExecutionRequest_Filter) GetStatus ¶
func (m *StreamExecutionRequest_Filter) GetStatus() definition.Status
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 (dst *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