run

package
v0.0.0-...-a74421f Latest Latest
Warning

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

 Go to latest Published: Oct 8, 2023 License: Apache-2.0 Imports: 8 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	RunningType_name = map[int32]string{
		0: "RunningTypeDefault",
		1: "RunningTypeRun",
		2: "RunningTypeRebalance",
		3: "RunningTypeStop",
	}
	RunningType_value = map[string]int32{
		"RunningTypeDefault":   0,
		"RunningTypeRun":       1,
		"RunningTypeRebalance": 2,
		"RunningTypeStop":      3,
	}
)

Enum value maps for RunningType.

View Source 
var (
	NotifierType_name = map[int32]string{
		0: "Default",
		1: "Feishu",
		2: "Dingtalk",
		3: "Wechat",
		4: "DingtalkText",
		5: "WechatText",
	}
	NotifierType_value = map[string]int32{
		"Default":      0,
		"Feishu":       1,
		"Dingtalk":     2,
		"Wechat":       3,
		"DingtalkText": 4,
		"WechatText":   5,
	}
)

Enum value maps for NotifierType.

View Source 
var (
	CaseType_name = map[int32]string{
		0: "CaseTypeDefault",
		1: "CaseTypeApi",
		2: "CaseTypeStep",
		3: "CaseTypeCases",
		4: "CaseTypeTask",
		5: "CaseTypeBoomerDebug",
		6: "CaseTypeBoomer",
		7: "CaseTypeTag",
	}
	CaseType_value = map[string]int32{
		"CaseTypeDefault":     0,
		"CaseTypeApi":         1,
		"CaseTypeStep":        2,
		"CaseTypeCases":       3,
		"CaseTypeTask":        4,
		"CaseTypeBoomerDebug": 5,
		"CaseTypeBoomer":      6,
		"CaseTypeTag":         7,
	}
)

Enum value maps for CaseType.

View Source 
var (
	RunType_name = map[int32]string{
		0: "RunTypeDefault",
		1: "Debug",
		2: "Runing",
		3: "RunBack",
		4: "RunTimer",
		5: "RunSave",
		6: "CI",
	}
	RunType_value = map[string]int32{
		"RunTypeDefault": 0,
		"Debug":          1,
		"Runing":         2,
		"RunBack":        3,
		"RunTimer":       4,
		"RunSave":        5,
		"CI":             6,
	}
)

Enum value maps for RunType.

View Source 
var File_run_proto protoreflect.FileDescriptor
View Source 
var RunCase_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "run.RunCase",
	HandlerType: (*RunCaseServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RunApi",
			Handler:    _RunCase_RunApi_Handler,
		},
		{
			MethodName: "RunStep",
			Handler:    _RunCase_RunStep_Handler,
		},
		{
			MethodName: "RunCase",
			Handler:    _RunCase_RunCase_Handler,
		},
		{
			MethodName: "RunBoomerDebug",
			Handler:    _RunCase_RunBoomerDebug_Handler,
		},
		{
			MethodName: "RunTimerTask",
			Handler:    _RunCase_RunTimerTask_Handler,
		},
		{
			MethodName: "RunTimerTag",
			Handler:    _RunCase_RunTimerTag_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "run.proto",
}

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

Functions

func RegisterRunCaseServer 

func RegisterRunCaseServer(s grpc.ServiceRegistrar, srv RunCaseServer)

Types

type CaseType 

type CaseType int32
const (
	CaseType_CaseTypeDefault     CaseType = 0 // 默认
	CaseType_CaseTypeApi         CaseType = 1 // api 运行
	CaseType_CaseTypeStep        CaseType = 2 // 步骤运行
	CaseType_CaseTypeCases       CaseType = 3 // 用例运行
	CaseType_CaseTypeTask        CaseType = 4 // 定时任务运行
	CaseType_CaseTypeBoomerDebug CaseType = 5 // 性能任务调试
	CaseType_CaseTypeBoomer      CaseType = 6 // 性能任务运行
	CaseType_CaseTypeTag         CaseType = 7 // 性能任务运行
)

func (CaseType) Descriptor 

func (CaseType) Descriptor() protoreflect.EnumDescriptor

func (CaseType) Enum 

func (x CaseType) Enum() *CaseType

func (CaseType) EnumDescriptor deprecated 

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

Deprecated: Use CaseType.Descriptor instead.

