v1

Documentation

Index

• Constants
• Variables
• func RegisterIntegrateServiceServer(s grpc.ServiceRegistrar, srv IntegrateServiceServer)
• type IntegrateReply
  • func (*IntegrateReply) Descriptor() ([]byte, []int)
  • func (x *IntegrateReply) GetCode() int32
  • func (*IntegrateReply) ProtoMessage()
  • func (x *IntegrateReply) ProtoReflect() protoreflect.Message
  • func (x *IntegrateReply) Reset()
  • func (x *IntegrateReply) String() string
• type IntegrateRequest
  • func (*IntegrateRequest) Descriptor() ([]byte, []int)
  • func (x *IntegrateRequest) GetIntervalLen() int32
  • func (x *IntegrateRequest) GetPlanId() uint64
  • func (x *IntegrateRequest) GetStartTime() int64
  • func (x *IntegrateRequest) GetStepIntervalTime() int32
  • func (x *IntegrateRequest) GetStressMode() int32
  • func (x *IntegrateRequest) GetStressTime() int32
  • func (x *IntegrateRequest) GetStressType() int32
  • func (x *IntegrateRequest) GetTasks() []*Task
  • func (x *IntegrateRequest) GetUserId() string
  • func (*IntegrateRequest) ProtoMessage()
  • func (x *IntegrateRequest) ProtoReflect() protoreflect.Message
  • func (x *IntegrateRequest) Reset()
  • func (x *IntegrateRequest) String() string
• type IntegrateServiceClient
  • func NewIntegrateServiceClient(cc grpc.ClientConnInterface) IntegrateServiceClient
• type IntegrateServiceServer
• type Task
  • func (*Task) Descriptor() ([]byte, []int)
  • func (x *Task) GetRequestContentLength() int32
  • func (x *Task) GetTaskId() uint64
  • func (x *Task) GetUrl() string
  • func (*Task) ProtoMessage()
  • func (x *Task) ProtoReflect() protoreflect.Message
  • func (x *Task) Reset()
  • func (x *Task) String() string
• type UnimplementedIntegrateServiceServer
  • func (UnimplementedIntegrateServiceServer) Integrate(context.Context, *IntegrateRequest) (*IntegrateReply, error)
• type UnsafeIntegrateServiceServer

Constants

const (
	IntegrateService_Integrate_FullMethodName = "/integrate.IntegrateService/integrate"
)

Variables

var File_api_integrator_v1_integrate_proto protoreflect.FileDescriptor

var IntegrateService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "integrate.IntegrateService",
	HandlerType: (*IntegrateServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "integrate",
			Handler:    _IntegrateService_Integrate_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/integrator/v1/integrate.proto",
}

IntegrateService_ServiceDesc is the grpc.ServiceDesc for IntegrateService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterIntegrateServiceServer

func RegisterIntegrateServiceServer(s grpc.ServiceRegistrar, srv IntegrateServiceServer)

Types

type IntegrateReply

type IntegrateReply struct {
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*IntegrateReply) Descriptor

func (*IntegrateReply) Descriptor() ([]byte, []int)

Deprecated: Use IntegrateReply.ProtoReflect.Descriptor instead.

func (*IntegrateReply) GetCode

func (x *IntegrateReply) GetCode() int32

func (*IntegrateReply) ProtoMessage

func (*IntegrateReply) ProtoMessage()

func (*IntegrateReply) ProtoReflect

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

func (*IntegrateReply) Reset

func (x *IntegrateReply) Reset()

func (*IntegrateReply) String

func (x *IntegrateReply) String() string

type IntegrateRequest

