Documentation ¶
Index ¶
- Variables
- func RegisterAgentServer(s grpc.ServiceRegistrar, srv AgentServer)
- type AgentClient
- type AgentServer
- type JobRequest
- func (*JobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *JobRequest) GetOperation() string
- func (x *JobRequest) GetPayload() *anypb.Any
- func (*JobRequest) ProtoMessage()
- func (x *JobRequest) ProtoReflect() protoreflect.Message
- func (x *JobRequest) Reset()
- func (x *JobRequest) String() string
- type JobResponse
- func (*JobResponse) Descriptor() ([]byte, []int)deprecated
- func (x *JobResponse) GetId() string
- func (x *JobResponse) GetRunID() string
- func (x *JobResponse) GetWorkflowName() string
- func (*JobResponse) ProtoMessage()
- func (x *JobResponse) ProtoReflect() protoreflect.Message
- func (x *JobResponse) Reset()
- func (x *JobResponse) String() string
- type UnimplementedAgentServer
- type UnsafeAgentServer
Constants ¶
This section is empty.
Variables ¶
var Agent_ServiceDesc = grpc.ServiceDesc{ ServiceName: "agentpb.Agent", HandlerType: (*AgentServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "SubmitJob", Handler: _Agent_SubmitJob_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "agent.proto", }
Agent_ServiceDesc is the grpc.ServiceDesc for Agent service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_agent_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAgentServer ¶
func RegisterAgentServer(s grpc.ServiceRegistrar, srv AgentServer)
Types ¶
type AgentClient ¶
type AgentClient interface {
SubmitJob(ctx context.Context, in *JobRequest, opts ...grpc.CallOption) (*JobResponse, error)
}
AgentClient is the client API for Agent service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewAgentClient ¶
func NewAgentClient(cc grpc.ClientConnInterface) AgentClient
type AgentServer ¶
type AgentServer interface { SubmitJob(context.Context, *JobRequest) (*JobResponse, error) // contains filtered or unexported methods }
AgentServer is the server API for Agent service. All implementations must embed UnimplementedAgentServer for forward compatibility
type JobRequest ¶
type JobRequest struct { Operation string `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` Payload *anypb.Any `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"` // contains filtered or unexported fields }
func (*JobRequest) Descriptor
deprecated
func (*JobRequest) Descriptor() ([]byte, []int)
Deprecated: Use JobRequest.ProtoReflect.Descriptor instead.
func (*JobRequest) GetOperation ¶
func (x *JobRequest) GetOperation() string
func (*JobRequest) GetPayload ¶
func (x *JobRequest) GetPayload() *anypb.Any
func (*JobRequest) ProtoMessage ¶
func (*JobRequest) ProtoMessage()
func (*JobRequest) ProtoReflect ¶
func (x *JobRequest) ProtoReflect() protoreflect.Message
func (*JobRequest) Reset ¶
func (x *JobRequest) Reset()
func (*JobRequest) String ¶
func (x *JobRequest) String() string
type JobResponse ¶
type JobResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` RunID string `protobuf:"bytes,2,opt,name=runID,proto3" json:"runID,omitempty"` WorkflowName string `protobuf:"bytes,3,opt,name=workflowName,proto3" json:"workflowName,omitempty"` // contains filtered or unexported fields }
func (*JobResponse) Descriptor
deprecated
func (*JobResponse) Descriptor() ([]byte, []int)
Deprecated: Use JobResponse.ProtoReflect.Descriptor instead.
func (*JobResponse) GetId ¶
func (x *JobResponse) GetId() string
func (*JobResponse) GetRunID ¶
func (x *JobResponse) GetRunID() string
func (*JobResponse) GetWorkflowName ¶
func (x *JobResponse) GetWorkflowName() string
func (*JobResponse) ProtoMessage ¶
func (*JobResponse) ProtoMessage()
func (*JobResponse) ProtoReflect ¶
func (x *JobResponse) ProtoReflect() protoreflect.Message
func (*JobResponse) Reset ¶
func (x *JobResponse) Reset()
func (*JobResponse) String ¶
func (x *JobResponse) String() string
type UnimplementedAgentServer ¶
type UnimplementedAgentServer struct { }
UnimplementedAgentServer must be embedded to have forward compatible implementations.
func (UnimplementedAgentServer) SubmitJob ¶
func (UnimplementedAgentServer) SubmitJob(context.Context, *JobRequest) (*JobResponse, error)
type UnsafeAgentServer ¶
type UnsafeAgentServer interface {
// contains filtered or unexported methods
}
UnsafeAgentServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AgentServer will result in compilation errors.