func (CaseType) Number 

func (x CaseType) Number() protoreflect.EnumNumber

func (CaseType) String 

func (x CaseType) String() string

func (CaseType) Type 

func (CaseType) Type() protoreflect.EnumType

type Msg 

type Msg struct {
	Id        uint64       `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name      string       `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Type      NotifierType `protobuf:"varint,3,opt,name=type,proto3,enum=run.NotifierType" json:"type,omitempty"`
	TypeName  string       `protobuf:"bytes,4,opt,name=typeName,proto3" json:"typeName,omitempty"`
	Webhook   string       `protobuf:"bytes,5,opt,name=webhook,proto3" json:"webhook,omitempty"`
	Signature string       `protobuf:"bytes,6,opt,name=signature,proto3" json:"signature,omitempty"`
	Fail      bool         `protobuf:"varint,7,opt,name=fail,proto3" json:"fail,omitempty"`
	// contains filtered or unexported fields
}

func (*Msg) Descriptor deprecated 

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

Deprecated: Use Msg.ProtoReflect.Descriptor instead.

func (*Msg) GetFail 

func (x *Msg) GetFail() bool

func (*Msg) GetId 

func (x *Msg) GetId() uint64

func (*Msg) GetName 

func (x *Msg) GetName() string

func (*Msg) GetSignature 

func (x *Msg) GetSignature() string

func (*Msg) GetType 

func (x *Msg) GetType() NotifierType

func (*Msg) GetTypeName 

func (x *Msg) GetTypeName() string

func (*Msg) GetWebhook 

func (x *Msg) GetWebhook() string

func (*Msg) ProtoMessage 

func (*Msg) ProtoMessage()

func (*Msg) ProtoReflect 

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

func (*Msg) Reset 

func (x *Msg) Reset()

func (*Msg) String 

func (x *Msg) String() string

type NotifierType 

type NotifierType int32
const (
	NotifierType_Default      NotifierType = 0
	NotifierType_Feishu       NotifierType = 1
	NotifierType_Dingtalk     NotifierType = 2
	NotifierType_Wechat       NotifierType = 3
	NotifierType_DingtalkText NotifierType = 4
	NotifierType_WechatText   NotifierType = 5
)

func (NotifierType) Descriptor 

func (NotifierType) Descriptor() protoreflect.EnumDescriptor

func (NotifierType) Enum 

func (x NotifierType) Enum() *NotifierType

func (NotifierType) EnumDescriptor deprecated 

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

Deprecated: Use NotifierType.Descriptor instead.

func (NotifierType) Number 

func (x NotifierType) Number() protoreflect.EnumNumber

func (NotifierType) String 

func (x NotifierType) String() string

func (NotifierType) Type 

func (NotifierType) Type() protoreflect.EnumType

type Operation 

type Operation struct {
	Running    RunningType `protobuf:"varint,1,opt,name=running,proto3,enum=run.RunningType" json:"running,omitempty"`
	SpawnCount int64       `protobuf:"varint,2,opt,name=spawnCount,proto3" json:"spawnCount,omitempty"`
	SpawnRate  float32     `protobuf:"fixed32,3,opt,name=spawnRate,proto3" json:"spawnRate,omitempty"`
	// contains filtered or unexported fields
}

func (*Operation) Descriptor deprecated 

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

Deprecated: Use Operation.ProtoReflect.Descriptor instead.

func (*Operation) GetRunning 

func (x *Operation) GetRunning() RunningType

func (*Operation) GetSpawnCount 

func (x *Operation) GetSpawnCount() int64

func (*Operation) GetSpawnRate 

func (x *Operation) GetSpawnRate() float32

func (*Operation) ProtoMessage 

func (*Operation) ProtoMessage()

func (*Operation) ProtoReflect 

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

func (*Operation) Reset 

func (x *Operation) Reset()

func (*Operation) String 

func (x *Operation) String() string

type RunCaseClient 

type RunCaseClient interface {
	RunApi(ctx context.Context, in *RunCaseReq, opts ...grpc.CallOption) (*RunCaseResponse, error)
	RunStep(ctx context.Context, in *RunCaseReq, opts ...grpc.CallOption) (*RunCaseResponse, error)
	RunCase(ctx context.Context, in *RunCaseReq, opts ...grpc.CallOption) (*RunCaseResponse, error)
	RunBoomerDebug(ctx context.Context, in *RunCaseReq, opts ...grpc.CallOption) (*RunCaseResponse, error)
	RunTimerTask(ctx context.Context, in *RunCaseReq, opts ...grpc.CallOption) (*RunCaseResponse, error)
	RunTimerTag(ctx context.Context, in *RunCaseReq, opts ...grpc.CallOption) (*RunCaseResponse, error)
}

