protobuf

package
v0.0.0-...-b2c1117 Latest Latest
Warning

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

Go to latest
Published: Jun 19, 2022 License: Apache-2.0 Imports: 19 Imported by: 0

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

Constants

This section is empty.

Variables

View Source
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.

View Source
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.

View Source
var (
	SchemaType_name = map[int32]string{
		0: "HTTP",
		1: "HTTPS",
	}
	SchemaType_value = map[string]int32{
		"HTTP":  0,
		"HTTPS": 1,
	}
)

Enum value maps for SchemaType.

View Source
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.

View Source
var File_common_proto protoreflect.FileDescriptor
View Source
var File_health_check_proto protoreflect.FileDescriptor
View Source
var File_http_common_proto protoreflect.FileDescriptor
View Source
var File_http_content_proto protoreflect.FileDescriptor
View Source
var File_https_content_proto protoreflect.FileDescriptor
View Source
var File_request_step_proto protoreflect.FileDescriptor
View Source
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)

View Source
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)

View Source
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 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) Descriptor() ([]byte, []int)

Deprecated: Use Cookie.ProtoReflect.Descriptor instead.

func (*Cookie) GetDomain

func (x *Cookie) GetDomain() string

func (*Cookie) GetExpires

func (x *Cookie) GetExpires() *timestamppb.Timestamp

func (*Cookie) GetHttpOnly

func (x *Cookie) GetHttpOnly() bool

func (*Cookie) GetMaxAge

func (x *Cookie) GetMaxAge() int32

func (*Cookie) GetName

func (x *Cookie) GetName() string

func (*Cookie) GetPath

func (x *Cookie) GetPath() string

func (*Cookie) GetRaw

func (x *Cookie) GetRaw() string

func (*Cookie) GetRawExpires

func (x *Cookie) GetRawExpires() string

func (*Cookie) GetSameSite

func (x *Cookie) GetSameSite() int32

func (*Cookie) GetSecure

func (x *Cookie) GetSecure() bool

func (*Cookie) GetUnparsed

func (x *Cookie) GetUnparsed() []string

func (*Cookie) GetValue

func (x *Cookie) GetValue() string

func (*Cookie) ProtoMessage

func (*Cookie) ProtoMessage()

func (*Cookie) ProtoReflect

func (x *Cookie) ProtoReflect() protoreflect.Message

func (*Cookie) Reset

func (x *Cookie) Reset()

func (*Cookie) String

func (x *Cookie) String() string

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.

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 (*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) Enum

func (HealthCondition_HealthStatus) EnumDescriptor deprecated

func (HealthCondition_HealthStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use HealthCondition_HealthStatus.Descriptor instead.

func (HealthCondition_HealthStatus) Number

func (HealthCondition_HealthStatus) String

func (HealthCondition_HealthStatus) Type

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) 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

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) Descriptor() ([]byte, []int)

Deprecated: Use JobResult.ProtoReflect.Descriptor instead.

func (*JobResult) GetResult

func (x *JobResult) GetResult() *StepResult

func (*JobResult) GetStatus

func (x *JobResult) GetStatus() *JobStatus

func (*JobResult) ProtoMessage

func (*JobResult) ProtoMessage()

func (*JobResult) ProtoReflect

func (x *JobResult) ProtoReflect() protoreflect.Message

func (*JobResult) Reset

func (x *JobResult) Reset()

func (*JobResult) String

func (x *JobResult) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use JobStatus.ProtoReflect.Descriptor instead.

func (*JobStatus) GetProgress

func (x *JobStatus) GetProgress() JobProgress

func (*JobStatus) GetReason

func (x *JobStatus) GetReason() string

func (*JobStatus) GetUuid

func (x *JobStatus) GetUuid() string

func (*JobStatus) ProtoMessage

func (*JobStatus) ProtoMessage()

func (*JobStatus) ProtoReflect

func (x *JobStatus) ProtoReflect() protoreflect.Message

func (*JobStatus) Reset

func (x *JobStatus) Reset()

func (*JobStatus) String

func (x *JobStatus) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use JobUuid.ProtoReflect.Descriptor instead.

func (*JobUuid) GetUuid

func (x *JobUuid) GetUuid() string

func (*JobUuid) ProtoMessage

func (*JobUuid) ProtoMessage()

func (*JobUuid) ProtoReflect

func (x *JobUuid) ProtoReflect() protoreflect.Message

func (*JobUuid) Reset

func (x *JobUuid) Reset()

func (*JobUuid) String

func (x *JobUuid) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetConcurrency

func (x *Request) GetConcurrency() int32

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) GetTimes

func (x *Request) GetTimes() int32

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) ProtoReflect

func (x *Request) ProtoReflect() protoreflect.Message

func (*Request) Reset

func (x *Request) Reset()

func (*Request) String

func (x *Request) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetAllResponse

func (x *Response) GetAllResponse() []*SingleResponse

func (*Response) GetResponseSchema

func (x *Response) GetResponseSchema() SchemaType

func (*Response) GetSuccessRequests

func (x *Response) GetSuccessRequests() int32

func (*Response) GetTotalRequests

func (x *Response) GetTotalRequests() int32

func (*Response) GetTotalTime

func (x *Response) GetTotalTime() *durationpb.Duration

func (*Response) ProtoMessage

func (*Response) ProtoMessage()

func (*Response) ProtoReflect

func (x *Response) ProtoReflect() protoreflect.Message

func (*Response) Reset

func (x *Response) Reset()

func (*Response) String

func (x *Response) String() string

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

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) Descriptor() ([]byte, []int)

Deprecated: Use Step.ProtoReflect.Descriptor instead.

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) GetType

func (x *Step) GetType() StepType

func (*Step) ProtoMessage

func (*Step) ProtoMessage()

func (*Step) ProtoReflect

func (x *Step) ProtoReflect() protoreflect.Message

func (*Step) Reset

func (x *Step) Reset()

func (*Step) String

func (x *Step) String() string

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.

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
const (
	StepType_UNKNOWN  StepType = 0
	StepType_REQUEST  StepType = 1
	StepType_SCRIPT   StepType = 2
	StepType_FOR      StepType = 3
	StepType_IF       StepType = 4
	StepType_SEQUENCE StepType = 5
)

func (StepType) Descriptor

func (StepType) Descriptor() protoreflect.EnumDescriptor

func (StepType) Enum

func (x StepType) Enum() *StepType

func (StepType) EnumDescriptor deprecated

func (StepType) EnumDescriptor() ([]byte, []int)

Deprecated: Use StepType.Descriptor instead.

func (StepType) Number

func (x StepType) Number() protoreflect.EnumNumber

func (StepType) String

func (x StepType) String() string

func (StepType) Type

type UnimplementedHealthCheckerServer

type UnimplementedHealthCheckerServer struct {
}

UnimplementedHealthCheckerServer should be embedded to have forward compatible implementations.

func (UnimplementedHealthCheckerServer) CheckHealth

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

type UnimplementedStepServiceServer

type UnimplementedStepServiceServer struct {
}

UnimplementedStepServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedStepServiceServer) ExecuteStep

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL