Documentation ¶
Overview ¶
Package protobuf is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Package protobuf is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Package protobuf is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func RegisterHealthCheckerHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterHealthCheckerHandlerClient(ctx context.Context, mux *runtime.ServeMux, client HealthCheckerClient) error
- func RegisterHealthCheckerHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterHealthCheckerHandlerServer(ctx context.Context, mux *runtime.ServeMux, server HealthCheckerServer) error
- func RegisterHealthCheckerServer(s grpc.ServiceRegistrar, srv HealthCheckerServer)
- func RegisterJobServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterJobServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client JobServiceClient) error
- func RegisterJobServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterJobServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server JobServiceServer) error
- func RegisterJobServiceServer(s grpc.ServiceRegistrar, srv JobServiceServer)
- func RegisterStepServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterStepServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client StepServiceClient) error
- func RegisterStepServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterStepServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server StepServiceServer) error
- func RegisterStepServiceServer(s grpc.ServiceRegistrar, srv StepServiceServer)
- type Cookie
- func (*Cookie) Descriptor() ([]byte, []int)deprecated
- func (x *Cookie) GetDomain() string
- func (x *Cookie) GetExpires() *timestamppb.Timestamp
- func (x *Cookie) GetHttpOnly() bool
- func (x *Cookie) GetMaxAge() int32
- func (x *Cookie) GetName() string
- func (x *Cookie) GetPath() string
- func (x *Cookie) GetRaw() string
- func (x *Cookie) GetRawExpires() string
- func (x *Cookie) GetSameSite() int32
- func (x *Cookie) GetSecure() bool
- func (x *Cookie) GetUnparsed() []string
- func (x *Cookie) GetValue() string
- func (*Cookie) ProtoMessage()
- func (x *Cookie) ProtoReflect() protoreflect.Message
- func (x *Cookie) Reset()
- func (x *Cookie) String() string
- type ForStepType
- type HealthCheckerClient
- type HealthCheckerServer
- type HealthCondition
- func (*HealthCondition) Descriptor() ([]byte, []int)deprecated
- func (x *HealthCondition) GetError() string
- func (x *HealthCondition) GetReason() string
- func (x *HealthCondition) GetStatus() HealthCondition_HealthStatus
- func (*HealthCondition) ProtoMessage()
- func (x *HealthCondition) ProtoReflect() protoreflect.Message
- func (x *HealthCondition) Reset()
- func (x *HealthCondition) String() string
- type HealthCondition_HealthStatus
- func (HealthCondition_HealthStatus) Descriptor() protoreflect.EnumDescriptor
- func (x HealthCondition_HealthStatus) Enum() *HealthCondition_HealthStatus
- func (HealthCondition_HealthStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x HealthCondition_HealthStatus) Number() protoreflect.EnumNumber
- func (x HealthCondition_HealthStatus) String() string
- func (HealthCondition_HealthStatus) Type() protoreflect.EnumType
- type HttpRequest
- func (*HttpRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HttpRequest) GetBody() []byte
- func (x *HttpRequest) GetHeaders() map[string]*ListOfString
- func (x *HttpRequest) GetMethod() string
- func (x *HttpRequest) GetParams() map[string]string
- func (x *HttpRequest) GetUrl() string
- func (*HttpRequest) ProtoMessage()
- func (x *HttpRequest) ProtoReflect() protoreflect.Message
- func (x *HttpRequest) Reset()
- func (x *HttpRequest) String() string
- type HttpResponse
- func (*HttpResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HttpResponse) GetBody() []byte
- func (x *HttpResponse) GetCompleteTime() *durationpb.Duration
- func (x *HttpResponse) GetCookies() []*Cookie
- func (x *HttpResponse) GetError() string
- func (x *HttpResponse) GetFistByteTime() *durationpb.Duration
- func (x *HttpResponse) GetHeaders() map[string]*ListOfString
- func (x *HttpResponse) GetStartTime() *timestamppb.Timestamp
- func (x *HttpResponse) GetStatus() int32
- func (*HttpResponse) ProtoMessage()
- func (x *HttpResponse) ProtoReflect() protoreflect.Message
- func (x *HttpResponse) Reset()
- func (x *HttpResponse) String() string
- type HttpsRequest
- func (*HttpsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HttpsRequest) GetBody() []byte
- func (x *HttpsRequest) GetCaCert() []byte
- func (x *HttpsRequest) GetCert() []byte
- func (x *HttpsRequest) GetHeaders() map[string]*ListOfString
- func (x *HttpsRequest) GetKey() []byte
- func (x *HttpsRequest) GetMethod() string
- func (x *HttpsRequest) GetParams() map[string]string
- func (x *HttpsRequest) GetSkipInsecureVerify() bool
- func (x *HttpsRequest) GetUrl() string
- func (*HttpsRequest) ProtoMessage()
- func (x *HttpsRequest) ProtoReflect() protoreflect.Message
- func (x *HttpsRequest) Reset()
- func (x *HttpsRequest) String() string
- type HttpsResponse
- func (*HttpsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HttpsResponse) GetBody() []byte
- func (x *HttpsResponse) GetCompleteTime() *durationpb.Duration
- func (x *HttpsResponse) GetCookies() []*Cookie
- func (x *HttpsResponse) GetError() string
- func (x *HttpsResponse) GetFistByteTime() *durationpb.Duration
- func (x *HttpsResponse) GetHeaders() map[string]*ListOfString
- func (x *HttpsResponse) GetStartTime() *timestamppb.Timestamp
- func (x *HttpsResponse) GetStatus() int32
- func (*HttpsResponse) ProtoMessage()
- func (x *HttpsResponse) ProtoReflect() protoreflect.Message
- func (x *HttpsResponse) Reset()
- func (x *HttpsResponse) String() string
- type IfStepType
- func (*IfStepType) Descriptor() ([]byte, []int)deprecated
- func (x *IfStepType) GetFalseStep() *Step
- func (x *IfStepType) GetScriptStep() *ScriptStepType
- func (x *IfStepType) GetTrueStep() *Step
- func (*IfStepType) ProtoMessage()
- func (x *IfStepType) ProtoReflect() protoreflect.Message
- func (x *IfStepType) Reset()
- func (x *IfStepType) String() string
- type JobProgress
- func (JobProgress) Descriptor() protoreflect.EnumDescriptor
- func (x JobProgress) Enum() *JobProgress
- func (JobProgress) EnumDescriptor() ([]byte, []int)deprecated
- func (x JobProgress) Number() protoreflect.EnumNumber
- func (x JobProgress) String() string
- func (JobProgress) Type() protoreflect.EnumType
- type JobResult
- type JobServiceClient
- type JobServiceServer
- type JobStatus
- func (*JobStatus) Descriptor() ([]byte, []int)deprecated
- func (x *JobStatus) GetProgress() JobProgress
- func (x *JobStatus) GetReason() string
- func (x *JobStatus) GetUuid() string
- func (*JobStatus) ProtoMessage()
- func (x *JobStatus) ProtoReflect() protoreflect.Message
- func (x *JobStatus) Reset()
- func (x *JobStatus) String() string
- type JobUuid
- type ListOfString
- type Request
- func (*Request) Descriptor() ([]byte, []int)deprecated
- func (x *Request) GetConcurrency() int32
- func (x *Request) GetHttpRequest() *HttpRequest
- func (x *Request) GetHttpsRequest() *HttpsRequest
- func (x *Request) GetRequestSchema() SchemaType
- func (x *Request) GetTimes() int32
- func (*Request) ProtoMessage()
- func (x *Request) ProtoReflect() protoreflect.Message
- func (x *Request) Reset()
- func (x *Request) String() string
- type RequestStepType
- type Response
- func (*Response) Descriptor() ([]byte, []int)deprecated
- func (x *Response) GetAllResponse() []*SingleResponse
- func (x *Response) GetResponseSchema() SchemaType
- func (x *Response) GetSuccessRequests() int32
- func (x *Response) GetTotalRequests() int32
- func (x *Response) GetTotalTime() *durationpb.Duration
- func (*Response) ProtoMessage()
- func (x *Response) ProtoReflect() protoreflect.Message
- func (x *Response) Reset()
- func (x *Response) String() string
- type SchemaType
- type ScriptStepType
- type SequenceStepType
- type SingleResponse
- func (*SingleResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SingleResponse) GetHttpResponse() *HttpResponse
- func (x *SingleResponse) GetHttpsResponse() *HttpsResponse
- func (*SingleResponse) ProtoMessage()
- func (x *SingleResponse) ProtoReflect() protoreflect.Message
- func (x *SingleResponse) Reset()
- func (x *SingleResponse) String() string
- type Step
- func (*Step) Descriptor() ([]byte, []int)deprecated
- func (x *Step) GetForStep() *ForStepType
- func (x *Step) GetIfStep() *IfStepType
- func (x *Step) GetRequestStep() *RequestStepType
- func (x *Step) GetScriptStep() *ScriptStepType
- func (x *Step) GetSequenceStep() *SequenceStepType
- func (x *Step) GetType() StepType
- func (*Step) ProtoMessage()
- func (x *Step) ProtoReflect() protoreflect.Message
- func (x *Step) Reset()
- func (x *Step) String() string
- type StepResult
- func (*StepResult) Descriptor() ([]byte, []int)deprecated
- func (x *StepResult) GetReason() string
- func (x *StepResult) GetResult() string
- func (x *StepResult) GetSubResult() []*StepResult
- func (x *StepResult) GetSuccess() bool
- func (*StepResult) ProtoMessage()
- func (x *StepResult) ProtoReflect() protoreflect.Message
- func (x *StepResult) Reset()
- func (x *StepResult) String() string
- type StepServiceClient
- type StepServiceServer
- type StepType
- type UnimplementedHealthCheckerServer
- type UnimplementedJobServiceServer
- func (UnimplementedJobServiceServer) CancelAJob(context.Context, *JobUuid) (*emptypb.Empty, error)
- func (UnimplementedJobServiceServer) CreateAJob(context.Context, *emptypb.Empty) (*JobUuid, error)
- func (UnimplementedJobServiceServer) GetJobResult(context.Context, *JobUuid) (*JobResult, error)
- func (UnimplementedJobServiceServer) StartAJob(context.Context, *UpdateJobContent) (*emptypb.Empty, error)
- type UnimplementedStepServiceServer
- type UnsafeHealthCheckerServer
- type UnsafeJobServiceServer
- type UnsafeStepServiceServer
- type UpdateJobContent
- func (*UpdateJobContent) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateJobContent) GetMainStep() *Step
- func (x *UpdateJobContent) GetUuid() *JobUuid
- func (*UpdateJobContent) ProtoMessage()
- func (x *UpdateJobContent) ProtoReflect() protoreflect.Message
- func (x *UpdateJobContent) Reset()
- func (x *UpdateJobContent) String() string
Constants ¶
This section is empty.
Variables ¶
var ( HealthCondition_HealthStatus_name = map[int32]string{ 0: "HEALTHY", 1: "UNHEALTHY", } HealthCondition_HealthStatus_value = map[string]int32{ "HEALTHY": 0, "UNHEALTHY": 1, } )
Enum value maps for HealthCondition_HealthStatus.
var ( JobProgress_name = map[int32]string{ 0: "CREATED", 1: "PROCESSING", 2: "FINISHED", 3: "FAILED", 4: "CANCELING", 5: "CANCELED", } JobProgress_value = map[string]int32{ "CREATED": 0, "PROCESSING": 1, "FINISHED": 2, "FAILED": 3, "CANCELING": 4, "CANCELED": 5, } )
Enum value maps for JobProgress.
var ( SchemaType_name = map[int32]string{ 0: "HTTP", 1: "HTTPS", } SchemaType_value = map[string]int32{ "HTTP": 0, "HTTPS": 1, } )
Enum value maps for SchemaType.
var ( StepType_name = map[int32]string{ 0: "UNKNOWN", 1: "REQUEST", 2: "SCRIPT", 3: "FOR", 4: "IF", 5: "SEQUENCE", } StepType_value = map[string]int32{ "UNKNOWN": 0, "REQUEST": 1, "SCRIPT": 2, "FOR": 3, "IF": 4, "SEQUENCE": 5, } )
Enum value maps for StepType.
var File_common_proto protoreflect.FileDescriptor
var File_health_check_proto protoreflect.FileDescriptor
var File_http_common_proto protoreflect.FileDescriptor
var File_http_content_proto protoreflect.FileDescriptor
var File_https_content_proto protoreflect.FileDescriptor
var File_job_proto protoreflect.FileDescriptor
var File_request_step_proto protoreflect.FileDescriptor
var File_step_proto protoreflect.FileDescriptor
var HealthChecker_ServiceDesc = grpc.ServiceDesc{ ServiceName: "GGargantua.v1.proto.HealthChecker", HandlerType: (*HealthCheckerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CheckHealth", Handler: _HealthChecker_CheckHealth_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "health_check.proto", }
HealthChecker_ServiceDesc is the grpc.ServiceDesc for HealthChecker service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var JobService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "GGargantua.v1.proto.JobService", HandlerType: (*JobServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateAJob", Handler: _JobService_CreateAJob_Handler, }, { MethodName: "StartAJob", Handler: _JobService_StartAJob_Handler, }, { MethodName: "CancelAJob", Handler: _JobService_CancelAJob_Handler, }, { MethodName: "GetJobResult", Handler: _JobService_GetJobResult_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "job.proto", }
JobService_ServiceDesc is the grpc.ServiceDesc for JobService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var StepService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "GGargantua.v1.proto.StepService", HandlerType: (*StepServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ExecuteStep", Handler: _StepService_ExecuteStep_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "step.proto", }
StepService_ServiceDesc is the grpc.ServiceDesc for StepService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterHealthCheckerHandler ¶
func RegisterHealthCheckerHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterHealthCheckerHandler registers the http handlers for service HealthChecker to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterHealthCheckerHandlerClient ¶
func RegisterHealthCheckerHandlerClient(ctx context.Context, mux *runtime.ServeMux, client HealthCheckerClient) error
RegisterHealthCheckerHandlerClient registers the http handlers for service HealthChecker to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "HealthCheckerClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "HealthCheckerClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "HealthCheckerClient" to call the correct interceptors.
func RegisterHealthCheckerHandlerFromEndpoint ¶
func RegisterHealthCheckerHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterHealthCheckerHandlerFromEndpoint is same as RegisterHealthCheckerHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterHealthCheckerHandlerServer ¶
func RegisterHealthCheckerHandlerServer(ctx context.Context, mux *runtime.ServeMux, server HealthCheckerServer) error
RegisterHealthCheckerHandlerServer registers the http handlers for service HealthChecker to "mux". UnaryRPC :call HealthCheckerServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterHealthCheckerHandlerFromEndpoint instead.
func RegisterHealthCheckerServer ¶
func RegisterHealthCheckerServer(s grpc.ServiceRegistrar, srv HealthCheckerServer)
func RegisterJobServiceHandler ¶
func RegisterJobServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterJobServiceHandler registers the http handlers for service JobService to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterJobServiceHandlerClient ¶
func RegisterJobServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client JobServiceClient) error
RegisterJobServiceHandlerClient registers the http handlers for service JobService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "JobServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "JobServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "JobServiceClient" to call the correct interceptors.
func RegisterJobServiceHandlerFromEndpoint ¶
func RegisterJobServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterJobServiceHandlerFromEndpoint is same as RegisterJobServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterJobServiceHandlerServer ¶
func RegisterJobServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server JobServiceServer) error
RegisterJobServiceHandlerServer registers the http handlers for service JobService to "mux". UnaryRPC :call JobServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterJobServiceHandlerFromEndpoint instead.
func RegisterJobServiceServer ¶
func RegisterJobServiceServer(s grpc.ServiceRegistrar, srv JobServiceServer)
func RegisterStepServiceHandler ¶
func RegisterStepServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterStepServiceHandler registers the http handlers for service StepService to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterStepServiceHandlerClient ¶
func RegisterStepServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client StepServiceClient) error
RegisterStepServiceHandlerClient registers the http handlers for service StepService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "StepServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "StepServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "StepServiceClient" to call the correct interceptors.
func RegisterStepServiceHandlerFromEndpoint ¶
func RegisterStepServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterStepServiceHandlerFromEndpoint is same as RegisterStepServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterStepServiceHandlerServer ¶
func RegisterStepServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server StepServiceServer) error
RegisterStepServiceHandlerServer registers the http handlers for service StepService to "mux". UnaryRPC :call StepServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterStepServiceHandlerFromEndpoint instead.
func RegisterStepServiceServer ¶
func RegisterStepServiceServer(s grpc.ServiceRegistrar, srv StepServiceServer)
Types ¶
type Cookie ¶
type Cookie struct { Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"` Value string `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"` Path string `protobuf:"bytes,3,opt,name=Path,proto3" json:"Path,omitempty"` Domain string `protobuf:"bytes,4,opt,name=Domain,proto3" json:"Domain,omitempty"` Expires *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=Expires,proto3" json:"Expires,omitempty"` RawExpires string `protobuf:"bytes,6,opt,name=RawExpires,proto3" json:"RawExpires,omitempty"` MaxAge int32 `protobuf:"varint,7,opt,name=MaxAge,proto3" json:"MaxAge,omitempty"` Secure bool `protobuf:"varint,8,opt,name=Secure,proto3" json:"Secure,omitempty"` HttpOnly bool `protobuf:"varint,9,opt,name=HttpOnly,proto3" json:"HttpOnly,omitempty"` SameSite int32 `protobuf:"varint,10,opt,name=SameSite,proto3" json:"SameSite,omitempty"` Raw string `protobuf:"bytes,11,opt,name=Raw,proto3" json:"Raw,omitempty"` Unparsed []string `protobuf:"bytes,12,rep,name=Unparsed,proto3" json:"Unparsed,omitempty"` // contains filtered or unexported fields }
func (*Cookie) Descriptor
deprecated
func (*Cookie) GetExpires ¶
func (x *Cookie) GetExpires() *timestamppb.Timestamp
func (*Cookie) GetHttpOnly ¶
func (*Cookie) GetRawExpires ¶
func (*Cookie) GetSameSite ¶
func (*Cookie) GetUnparsed ¶
func (*Cookie) ProtoMessage ¶
func (*Cookie) ProtoMessage()
func (*Cookie) ProtoReflect ¶
func (x *Cookie) ProtoReflect() protoreflect.Message
type ForStepType ¶
type ForStepType struct { Times int32 `protobuf:"varint,1,opt,name=Times,proto3" json:"Times,omitempty"` SubStep *Step `protobuf:"bytes,2,opt,name=SubStep,proto3" json:"SubStep,omitempty"` // contains filtered or unexported fields }
func (*ForStepType) Descriptor
deprecated
func (*ForStepType) Descriptor() ([]byte, []int)
Deprecated: Use ForStepType.ProtoReflect.Descriptor instead.
func (*ForStepType) GetSubStep ¶
func (x *ForStepType) GetSubStep() *Step
func (*ForStepType) GetTimes ¶
func (x *ForStepType) GetTimes() int32
func (*ForStepType) ProtoMessage ¶
func (*ForStepType) ProtoMessage()
func (*ForStepType) ProtoReflect ¶
func (x *ForStepType) ProtoReflect() protoreflect.Message
func (*ForStepType) Reset ¶
func (x *ForStepType) Reset()
func (*ForStepType) String ¶
func (x *ForStepType) String() string
type HealthCheckerClient ¶
type HealthCheckerClient interface {
CheckHealth(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*HealthCondition, error)
}
HealthCheckerClient is the client API for HealthChecker 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 NewHealthCheckerClient ¶
func NewHealthCheckerClient(cc grpc.ClientConnInterface) HealthCheckerClient
type HealthCheckerServer ¶
type HealthCheckerServer interface {
CheckHealth(context.Context, *emptypb.Empty) (*HealthCondition, error)
}
HealthCheckerServer is the server API for HealthChecker service. All implementations should embed UnimplementedHealthCheckerServer for forward compatibility
type HealthCondition ¶
type HealthCondition struct { Status HealthCondition_HealthStatus `protobuf:"varint,1,opt,name=status,proto3,enum=GGargantua.v1.proto.HealthCondition_HealthStatus" json:"status,omitempty"` Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*HealthCondition) Descriptor
deprecated
func (*HealthCondition) Descriptor() ([]byte, []int)
Deprecated: Use HealthCondition.ProtoReflect.Descriptor instead.
func (*HealthCondition) GetError ¶
func (x *HealthCondition) GetError() string
func (*HealthCondition) GetReason ¶
func (x *HealthCondition) GetReason() string
func (*HealthCondition) GetStatus ¶
func (x *HealthCondition) GetStatus() HealthCondition_HealthStatus
func (*HealthCondition) ProtoMessage ¶
func (*HealthCondition) ProtoMessage()
func (*HealthCondition) ProtoReflect ¶
func (x *HealthCondition) ProtoReflect() protoreflect.Message
func (*HealthCondition) Reset ¶
func (x *HealthCondition) Reset()
func (*HealthCondition) String ¶
func (x *HealthCondition) String() string
type HealthCondition_HealthStatus ¶
type HealthCondition_HealthStatus int32
const ( HealthCondition_HEALTHY HealthCondition_HealthStatus = 0 HealthCondition_UNHEALTHY HealthCondition_HealthStatus = 1 )
func (HealthCondition_HealthStatus) Descriptor ¶
func (HealthCondition_HealthStatus) Descriptor() protoreflect.EnumDescriptor
func (HealthCondition_HealthStatus) Enum ¶
func (x HealthCondition_HealthStatus) Enum() *HealthCondition_HealthStatus
func (HealthCondition_HealthStatus) EnumDescriptor
deprecated
func (HealthCondition_HealthStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use HealthCondition_HealthStatus.Descriptor instead.
func (HealthCondition_HealthStatus) Number ¶
func (x HealthCondition_HealthStatus) Number() protoreflect.EnumNumber
func (HealthCondition_HealthStatus) String ¶
func (x HealthCondition_HealthStatus) String() string
func (HealthCondition_HealthStatus) Type ¶
func (HealthCondition_HealthStatus) Type() protoreflect.EnumType
type HttpRequest ¶
type HttpRequest struct { Method string `protobuf:"bytes,1,opt,name=Method,proto3" json:"Method,omitempty"` Url string `protobuf:"bytes,2,opt,name=Url,proto3" json:"Url,omitempty"` Headers map[string]*ListOfString `` /* 155-byte string literal not displayed */ Params map[string]string `` /* 153-byte string literal not displayed */ Body []byte `protobuf:"bytes,5,opt,name=Body,proto3" json:"Body,omitempty"` // contains filtered or unexported fields }
func (*HttpRequest) Descriptor
deprecated
func (*HttpRequest) Descriptor() ([]byte, []int)
Deprecated: Use HttpRequest.ProtoReflect.Descriptor instead.
func (*HttpRequest) GetBody ¶
func (x *HttpRequest) GetBody() []byte
func (*HttpRequest) GetHeaders ¶
func (x *HttpRequest) GetHeaders() map[string]*ListOfString
func (*HttpRequest) GetMethod ¶
func (x *HttpRequest) GetMethod() string
func (*HttpRequest) GetParams ¶
func (x *HttpRequest) GetParams() map[string]string
func (*HttpRequest) GetUrl ¶
func (x *HttpRequest) GetUrl() string
func (*HttpRequest) ProtoMessage ¶
func (*HttpRequest) ProtoMessage()
func (*HttpRequest) ProtoReflect ¶
func (x *HttpRequest) ProtoReflect() protoreflect.Message
func (*HttpRequest) Reset ¶
func (x *HttpRequest) Reset()
func (*HttpRequest) String ¶
func (x *HttpRequest) String() string
type HttpResponse ¶
type HttpResponse struct { Body []byte `protobuf:"bytes,1,opt,name=Body,proto3" json:"Body,omitempty"` Cookies []*Cookie `protobuf:"bytes,2,rep,name=Cookies,proto3" json:"Cookies,omitempty"` Headers map[string]*ListOfString `` /* 155-byte string literal not displayed */ Status int32 `protobuf:"varint,4,opt,name=Status,proto3" json:"Status,omitempty"` StartTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=StartTime,proto3" json:"StartTime,omitempty"` FistByteTime *durationpb.Duration `protobuf:"bytes,6,opt,name=FistByteTime,proto3" json:"FistByteTime,omitempty"` CompleteTime *durationpb.Duration `protobuf:"bytes,7,opt,name=CompleteTime,proto3" json:"CompleteTime,omitempty"` Error string `protobuf:"bytes,8,opt,name=Error,proto3" json:"Error,omitempty"` // contains filtered or unexported fields }
func (*HttpResponse) Descriptor
deprecated
func (*HttpResponse) Descriptor() ([]byte, []int)
Deprecated: Use HttpResponse.ProtoReflect.Descriptor instead.
func (*HttpResponse) GetBody ¶
func (x *HttpResponse) GetBody() []byte
func (*HttpResponse) GetCompleteTime ¶
func (x *HttpResponse) GetCompleteTime() *durationpb.Duration
func (*HttpResponse) GetCookies ¶
func (x *HttpResponse) GetCookies() []*Cookie
func (*HttpResponse) GetError ¶
func (x *HttpResponse) GetError() string
func (*HttpResponse) GetFistByteTime ¶
func (x *HttpResponse) GetFistByteTime() *durationpb.Duration
func (*HttpResponse) GetHeaders ¶
func (x *HttpResponse) GetHeaders() map[string]*ListOfString
func (*HttpResponse) GetStartTime ¶
func (x *HttpResponse) GetStartTime() *timestamppb.Timestamp
func (*HttpResponse) GetStatus ¶
func (x *HttpResponse) GetStatus() int32
func (*HttpResponse) ProtoMessage ¶
func (*HttpResponse) ProtoMessage()
func (*HttpResponse) ProtoReflect ¶
func (x *HttpResponse) ProtoReflect() protoreflect.Message
func (*HttpResponse) Reset ¶
func (x *HttpResponse) Reset()
func (*HttpResponse) String ¶
func (x *HttpResponse) String() string
type HttpsRequest ¶
type HttpsRequest struct { Method string `protobuf:"bytes,1,opt,name=Method,proto3" json:"Method,omitempty"` Url string `protobuf:"bytes,2,opt,name=Url,proto3" json:"Url,omitempty"` Headers map[string]*ListOfString `` /* 155-byte string literal not displayed */ Params map[string]string `` /* 153-byte string literal not displayed */ Body []byte `protobuf:"bytes,5,opt,name=Body,proto3" json:"Body,omitempty"` SkipInsecureVerify bool `protobuf:"varint,6,opt,name=SkipInsecureVerify,proto3" json:"SkipInsecureVerify,omitempty"` CaCert []byte `protobuf:"bytes,7,opt,name=CaCert,proto3" json:"CaCert,omitempty"` Cert []byte `protobuf:"bytes,8,opt,name=Cert,proto3" json:"Cert,omitempty"` Key []byte `protobuf:"bytes,9,opt,name=Key,proto3" json:"Key,omitempty"` // contains filtered or unexported fields }
func (*HttpsRequest) Descriptor
deprecated
func (*HttpsRequest) Descriptor() ([]byte, []int)
Deprecated: Use HttpsRequest.ProtoReflect.Descriptor instead.
func (*HttpsRequest) GetBody ¶
func (x *HttpsRequest) GetBody() []byte
func (*HttpsRequest) GetCaCert ¶
func (x *HttpsRequest) GetCaCert() []byte
func (*HttpsRequest) GetCert ¶
func (x *HttpsRequest) GetCert() []byte
func (*HttpsRequest) GetHeaders ¶
func (x *HttpsRequest) GetHeaders() map[string]*ListOfString
func (*HttpsRequest) GetKey ¶
func (x *HttpsRequest) GetKey() []byte
func (*HttpsRequest) GetMethod ¶
func (x *HttpsRequest) GetMethod() string
func (*HttpsRequest) GetParams ¶
func (x *HttpsRequest) GetParams() map[string]string
func (*HttpsRequest) GetSkipInsecureVerify ¶
func (x *HttpsRequest) GetSkipInsecureVerify() bool
func (*HttpsRequest) GetUrl ¶
func (x *HttpsRequest) GetUrl() string
func (*HttpsRequest) ProtoMessage ¶
func (*HttpsRequest) ProtoMessage()
func (*HttpsRequest) ProtoReflect ¶
func (x *HttpsRequest) ProtoReflect() protoreflect.Message
func (*HttpsRequest) Reset ¶
func (x *HttpsRequest) Reset()
func (*HttpsRequest) String ¶
func (x *HttpsRequest) String() string
type HttpsResponse ¶
type HttpsResponse struct { Body []byte `protobuf:"bytes,1,opt,name=Body,proto3" json:"Body,omitempty"` Cookies []*Cookie `protobuf:"bytes,2,rep,name=Cookies,proto3" json:"Cookies,omitempty"` Headers map[string]*ListOfString `` /* 155-byte string literal not displayed */ Status int32 `protobuf:"varint,4,opt,name=Status,proto3" json:"Status,omitempty"` StartTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=StartTime,proto3" json:"StartTime,omitempty"` FistByteTime *durationpb.Duration `protobuf:"bytes,6,opt,name=FistByteTime,proto3" json:"FistByteTime,omitempty"` CompleteTime *durationpb.Duration `protobuf:"bytes,7,opt,name=CompleteTime,proto3" json:"CompleteTime,omitempty"` Error string `protobuf:"bytes,8,opt,name=Error,proto3" json:"Error,omitempty"` // contains filtered or unexported fields }
func (*HttpsResponse) Descriptor
deprecated
func (*HttpsResponse) Descriptor() ([]byte, []int)
Deprecated: Use HttpsResponse.ProtoReflect.Descriptor instead.
func (*HttpsResponse) GetBody ¶
func (x *HttpsResponse) GetBody() []byte
func (*HttpsResponse) GetCompleteTime ¶
func (x *HttpsResponse) GetCompleteTime() *durationpb.Duration
func (*HttpsResponse) GetCookies ¶
func (x *HttpsResponse) GetCookies() []*Cookie
func (*HttpsResponse) GetError ¶
func (x *HttpsResponse) GetError() string
func (*HttpsResponse) GetFistByteTime ¶
func (x *HttpsResponse) GetFistByteTime() *durationpb.Duration
func (*HttpsResponse) GetHeaders ¶
func (x *HttpsResponse) GetHeaders() map[string]*ListOfString
func (*HttpsResponse) GetStartTime ¶
func (x *HttpsResponse) GetStartTime() *timestamppb.Timestamp
func (*HttpsResponse) GetStatus ¶
func (x *HttpsResponse) GetStatus() int32
func (*HttpsResponse) ProtoMessage ¶
func (*HttpsResponse) ProtoMessage()
func (*HttpsResponse) ProtoReflect ¶
func (x *HttpsResponse) ProtoReflect() protoreflect.Message
func (*HttpsResponse) Reset ¶
func (x *HttpsResponse) Reset()
func (*HttpsResponse) String ¶
func (x *HttpsResponse) String() string
type IfStepType ¶
type IfStepType struct { ScriptStep *ScriptStepType `protobuf:"bytes,1,opt,name=ScriptStep,proto3" json:"ScriptStep,omitempty"` TrueStep *Step `protobuf:"bytes,2,opt,name=TrueStep,proto3" json:"TrueStep,omitempty"` FalseStep *Step `protobuf:"bytes,3,opt,name=FalseStep,proto3" json:"FalseStep,omitempty"` // contains filtered or unexported fields }
func (*IfStepType) Descriptor
deprecated
func (*IfStepType) Descriptor() ([]byte, []int)
Deprecated: Use IfStepType.ProtoReflect.Descriptor instead.
func (*IfStepType) GetFalseStep ¶
func (x *IfStepType) GetFalseStep() *Step
func (*IfStepType) GetScriptStep ¶
func (x *IfStepType) GetScriptStep() *ScriptStepType
func (*IfStepType) GetTrueStep ¶
func (x *IfStepType) GetTrueStep() *Step
func (*IfStepType) ProtoMessage ¶
func (*IfStepType) ProtoMessage()
func (*IfStepType) ProtoReflect ¶
func (x *IfStepType) ProtoReflect() protoreflect.Message
func (*IfStepType) Reset ¶
func (x *IfStepType) Reset()
func (*IfStepType) String ¶
func (x *IfStepType) String() string
type JobProgress ¶
type JobProgress int32
const ( JobProgress_CREATED JobProgress = 0 JobProgress_PROCESSING JobProgress = 1 JobProgress_FINISHED JobProgress = 2 JobProgress_FAILED JobProgress = 3 JobProgress_CANCELING JobProgress = 4 JobProgress_CANCELED JobProgress = 5 )
func (JobProgress) Descriptor ¶
func (JobProgress) Descriptor() protoreflect.EnumDescriptor
func (JobProgress) Enum ¶
func (x JobProgress) Enum() *JobProgress
func (JobProgress) EnumDescriptor
deprecated
func (JobProgress) EnumDescriptor() ([]byte, []int)
Deprecated: Use JobProgress.Descriptor instead.
func (JobProgress) Number ¶
func (x JobProgress) Number() protoreflect.EnumNumber
func (JobProgress) String ¶
func (x JobProgress) String() string
func (JobProgress) Type ¶
func (JobProgress) Type() protoreflect.EnumType
type JobResult ¶
type JobResult struct { Status *JobStatus `protobuf:"bytes,1,opt,name=Status,proto3" json:"Status,omitempty"` Result *StepResult `protobuf:"bytes,2,opt,name=Result,proto3" json:"Result,omitempty"` // contains filtered or unexported fields }
func (*JobResult) Descriptor
deprecated
func (*JobResult) GetResult ¶
func (x *JobResult) GetResult() *StepResult
func (*JobResult) ProtoMessage ¶
func (*JobResult) ProtoMessage()
func (*JobResult) ProtoReflect ¶
func (x *JobResult) ProtoReflect() protoreflect.Message
type JobServiceClient ¶
type JobServiceClient interface { CreateAJob(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*JobUuid, error) StartAJob(ctx context.Context, in *UpdateJobContent, opts ...grpc.CallOption) (*emptypb.Empty, error) CancelAJob(ctx context.Context, in *JobUuid, opts ...grpc.CallOption) (*emptypb.Empty, error) GetJobResult(ctx context.Context, in *JobUuid, opts ...grpc.CallOption) (*JobResult, error) }
JobServiceClient is the client API for JobService 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 NewJobServiceClient ¶
func NewJobServiceClient(cc grpc.ClientConnInterface) JobServiceClient
type JobServiceServer ¶
type JobServiceServer interface { CreateAJob(context.Context, *emptypb.Empty) (*JobUuid, error) StartAJob(context.Context, *UpdateJobContent) (*emptypb.Empty, error) CancelAJob(context.Context, *JobUuid) (*emptypb.Empty, error) GetJobResult(context.Context, *JobUuid) (*JobResult, error) }
JobServiceServer is the server API for JobService service. All implementations should embed UnimplementedJobServiceServer for forward compatibility
type JobStatus ¶
type JobStatus struct { Uuid string `protobuf:"bytes,1,opt,name=Uuid,proto3" json:"Uuid,omitempty"` Progress JobProgress `protobuf:"varint,2,opt,name=Progress,proto3,enum=GGargantua.v1.proto.JobProgress" json:"Progress,omitempty"` Reason string `protobuf:"bytes,3,opt,name=Reason,proto3" json:"Reason,omitempty"` // contains filtered or unexported fields }
func (*JobStatus) Descriptor
deprecated
func (*JobStatus) GetProgress ¶
func (x *JobStatus) GetProgress() JobProgress
func (*JobStatus) ProtoMessage ¶
func (*JobStatus) ProtoMessage()
func (*JobStatus) ProtoReflect ¶
func (x *JobStatus) ProtoReflect() protoreflect.Message
type JobUuid ¶
type JobUuid struct { Uuid string `protobuf:"bytes,1,opt,name=Uuid,proto3" json:"Uuid,omitempty"` // contains filtered or unexported fields }
func (*JobUuid) Descriptor
deprecated
func (*JobUuid) ProtoMessage ¶
func (*JobUuid) ProtoMessage()
func (*JobUuid) ProtoReflect ¶
func (x *JobUuid) ProtoReflect() protoreflect.Message
type ListOfString ¶
type ListOfString struct { Strings []string `protobuf:"bytes,1,rep,name=Strings,proto3" json:"Strings,omitempty"` // contains filtered or unexported fields }
func (*ListOfString) Descriptor
deprecated
func (*ListOfString) Descriptor() ([]byte, []int)
Deprecated: Use ListOfString.ProtoReflect.Descriptor instead.
func (*ListOfString) GetStrings ¶
func (x *ListOfString) GetStrings() []string
func (*ListOfString) ProtoMessage ¶
func (*ListOfString) ProtoMessage()
func (*ListOfString) ProtoReflect ¶
func (x *ListOfString) ProtoReflect() protoreflect.Message
func (*ListOfString) Reset ¶
func (x *ListOfString) Reset()
func (*ListOfString) String ¶
func (x *ListOfString) String() string
type Request ¶
type Request struct { RequestSchema SchemaType `protobuf:"varint,1,opt,name=RequestSchema,proto3,enum=GGargantua.v1.proto.SchemaType" json:"RequestSchema,omitempty"` Times int32 `protobuf:"varint,2,opt,name=Times,proto3" json:"Times,omitempty"` Concurrency int32 `protobuf:"varint,3,opt,name=Concurrency,proto3" json:"Concurrency,omitempty"` HttpRequest *HttpRequest `protobuf:"bytes,4,opt,name=HttpRequest,proto3" json:"HttpRequest,omitempty"` HttpsRequest *HttpsRequest `protobuf:"bytes,5,opt,name=HttpsRequest,proto3" json:"HttpsRequest,omitempty"` // contains filtered or unexported fields }
func (*Request) Descriptor
deprecated
func (*Request) GetConcurrency ¶
func (*Request) GetHttpRequest ¶
func (x *Request) GetHttpRequest() *HttpRequest
func (*Request) GetHttpsRequest ¶
func (x *Request) GetHttpsRequest() *HttpsRequest
func (*Request) GetRequestSchema ¶
func (x *Request) GetRequestSchema() SchemaType
func (*Request) ProtoMessage ¶
func (*Request) ProtoMessage()
func (*Request) ProtoReflect ¶
func (x *Request) ProtoReflect() protoreflect.Message
type RequestStepType ¶
type RequestStepType struct { Request *Request `protobuf:"bytes,1,opt,name=Request,proto3" json:"Request,omitempty"` // contains filtered or unexported fields }
func (*RequestStepType) Descriptor
deprecated
func (*RequestStepType) Descriptor() ([]byte, []int)
Deprecated: Use RequestStepType.ProtoReflect.Descriptor instead.
func (*RequestStepType) GetRequest ¶
func (x *RequestStepType) GetRequest() *Request
func (*RequestStepType) ProtoMessage ¶
func (*RequestStepType) ProtoMessage()
func (*RequestStepType) ProtoReflect ¶
func (x *RequestStepType) ProtoReflect() protoreflect.Message
func (*RequestStepType) Reset ¶
func (x *RequestStepType) Reset()
func (*RequestStepType) String ¶
func (x *RequestStepType) String() string
type Response ¶
type Response struct { ResponseSchema SchemaType `protobuf:"varint,1,opt,name=ResponseSchema,proto3,enum=GGargantua.v1.proto.SchemaType" json:"ResponseSchema,omitempty"` TotalTime *durationpb.Duration `protobuf:"bytes,2,opt,name=TotalTime,proto3" json:"TotalTime,omitempty"` TotalRequests int32 `protobuf:"varint,3,opt,name=TotalRequests,proto3" json:"TotalRequests,omitempty"` SuccessRequests int32 `protobuf:"varint,4,opt,name=SuccessRequests,proto3" json:"SuccessRequests,omitempty"` AllResponse []*SingleResponse `protobuf:"bytes,5,rep,name=AllResponse,proto3" json:"AllResponse,omitempty"` // contains filtered or unexported fields }
func (*Response) Descriptor
deprecated
func (*Response) GetAllResponse ¶
func (x *Response) GetAllResponse() []*SingleResponse
func (*Response) GetResponseSchema ¶
func (x *Response) GetResponseSchema() SchemaType
func (*Response) GetSuccessRequests ¶
func (*Response) GetTotalRequests ¶
func (*Response) GetTotalTime ¶
func (x *Response) GetTotalTime() *durationpb.Duration
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) ProtoReflect ¶
func (x *Response) ProtoReflect() protoreflect.Message
type SchemaType ¶
type SchemaType int32
const ( SchemaType_HTTP SchemaType = 0 SchemaType_HTTPS SchemaType = 1 )
func (SchemaType) Descriptor ¶
func (SchemaType) Descriptor() protoreflect.EnumDescriptor
func (SchemaType) Enum ¶
func (x SchemaType) Enum() *SchemaType
func (SchemaType) EnumDescriptor
deprecated
func (SchemaType) EnumDescriptor() ([]byte, []int)
Deprecated: Use SchemaType.Descriptor instead.
func (SchemaType) Number ¶
func (x SchemaType) Number() protoreflect.EnumNumber
func (SchemaType) String ¶
func (x SchemaType) String() string
func (SchemaType) Type ¶
func (SchemaType) Type() protoreflect.EnumType
type ScriptStepType ¶
type ScriptStepType struct { Script string `protobuf:"bytes,1,opt,name=Script,proto3" json:"Script,omitempty"` // contains filtered or unexported fields }
func (*ScriptStepType) Descriptor
deprecated
func (*ScriptStepType) Descriptor() ([]byte, []int)
Deprecated: Use ScriptStepType.ProtoReflect.Descriptor instead.
func (*ScriptStepType) GetScript ¶
func (x *ScriptStepType) GetScript() string
func (*ScriptStepType) ProtoMessage ¶
func (*ScriptStepType) ProtoMessage()
func (*ScriptStepType) ProtoReflect ¶
func (x *ScriptStepType) ProtoReflect() protoreflect.Message
func (*ScriptStepType) Reset ¶
func (x *ScriptStepType) Reset()
func (*ScriptStepType) String ¶
func (x *ScriptStepType) String() string
type SequenceStepType ¶
type SequenceStepType struct { SubSteps []*Step `protobuf:"bytes,1,rep,name=SubSteps,proto3" json:"SubSteps,omitempty"` // contains filtered or unexported fields }
func (*SequenceStepType) Descriptor
deprecated
func (*SequenceStepType) Descriptor() ([]byte, []int)
Deprecated: Use SequenceStepType.ProtoReflect.Descriptor instead.
func (*SequenceStepType) GetSubSteps ¶
func (x *SequenceStepType) GetSubSteps() []*Step
func (*SequenceStepType) ProtoMessage ¶
func (*SequenceStepType) ProtoMessage()
func (*SequenceStepType) ProtoReflect ¶
func (x *SequenceStepType) ProtoReflect() protoreflect.Message
func (*SequenceStepType) Reset ¶
func (x *SequenceStepType) Reset()
func (*SequenceStepType) String ¶
func (x *SequenceStepType) String() string
type SingleResponse ¶
type SingleResponse struct { HttpResponse *HttpResponse `protobuf:"bytes,1,opt,name=HttpResponse,proto3" json:"HttpResponse,omitempty"` HttpsResponse *HttpsResponse `protobuf:"bytes,2,opt,name=HttpsResponse,proto3" json:"HttpsResponse,omitempty"` // contains filtered or unexported fields }
func (*SingleResponse) Descriptor
deprecated
func (*SingleResponse) Descriptor() ([]byte, []int)
Deprecated: Use SingleResponse.ProtoReflect.Descriptor instead.
func (*SingleResponse) GetHttpResponse ¶
func (x *SingleResponse) GetHttpResponse() *HttpResponse
func (*SingleResponse) GetHttpsResponse ¶
func (x *SingleResponse) GetHttpsResponse() *HttpsResponse
func (*SingleResponse) ProtoMessage ¶
func (*SingleResponse) ProtoMessage()
func (*SingleResponse) ProtoReflect ¶
func (x *SingleResponse) ProtoReflect() protoreflect.Message
func (*SingleResponse) Reset ¶
func (x *SingleResponse) Reset()
func (*SingleResponse) String ¶
func (x *SingleResponse) String() string
type Step ¶
type Step struct { Type StepType `protobuf:"varint,1,opt,name=Type,proto3,enum=GGargantua.v1.proto.StepType" json:"Type,omitempty"` RequestStep *RequestStepType `protobuf:"bytes,2,opt,name=RequestStep,proto3" json:"RequestStep,omitempty"` ScriptStep *ScriptStepType `protobuf:"bytes,3,opt,name=ScriptStep,proto3" json:"ScriptStep,omitempty"` ForStep *ForStepType `protobuf:"bytes,4,opt,name=ForStep,proto3" json:"ForStep,omitempty"` IfStep *IfStepType `protobuf:"bytes,5,opt,name=IfStep,proto3" json:"IfStep,omitempty"` SequenceStep *SequenceStepType `protobuf:"bytes,6,opt,name=SequenceStep,proto3" json:"SequenceStep,omitempty"` // contains filtered or unexported fields }
func (*Step) Descriptor
deprecated
func (*Step) GetForStep ¶
func (x *Step) GetForStep() *ForStepType
func (*Step) GetIfStep ¶
func (x *Step) GetIfStep() *IfStepType
func (*Step) GetRequestStep ¶
func (x *Step) GetRequestStep() *RequestStepType
func (*Step) GetScriptStep ¶
func (x *Step) GetScriptStep() *ScriptStepType
func (*Step) GetSequenceStep ¶
func (x *Step) GetSequenceStep() *SequenceStepType
func (*Step) ProtoMessage ¶
func (*Step) ProtoMessage()
func (*Step) ProtoReflect ¶
func (x *Step) ProtoReflect() protoreflect.Message
type StepResult ¶
type StepResult struct { Success bool `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"` Reason string `protobuf:"bytes,2,opt,name=Reason,proto3" json:"Reason,omitempty"` Result string `protobuf:"bytes,3,opt,name=Result,proto3" json:"Result,omitempty"` SubResult []*StepResult `protobuf:"bytes,4,rep,name=SubResult,proto3" json:"SubResult,omitempty"` // contains filtered or unexported fields }
func (*StepResult) Descriptor
deprecated
func (*StepResult) Descriptor() ([]byte, []int)
Deprecated: Use StepResult.ProtoReflect.Descriptor instead.
func (*StepResult) GetReason ¶
func (x *StepResult) GetReason() string
func (*StepResult) GetResult ¶
func (x *StepResult) GetResult() string
func (*StepResult) GetSubResult ¶
func (x *StepResult) GetSubResult() []*StepResult
func (*StepResult) GetSuccess ¶
func (x *StepResult) GetSuccess() bool
func (*StepResult) ProtoMessage ¶
func (*StepResult) ProtoMessage()
func (*StepResult) ProtoReflect ¶
func (x *StepResult) ProtoReflect() protoreflect.Message
func (*StepResult) Reset ¶
func (x *StepResult) Reset()
func (*StepResult) String ¶
func (x *StepResult) String() string
type StepServiceClient ¶
type StepServiceClient interface {
ExecuteStep(ctx context.Context, in *Step, opts ...grpc.CallOption) (*StepResult, error)
}
StepServiceClient is the client API for StepService 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 NewStepServiceClient ¶
func NewStepServiceClient(cc grpc.ClientConnInterface) StepServiceClient
type StepServiceServer ¶
type StepServiceServer interface {
ExecuteStep(context.Context, *Step) (*StepResult, error)
}
StepServiceServer is the server API for StepService service. All implementations should embed UnimplementedStepServiceServer for forward compatibility
type StepType ¶
type StepType int32
func (StepType) Descriptor ¶
func (StepType) Descriptor() protoreflect.EnumDescriptor
func (StepType) EnumDescriptor
deprecated
func (StepType) Number ¶
func (x StepType) Number() protoreflect.EnumNumber
func (StepType) Type ¶
func (StepType) Type() protoreflect.EnumType
type UnimplementedHealthCheckerServer ¶
type UnimplementedHealthCheckerServer struct { }
UnimplementedHealthCheckerServer should be embedded to have forward compatible implementations.
func (UnimplementedHealthCheckerServer) CheckHealth ¶
func (UnimplementedHealthCheckerServer) CheckHealth(context.Context, *emptypb.Empty) (*HealthCondition, error)
type UnimplementedJobServiceServer ¶
type UnimplementedJobServiceServer struct { }
UnimplementedJobServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedJobServiceServer) CancelAJob ¶
func (UnimplementedJobServiceServer) CreateAJob ¶
func (UnimplementedJobServiceServer) GetJobResult ¶
func (UnimplementedJobServiceServer) StartAJob ¶
func (UnimplementedJobServiceServer) StartAJob(context.Context, *UpdateJobContent) (*emptypb.Empty, error)
type UnimplementedStepServiceServer ¶
type UnimplementedStepServiceServer struct { }
UnimplementedStepServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedStepServiceServer) ExecuteStep ¶
func (UnimplementedStepServiceServer) ExecuteStep(context.Context, *Step) (*StepResult, error)
type UnsafeHealthCheckerServer ¶
type UnsafeHealthCheckerServer interface {
// contains filtered or unexported methods
}
UnsafeHealthCheckerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HealthCheckerServer will result in compilation errors.
type UnsafeJobServiceServer ¶
type UnsafeJobServiceServer interface {
// contains filtered or unexported methods
}
UnsafeJobServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to JobServiceServer will result in compilation errors.
type UnsafeStepServiceServer ¶
type UnsafeStepServiceServer interface {
// contains filtered or unexported methods
}
UnsafeStepServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StepServiceServer will result in compilation errors.
type UpdateJobContent ¶
type UpdateJobContent struct { Uuid *JobUuid `protobuf:"bytes,1,opt,name=Uuid,proto3" json:"Uuid,omitempty"` MainStep *Step `protobuf:"bytes,2,opt,name=MainStep,proto3" json:"MainStep,omitempty"` // contains filtered or unexported fields }
func (*UpdateJobContent) Descriptor
deprecated
func (*UpdateJobContent) Descriptor() ([]byte, []int)
Deprecated: Use UpdateJobContent.ProtoReflect.Descriptor instead.
func (*UpdateJobContent) GetMainStep ¶
func (x *UpdateJobContent) GetMainStep() *Step
func (*UpdateJobContent) GetUuid ¶
func (x *UpdateJobContent) GetUuid() *JobUuid
func (*UpdateJobContent) ProtoMessage ¶
func (*UpdateJobContent) ProtoMessage()
func (*UpdateJobContent) ProtoReflect ¶
func (x *UpdateJobContent) ProtoReflect() protoreflect.Message
func (*UpdateJobContent) Reset ¶
func (x *UpdateJobContent) Reset()
func (*UpdateJobContent) String ¶
func (x *UpdateJobContent) String() string