type IntegrateRequest struct {
	PlanId           uint64  `protobuf:"varint,1,opt,name=planId,proto3" json:"planId,omitempty"`
	StressTime       int32   `protobuf:"varint,2,opt,name=stressTime,proto3" json:"stressTime,omitempty"`
	IntervalLen      int32   `protobuf:"varint,3,opt,name=intervalLen,proto3" json:"intervalLen,omitempty"`
	StressType       int32   `protobuf:"varint,4,opt,name=stressType,proto3" json:"stressType,omitempty"`
	StressMode       int32   `protobuf:"varint,5,opt,name=stressMode,proto3" json:"stressMode,omitempty"`
	StartTime        int64   `protobuf:"varint,6,opt,name=startTime,proto3" json:"startTime,omitempty"`
	StepIntervalTime int32   `protobuf:"varint,7,opt,name=stepIntervalTime,proto3" json:"stepIntervalTime,omitempty"`
	UserId           string  `protobuf:"bytes,8,opt,name=userId,proto3" json:"userId,omitempty"`
	Tasks            []*Task `protobuf:"bytes,9,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*IntegrateRequest) Descriptor

func (*IntegrateRequest) Descriptor() ([]byte, []int)

Deprecated: Use IntegrateRequest.ProtoReflect.Descriptor instead.

func (*IntegrateRequest) GetIntervalLen

func (x *IntegrateRequest) GetIntervalLen() int32

func (*IntegrateRequest) GetPlanId

func (x *IntegrateRequest) GetPlanId() uint64

func (*IntegrateRequest) GetStartTime

func (x *IntegrateRequest) GetStartTime() int64

func (*IntegrateRequest) GetStepIntervalTime

func (x *IntegrateRequest) GetStepIntervalTime() int32

func (*IntegrateRequest) GetStressMode

func (x *IntegrateRequest) GetStressMode() int32

func (*IntegrateRequest) GetStressTime

func (x *IntegrateRequest) GetStressTime() int32

func (*IntegrateRequest) GetStressType

func (x *IntegrateRequest) GetStressType() int32

func (*IntegrateRequest) GetTasks

func (x *IntegrateRequest) GetTasks() []*Task

func (*IntegrateRequest) GetUserId

func (x *IntegrateRequest) GetUserId() string

func (*IntegrateRequest) ProtoMessage

func (*IntegrateRequest) ProtoMessage()

func (*IntegrateRequest) ProtoReflect

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

func (*IntegrateRequest) Reset

func (x *IntegrateRequest) Reset()

func (*IntegrateRequest) String

func (x *IntegrateRequest) String() string

type IntegrateServiceClient

type IntegrateServiceClient interface {
	Integrate(ctx context.Context, in *IntegrateRequest, opts ...grpc.CallOption) (*IntegrateReply, error)
}

IntegrateServiceClient is the client API for IntegrateService 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 NewIntegrateServiceClient

func NewIntegrateServiceClient(cc grpc.ClientConnInterface) IntegrateServiceClient

type IntegrateServiceServer

type IntegrateServiceServer interface {
	Integrate(context.Context, *IntegrateRequest) (*IntegrateReply, error)
	// contains filtered or unexported methods
}

IntegrateServiceServer is the server API for IntegrateService service. All implementations must embed UnimplementedIntegrateServiceServer for forward compatibility

type Task

type Task struct {
	TaskId               uint64 `protobuf:"varint,1,opt,name=taskId,proto3" json:"taskId,omitempty"`
	Url                  string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	RequestContentLength int32  `protobuf:"varint,3,opt,name=requestContentLength,proto3" json:"requestContentLength,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor

func (*Task) Descriptor() ([]byte, []int)

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetRequestContentLength

func (x *Task) GetRequestContentLength() int32

func (*Task) GetTaskId

func (x *Task) GetTaskId() uint64

func (*Task) GetUrl

func (x *Task) GetUrl() string

func (*Task) ProtoMessage

func (*Task) ProtoMessage()

func (*Task) ProtoReflect

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

func (*Task) Reset

func (x *Task) Reset()

func (*Task) String

func (x *Task) String() string

type UnimplementedIntegrateServiceServer

type UnimplementedIntegrateServiceServer struct {
}

UnimplementedIntegrateServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedIntegrateServiceServer) Integrate

func (UnimplementedIntegrateServiceServer) Integrate(context.Context, *IntegrateRequest) (*IntegrateReply, error)

type UnsafeIntegrateServiceServer

type UnsafeIntegrateServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeIntegrateServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to IntegrateServiceServer will result in compilation errors.