RunCaseClient is the client API for RunCase 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 NewRunCaseClient 

func NewRunCaseClient(cc grpc.ClientConnInterface) RunCaseClient

type RunCaseReq 

type RunCaseReq struct {
	ApiID     uint32     `protobuf:"varint,1,opt,name=apiID,proto3" json:"apiID,omitempty"`
	ConfigID  uint32     `protobuf:"varint,2,opt,name=configID,proto3" json:"configID,omitempty"`
	CaseID    uint32     `protobuf:"varint,3,opt,name=caseID,proto3" json:"caseID,omitempty"`
	RunType   RunType    `protobuf:"varint,4,opt,name=run_type,json=runType,proto3,enum=run.RunType" json:"run_type,omitempty"`
	TaskID    uint32     `protobuf:"varint,5,opt,name=taskID,proto3" json:"taskID,omitempty"`
	Operation *Operation `protobuf:"bytes,6,opt,name=operation,proto3" json:"operation,omitempty"`
	TagID     uint32     `protobuf:"varint,7,opt,name=tagID,proto3" json:"tagID,omitempty"`
	ProjectID uint32     `protobuf:"varint,8,opt,name=projectID,proto3" json:"projectID,omitempty"`
	Env       uint32     `protobuf:"varint,9,opt,name=env,proto3" json:"env,omitempty"`
	ReportID  uint32     `protobuf:"varint,10,opt,name=reportID,proto3" json:"reportID,omitempty"`
	CaseType  CaseType   `protobuf:"varint,11,opt,name=case_type,json=caseType,proto3,enum=run.CaseType" json:"case_type,omitempty"`
	Msg       *Msg       `protobuf:"bytes,12,opt,name=msg,proto3" json:"msg,omitempty"`
	CI        uint32     `protobuf:"varint,13,opt,name=CI,proto3" json:"CI,omitempty"`
	// contains filtered or unexported fields
}

func (*RunCaseReq) Descriptor deprecated 

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

Deprecated: Use RunCaseReq.ProtoReflect.Descriptor instead.

func (*RunCaseReq) GetApiID 

func (x *RunCaseReq) GetApiID() uint32

func (*RunCaseReq) GetCI 

func (x *RunCaseReq) GetCI() uint32

func (*RunCaseReq) GetCaseID 

func (x *RunCaseReq) GetCaseID() uint32

func (*RunCaseReq) GetCaseType 

func (x *RunCaseReq) GetCaseType() CaseType

func (*RunCaseReq) GetConfigID 

func (x *RunCaseReq) GetConfigID() uint32

func (*RunCaseReq) GetEnv 

func (x *RunCaseReq) GetEnv() uint32

func (*RunCaseReq) GetMsg 

func (x *RunCaseReq) GetMsg() *Msg

func (*RunCaseReq) GetOperation 

func (x *RunCaseReq) GetOperation() *Operation

func (*RunCaseReq) GetProjectID 

func (x *RunCaseReq) GetProjectID() uint32

func (*RunCaseReq) GetReportID 

func (x *RunCaseReq) GetReportID() uint32

func (*RunCaseReq) GetRunType 

func (x *RunCaseReq) GetRunType() RunType

func (*RunCaseReq) GetTagID 

func (x *RunCaseReq) GetTagID() uint32

func (*RunCaseReq) GetTaskID 

func (x *RunCaseReq) GetTaskID() uint32

func (*RunCaseReq) ProtoMessage 

func (*RunCaseReq) ProtoMessage()

func (*RunCaseReq) ProtoReflect 

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

func (*RunCaseReq) Reset 

func (x *RunCaseReq) Reset()

func (*RunCaseReq) String 

func (x *RunCaseReq) String() string

type RunCaseResponse 

type RunCaseResponse struct {
	ReportID uint32 `protobuf:"varint,1,opt,name=reportID,proto3" json:"reportID,omitempty"`
	// contains filtered or unexported fields
}

func (*RunCaseResponse) Descriptor deprecated 

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

Deprecated: Use RunCaseResponse.ProtoReflect.Descriptor instead.

func (*RunCaseResponse) GetReportID 

func (x *RunCaseResponse) GetReportID() uint32

func (*RunCaseResponse) ProtoMessage 

func (*RunCaseResponse) ProtoMessage()

func (*RunCaseResponse) ProtoReflect 

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

func (*RunCaseResponse) Reset 

func (x *RunCaseResponse) Reset()

func (*RunCaseResponse) String 

func (x *RunCaseResponse) String() string

type RunCaseServer 

type RunCaseServer interface {
	RunApi(context.Context, *RunCaseReq) (*RunCaseResponse, error)
	RunStep(context.Context, *RunCaseReq) (*RunCaseResponse, error)
	RunCase(context.Context, *RunCaseReq) (*RunCaseResponse, error)
	RunBoomerDebug(context.Context, *RunCaseReq) (*RunCaseResponse, error)
	RunTimerTask(context.Context, *RunCaseReq) (*RunCaseResponse, error)
	RunTimerTag(context.Context, *RunCaseReq) (*RunCaseResponse, error)
	// contains filtered or unexported methods
}

RunCaseServer is the server API for RunCase service. All implementations must embed UnimplementedRunCaseServer for forward compatibility

type RunType 

type RunType int32
const (
	RunType_RunTypeDefault RunType = 0 // 默认
	RunType_Debug          RunType = 1 // 调试模式
	RunType_Runing         RunType = 2 // 立即运行
	RunType_RunBack        RunType = 3 // 后台运行
	RunType_RunTimer       RunType = 4 // 定时执行
	RunType_RunSave        RunType = 5 // 调试并保存
	RunType_CI             RunType = 6 // 调试并保存
)

func (RunType) Descriptor 

func (RunType) Descriptor() protoreflect.EnumDescriptor

func (RunType) Enum 

func (x RunType) Enum() *RunType

func (RunType) EnumDescriptor deprecated 

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

Deprecated: Use RunType.Descriptor instead.

func (RunType) Number 

func (x RunType) Number() protoreflect.EnumNumber

func (RunType) String 

func (x RunType) String() string

func (RunType) Type 

func (RunType) Type() protoreflect.EnumType

type RunningType 

type RunningType int32
const (
	RunningType_RunningTypeDefault   RunningType = 0
	RunningType_RunningTypeRun       RunningType = 1
	RunningType_RunningTypeRebalance RunningType = 2
	RunningType_RunningTypeStop      RunningType = 3
)

func (RunningType) Descriptor 

func (RunningType) Descriptor() protoreflect.EnumDescriptor

func (RunningType) Enum 

func (x RunningType) Enum() *RunningType

func (RunningType) EnumDescriptor deprecated 

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

Deprecated: Use RunningType.Descriptor instead.

func (RunningType) Number 

func (x RunningType) Number() protoreflect.EnumNumber

func (RunningType) String 

func (x RunningType) String() string

func (RunningType) Type 

func (RunningType) Type() protoreflect.EnumType

type UnimplementedRunCaseServer 

type UnimplementedRunCaseServer struct {
}

UnimplementedRunCaseServer must be embedded to have forward compatible implementations.

func (UnimplementedRunCaseServer) RunApi 

func (UnimplementedRunCaseServer) RunApi(context.Context, *RunCaseReq) (*RunCaseResponse, error)

func (UnimplementedRunCaseServer) RunBoomerDebug 

func (UnimplementedRunCaseServer) RunBoomerDebug(context.Context, *RunCaseReq) (*RunCaseResponse, error)

func (UnimplementedRunCaseServer) RunCase 

func (UnimplementedRunCaseServer) RunCase(context.Context, *RunCaseReq) (*RunCaseResponse, error)

func (UnimplementedRunCaseServer) RunStep 

func (UnimplementedRunCaseServer) RunStep(context.Context, *RunCaseReq) (*RunCaseResponse, error)

func (UnimplementedRunCaseServer) RunTimerTag 

func (UnimplementedRunCaseServer) RunTimerTag(context.Context, *RunCaseReq) (*RunCaseResponse, error)

func (UnimplementedRunCaseServer) RunTimerTask 

func (UnimplementedRunCaseServer) RunTimerTask(context.Context, *RunCaseReq) (*RunCaseResponse, error)

type UnsafeRunCaseServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.