agent

package
v0.0.0-...-5fa7aab Latest Latest
Warning

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

Go to latest
Published: May 2, 2024 License: MIT Imports: 14 Imported by: 1

Documentation

Index

Constants

View Source
const (
	AgentRegistrationService_Register_FullMethodName              = "/yandex.cloud.loadtesting.agent.v1.AgentRegistrationService/Register"
	AgentRegistrationService_ExternalAgentRegister_FullMethodName = "/yandex.cloud.loadtesting.agent.v1.AgentRegistrationService/ExternalAgentRegister"
)
View Source
const (
	JobService_ClaimStatus_FullMethodName      = "/yandex.cloud.loadtesting.agent.v1.JobService/ClaimStatus"
	JobService_Get_FullMethodName              = "/yandex.cloud.loadtesting.agent.v1.JobService/Get"
	JobService_GetSignal_FullMethodName        = "/yandex.cloud.loadtesting.agent.v1.JobService/GetSignal"
	JobService_GetTransientFile_FullMethodName = "/yandex.cloud.loadtesting.agent.v1.JobService/GetTransientFile"
)
View Source
const (
	TestService_Get_FullMethodName    = "/yandex.cloud.loadtesting.agent.v1.TestService/Get"
	TestService_Update_FullMethodName = "/yandex.cloud.loadtesting.agent.v1.TestService/Update"
)
View Source
const (
	AgentService_ClaimStatus_FullMethodName = "/yandex.cloud.loadtesting.agent.v1.AgentService/ClaimStatus"
)
View Source
const (
	MonitoringService_AddMetric_FullMethodName = "/yandex.cloud.loadtesting.agent.v1.MonitoringService/AddMetric"
)
View Source
const (
	TrailService_Create_FullMethodName = "/yandex.cloud.loadtesting.agent.v1.TrailService/Create"
)

Variables

View Source
var (
	ClaimAgentStatusRequest_Status_name = map[int32]string{
		0: "STATUS_UNSPECIFIED",
		1: "READY_FOR_TEST",
		2: "PREPARING_TEST",
		3: "TESTING",
		4: "TANK_FAILED",
		5: "STOPPED",
		6: "UPLOADING_ARTIFACTS",
		7: "ERROR",
	}
	ClaimAgentStatusRequest_Status_value = map[string]int32{
		"STATUS_UNSPECIFIED":  0,
		"READY_FOR_TEST":      1,
		"PREPARING_TEST":      2,
		"TESTING":             3,
		"TANK_FAILED":         4,
		"STOPPED":             5,
		"UPLOADING_ARTIFACTS": 6,
		"ERROR":               7,
	}
)

Enum value maps for ClaimAgentStatusRequest_Status.

View Source
var (
	ClaimJobStatusRequest_JobStatus_name = map[int32]string{
		0:  "JOB_STATUS_UNSPECIFIED",
		1:  "POST_PROCESS",
		2:  "INITIATED",
		3:  "PREPARING",
		4:  "NOT_FOUND",
		5:  "RUNNING",
		6:  "FINISHING",
		7:  "FINISHED",
		8:  "STOPPED",
		9:  "FAILED",
		10: "AUTOSTOPPED",
		11: "WAITING_FOR_A_COMMAND_TO_RUN",
	}
	ClaimJobStatusRequest_JobStatus_value = map[string]int32{
		"JOB_STATUS_UNSPECIFIED":       0,
		"POST_PROCESS":                 1,
		"INITIATED":                    2,
		"PREPARING":                    3,
		"NOT_FOUND":                    4,
		"RUNNING":                      5,
		"FINISHING":                    6,
		"FINISHED":                     7,
		"STOPPED":                      8,
		"FAILED":                       9,
		"AUTOSTOPPED":                  10,
		"WAITING_FOR_A_COMMAND_TO_RUN": 11,
	}
)

Enum value maps for ClaimJobStatusRequest_JobStatus.

View Source
var (
	JobSignalResponse_Signal_name = map[int32]string{
		0: "SIGNAL_UNSPECIFIED",
		1: "STOP",
		2: "WAIT",
		3: "RUN_IN",
	}
	JobSignalResponse_Signal_value = map[string]int32{
		"SIGNAL_UNSPECIFIED": 0,
		"STOP":               1,
		"WAIT":               2,
		"RUN_IN":             3,
	}
)

Enum value maps for JobSignalResponse_Signal.

View Source
var (
	Test_Status_name = map[int32]string{
		0:  "STATUS_UNSPECIFIED",
		1:  "CREATED",
		2:  "INITIATED",
		3:  "PREPARING",
		4:  "RUNNING",
		5:  "FINISHING",
		6:  "DONE",
		7:  "POST_PROCESSING",
		8:  "FAILED",
		9:  "STOPPING",
		10: "STOPPED",
		11: "AUTOSTOPPED",
		12: "WAITING",
		13: "DELETING",
		14: "LOST",
	}
	Test_Status_value = map[string]int32{
		"STATUS_UNSPECIFIED": 0,
		"CREATED":            1,
		"INITIATED":          2,
		"PREPARING":          3,
		"RUNNING":            4,
		"FINISHING":          5,
		"DONE":               6,
		"POST_PROCESSING":    7,
		"FAILED":             8,
		"STOPPING":           9,
		"STOPPED":            10,
		"AUTOSTOPPED":        11,
		"WAITING":            12,
		"DELETING":           13,
		"LOST":               14,
	}
)

Enum value maps for Test_Status.

View Source
var (
	Test_Generator_name = map[int32]string{
		0: "GENERATOR_UNSPECIFIED",
		1: "PANDORA",
		2: "PHANTOM",
		3: "JMETER",
	}
	Test_Generator_value = map[string]int32{
		"GENERATOR_UNSPECIFIED": 0,
		"PANDORA":               1,
		"PHANTOM":               2,
		"JMETER":                3,
	}
)

Enum value maps for Test_Generator.

View Source
var AgentRegistrationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yandex.cloud.loadtesting.agent.v1.AgentRegistrationService",
	HandlerType: (*AgentRegistrationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Register",
			Handler:    _AgentRegistrationService_Register_Handler,
		},
		{
			MethodName: "ExternalAgentRegister",
			Handler:    _AgentRegistrationService_ExternalAgentRegister_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "yandex/cloud/loadtesting/agent/v1/agent_registration_service.proto",
}

AgentRegistrationService_ServiceDesc is the grpc.ServiceDesc for AgentRegistrationService 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 AgentService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yandex.cloud.loadtesting.agent.v1.AgentService",
	HandlerType: (*AgentServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ClaimStatus",
			Handler:    _AgentService_ClaimStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "yandex/cloud/loadtesting/agent/v1/agent_service.proto",
}

AgentService_ServiceDesc is the grpc.ServiceDesc for AgentService 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 File_yandex_cloud_loadtesting_agent_v1_agent_proto protoreflect.FileDescriptor
View Source
var File_yandex_cloud_loadtesting_agent_v1_agent_registration_service_proto protoreflect.FileDescriptor
View Source
var File_yandex_cloud_loadtesting_agent_v1_agent_service_proto protoreflect.FileDescriptor
View Source
var File_yandex_cloud_loadtesting_agent_v1_job_service_proto protoreflect.FileDescriptor
View Source
var File_yandex_cloud_loadtesting_agent_v1_monitoring_service_proto protoreflect.FileDescriptor
View Source
var File_yandex_cloud_loadtesting_agent_v1_test_proto protoreflect.FileDescriptor
View Source
var File_yandex_cloud_loadtesting_agent_v1_test_service_proto protoreflect.FileDescriptor
View Source
var File_yandex_cloud_loadtesting_agent_v1_trail_service_proto protoreflect.FileDescriptor
View Source
var JobService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yandex.cloud.loadtesting.agent.v1.JobService",
	HandlerType: (*JobServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ClaimStatus",
			Handler:    _JobService_ClaimStatus_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _JobService_Get_Handler,
		},
		{
			MethodName: "GetSignal",
			Handler:    _JobService_GetSignal_Handler,
		},
		{
			MethodName: "GetTransientFile",
			Handler:    _JobService_GetTransientFile_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "yandex/cloud/loadtesting/agent/v1/job_service.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 MonitoringService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yandex.cloud.loadtesting.agent.v1.MonitoringService",
	HandlerType: (*MonitoringServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AddMetric",
			Handler:    _MonitoringService_AddMetric_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "yandex/cloud/loadtesting/agent/v1/monitoring_service.proto",
}

MonitoringService_ServiceDesc is the grpc.ServiceDesc for MonitoringService 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 TestService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yandex.cloud.loadtesting.agent.v1.TestService",
	HandlerType: (*TestServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _TestService_Get_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _TestService_Update_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "yandex/cloud/loadtesting/agent/v1/test_service.proto",
}

TestService_ServiceDesc is the grpc.ServiceDesc for TestService 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 TrailService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yandex.cloud.loadtesting.agent.v1.TrailService",
	HandlerType: (*TrailServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _TrailService_Create_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "yandex/cloud/loadtesting/agent/v1/trail_service.proto",
}

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

Functions

func RegisterAgentRegistrationServiceServer

func RegisterAgentRegistrationServiceServer(s grpc.ServiceRegistrar, srv AgentRegistrationServiceServer)

func RegisterAgentServiceServer

func RegisterAgentServiceServer(s grpc.ServiceRegistrar, srv AgentServiceServer)

func RegisterJobServiceServer

func RegisterJobServiceServer(s grpc.ServiceRegistrar, srv JobServiceServer)

func RegisterMonitoringServiceServer

func RegisterMonitoringServiceServer(s grpc.ServiceRegistrar, srv MonitoringServiceServer)

func RegisterTestServiceServer

func RegisterTestServiceServer(s grpc.ServiceRegistrar, srv TestServiceServer)

func RegisterTrailServiceServer

func RegisterTrailServiceServer(s grpc.ServiceRegistrar, srv TrailServiceServer)

Types

type AddMetricRequest

type AddMetricRequest struct {
	ComputeInstanceId string         `protobuf:"bytes,1,opt,name=compute_instance_id,json=computeInstanceId,proto3" json:"compute_instance_id,omitempty"`
	JobId             string         `protobuf:"bytes,3,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Chunks            []*MetricChunk `protobuf:"bytes,4,rep,name=chunks,proto3" json:"chunks,omitempty"`
	AgentInstanceId   string         `protobuf:"bytes,5,opt,name=agent_instance_id,json=agentInstanceId,proto3" json:"agent_instance_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AddMetricRequest) Descriptor deprecated

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

Deprecated: Use AddMetricRequest.ProtoReflect.Descriptor instead.

func (*AddMetricRequest) GetAgentInstanceId

func (x *AddMetricRequest) GetAgentInstanceId() string

func (*AddMetricRequest) GetChunks

func (x *AddMetricRequest) GetChunks() []*MetricChunk

func (*AddMetricRequest) GetComputeInstanceId

func (x *AddMetricRequest) GetComputeInstanceId() string

func (*AddMetricRequest) GetJobId

func (x *AddMetricRequest) GetJobId() string

func (*AddMetricRequest) ProtoMessage

func (*AddMetricRequest) ProtoMessage()

func (*AddMetricRequest) ProtoReflect

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

func (*AddMetricRequest) Reset

func (x *AddMetricRequest) Reset()

func (*AddMetricRequest) SetAgentInstanceId

func (m *AddMetricRequest) SetAgentInstanceId(v string)

func (*AddMetricRequest) SetChunks

func (m *AddMetricRequest) SetChunks(v []*MetricChunk)

func (*AddMetricRequest) SetComputeInstanceId

func (m *AddMetricRequest) SetComputeInstanceId(v string)

func (*AddMetricRequest) SetJobId

func (m *AddMetricRequest) SetJobId(v string)

func (*AddMetricRequest) String

func (x *AddMetricRequest) String() string

type AddMetricResponse

type AddMetricResponse struct {
	MetricTrailId string `protobuf:"bytes,1,opt,name=metric_trail_id,json=metricTrailId,proto3" json:"metric_trail_id,omitempty"`
	Code          int64  `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*AddMetricResponse) Descriptor deprecated

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

Deprecated: Use AddMetricResponse.ProtoReflect.Descriptor instead.

func (*AddMetricResponse) GetCode

func (x *AddMetricResponse) GetCode() int64

func (*AddMetricResponse) GetMetricTrailId

func (x *AddMetricResponse) GetMetricTrailId() string

func (*AddMetricResponse) ProtoMessage

func (*AddMetricResponse) ProtoMessage()

func (*AddMetricResponse) ProtoReflect

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

func (*AddMetricResponse) Reset

func (x *AddMetricResponse) Reset()

func (*AddMetricResponse) SetCode

func (m *AddMetricResponse) SetCode(v int64)

func (*AddMetricResponse) SetMetricTrailId

func (m *AddMetricResponse) SetMetricTrailId(v string)

func (*AddMetricResponse) String

func (x *AddMetricResponse) String() string

type AgentInstance

type AgentInstance struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentInstance) Descriptor deprecated

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

Deprecated: Use AgentInstance.ProtoReflect.Descriptor instead.

func (*AgentInstance) GetId

func (x *AgentInstance) GetId() string

func (*AgentInstance) ProtoMessage

func (*AgentInstance) ProtoMessage()

func (*AgentInstance) ProtoReflect

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

func (*AgentInstance) Reset

func (x *AgentInstance) Reset()

func (*AgentInstance) SetId

func (m *AgentInstance) SetId(v string)

func (*AgentInstance) String

func (x *AgentInstance) String() string

type AgentRegistrationServiceClient

type AgentRegistrationServiceClient interface {
	// Registers specified agent.
	Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, error)
	// Registers external agent.
	ExternalAgentRegister(ctx context.Context, in *ExternalAgentRegisterRequest, opts ...grpc.CallOption) (*operation.Operation, error)
}

AgentRegistrationServiceClient is the client API for AgentRegistrationService 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 AgentRegistrationServiceServer

type AgentRegistrationServiceServer interface {
	// Registers specified agent.
	Register(context.Context, *RegisterRequest) (*RegisterResponse, error)
	// Registers external agent.
	ExternalAgentRegister(context.Context, *ExternalAgentRegisterRequest) (*operation.Operation, error)
}

AgentRegistrationServiceServer is the server API for AgentRegistrationService service. All implementations should embed UnimplementedAgentRegistrationServiceServer for forward compatibility

type AgentServiceClient

type AgentServiceClient interface {
	// Claims status for the specified agent.
	ClaimStatus(ctx context.Context, in *ClaimAgentStatusRequest, opts ...grpc.CallOption) (*ClaimAgentStatusResponse, error)
}

AgentServiceClient is the client API for AgentService 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 AgentServiceServer

type AgentServiceServer interface {
	// Claims status for the specified agent.
	ClaimStatus(context.Context, *ClaimAgentStatusRequest) (*ClaimAgentStatusResponse, error)
}

AgentServiceServer is the server API for AgentService service. All implementations should embed UnimplementedAgentServiceServer for forward compatibility

type ClaimAgentStatusRequest

type ClaimAgentStatusRequest struct {
	AgentInstanceId string                         `protobuf:"bytes,1,opt,name=agent_instance_id,json=agentInstanceId,proto3" json:"agent_instance_id,omitempty"`
	Status          ClaimAgentStatusRequest_Status `` /* 136-byte string literal not displayed */
	StatusMessage   string                         `protobuf:"bytes,3,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
	// contains filtered or unexported fields
}

func (*ClaimAgentStatusRequest) Descriptor deprecated

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

Deprecated: Use ClaimAgentStatusRequest.ProtoReflect.Descriptor instead.

func (*ClaimAgentStatusRequest) GetAgentInstanceId

func (x *ClaimAgentStatusRequest) GetAgentInstanceId() string

func (*ClaimAgentStatusRequest) GetStatus

func (*ClaimAgentStatusRequest) GetStatusMessage

func (x *ClaimAgentStatusRequest) GetStatusMessage() string

func (*ClaimAgentStatusRequest) ProtoMessage

func (*ClaimAgentStatusRequest) ProtoMessage()

func (*ClaimAgentStatusRequest) ProtoReflect

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

func (*ClaimAgentStatusRequest) Reset

func (x *ClaimAgentStatusRequest) Reset()

func (*ClaimAgentStatusRequest) SetAgentInstanceId

func (m *ClaimAgentStatusRequest) SetAgentInstanceId(v string)

func (*ClaimAgentStatusRequest) SetStatus

func (*ClaimAgentStatusRequest) SetStatusMessage

func (m *ClaimAgentStatusRequest) SetStatusMessage(v string)

func (*ClaimAgentStatusRequest) String

func (x *ClaimAgentStatusRequest) String() string

type ClaimAgentStatusRequest_Status

type ClaimAgentStatusRequest_Status int32
const (
	ClaimAgentStatusRequest_STATUS_UNSPECIFIED  ClaimAgentStatusRequest_Status = 0
	ClaimAgentStatusRequest_READY_FOR_TEST      ClaimAgentStatusRequest_Status = 1
	ClaimAgentStatusRequest_PREPARING_TEST      ClaimAgentStatusRequest_Status = 2
	ClaimAgentStatusRequest_TESTING             ClaimAgentStatusRequest_Status = 3
	ClaimAgentStatusRequest_TANK_FAILED         ClaimAgentStatusRequest_Status = 4
	ClaimAgentStatusRequest_STOPPED             ClaimAgentStatusRequest_Status = 5
	ClaimAgentStatusRequest_UPLOADING_ARTIFACTS ClaimAgentStatusRequest_Status = 6
	ClaimAgentStatusRequest_ERROR               ClaimAgentStatusRequest_Status = 7
)

func (ClaimAgentStatusRequest_Status) Descriptor

func (ClaimAgentStatusRequest_Status) Enum

func (ClaimAgentStatusRequest_Status) EnumDescriptor deprecated

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

Deprecated: Use ClaimAgentStatusRequest_Status.Descriptor instead.

func (ClaimAgentStatusRequest_Status) Number

func (ClaimAgentStatusRequest_Status) String

func (ClaimAgentStatusRequest_Status) Type

type ClaimAgentStatusResponse

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

func (*ClaimAgentStatusResponse) Descriptor deprecated

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

Deprecated: Use ClaimAgentStatusResponse.ProtoReflect.Descriptor instead.

func (*ClaimAgentStatusResponse) GetCode

func (x *ClaimAgentStatusResponse) GetCode() int64

func (*ClaimAgentStatusResponse) ProtoMessage

func (*ClaimAgentStatusResponse) ProtoMessage()

func (*ClaimAgentStatusResponse) ProtoReflect

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

func (*ClaimAgentStatusResponse) Reset

func (x *ClaimAgentStatusResponse) Reset()

func (*ClaimAgentStatusResponse) SetCode

func (m *ClaimAgentStatusResponse) SetCode(v int64)

func (*ClaimAgentStatusResponse) String

func (x *ClaimAgentStatusResponse) String() string

type ClaimJobStatusRequest

type ClaimJobStatusRequest struct {
	JobId  string                          `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Status ClaimJobStatusRequest_JobStatus `` /* 137-byte string literal not displayed */
	Error  string                          `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ClaimJobStatusRequest) Descriptor deprecated

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

Deprecated: Use ClaimJobStatusRequest.ProtoReflect.Descriptor instead.

func (*ClaimJobStatusRequest) GetError

func (x *ClaimJobStatusRequest) GetError() string

func (*ClaimJobStatusRequest) GetJobId

func (x *ClaimJobStatusRequest) GetJobId() string

func (*ClaimJobStatusRequest) GetStatus

func (*ClaimJobStatusRequest) ProtoMessage

func (*ClaimJobStatusRequest) ProtoMessage()

func (*ClaimJobStatusRequest) ProtoReflect

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

func (*ClaimJobStatusRequest) Reset

func (x *ClaimJobStatusRequest) Reset()

func (*ClaimJobStatusRequest) SetError

func (m *ClaimJobStatusRequest) SetError(v string)

func (*ClaimJobStatusRequest) SetJobId

func (m *ClaimJobStatusRequest) SetJobId(v string)

func (*ClaimJobStatusRequest) SetStatus

func (*ClaimJobStatusRequest) String

func (x *ClaimJobStatusRequest) String() string

type ClaimJobStatusRequest_JobStatus

type ClaimJobStatusRequest_JobStatus int32
const (
	ClaimJobStatusRequest_JOB_STATUS_UNSPECIFIED ClaimJobStatusRequest_JobStatus = 0
	ClaimJobStatusRequest_POST_PROCESS           ClaimJobStatusRequest_JobStatus = 1
	ClaimJobStatusRequest_INITIATED              ClaimJobStatusRequest_JobStatus = 2
	ClaimJobStatusRequest_PREPARING              ClaimJobStatusRequest_JobStatus = 3
	// Deprecated: Marked as deprecated in yandex/cloud/loadtesting/agent/v1/job_service.proto.
	ClaimJobStatusRequest_NOT_FOUND                    ClaimJobStatusRequest_JobStatus = 4
	ClaimJobStatusRequest_RUNNING                      ClaimJobStatusRequest_JobStatus = 5
	ClaimJobStatusRequest_FINISHING                    ClaimJobStatusRequest_JobStatus = 6
	ClaimJobStatusRequest_FINISHED                     ClaimJobStatusRequest_JobStatus = 7
	ClaimJobStatusRequest_STOPPED                      ClaimJobStatusRequest_JobStatus = 8
	ClaimJobStatusRequest_FAILED                       ClaimJobStatusRequest_JobStatus = 9
	ClaimJobStatusRequest_AUTOSTOPPED                  ClaimJobStatusRequest_JobStatus = 10
	ClaimJobStatusRequest_WAITING_FOR_A_COMMAND_TO_RUN ClaimJobStatusRequest_JobStatus = 11
)

func (ClaimJobStatusRequest_JobStatus) Descriptor

func (ClaimJobStatusRequest_JobStatus) Enum

func (ClaimJobStatusRequest_JobStatus) EnumDescriptor deprecated

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

Deprecated: Use ClaimJobStatusRequest_JobStatus.Descriptor instead.

func (ClaimJobStatusRequest_JobStatus) Number

func (ClaimJobStatusRequest_JobStatus) String

func (ClaimJobStatusRequest_JobStatus) Type

type ClaimJobStatusResponse

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

func (*ClaimJobStatusResponse) Descriptor deprecated

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

Deprecated: Use ClaimJobStatusResponse.ProtoReflect.Descriptor instead.

func (*ClaimJobStatusResponse) GetCode

func (x *ClaimJobStatusResponse) GetCode() int64

func (*ClaimJobStatusResponse) ProtoMessage

func (*ClaimJobStatusResponse) ProtoMessage()

func (*ClaimJobStatusResponse) ProtoReflect

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

func (*ClaimJobStatusResponse) Reset

func (x *ClaimJobStatusResponse) Reset()

func (*ClaimJobStatusResponse) SetCode

func (m *ClaimJobStatusResponse) SetCode(v int64)

func (*ClaimJobStatusResponse) String

func (x *ClaimJobStatusResponse) String() string

type CreateTrailRequest

type CreateTrailRequest struct {
	ComputeInstanceId string   `protobuf:"bytes,1,opt,name=compute_instance_id,json=computeInstanceId,proto3" json:"compute_instance_id,omitempty"`
	Data              []*Trail `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
	JobId             string   `protobuf:"bytes,3,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	AgentInstanceId   string   `protobuf:"bytes,4,opt,name=agent_instance_id,json=agentInstanceId,proto3" json:"agent_instance_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTrailRequest) Descriptor deprecated

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

Deprecated: Use CreateTrailRequest.ProtoReflect.Descriptor instead.

func (*CreateTrailRequest) GetAgentInstanceId

func (x *CreateTrailRequest) GetAgentInstanceId() string

func (*CreateTrailRequest) GetComputeInstanceId

func (x *CreateTrailRequest) GetComputeInstanceId() string

func (*CreateTrailRequest) GetData

func (x *CreateTrailRequest) GetData() []*Trail

func (*CreateTrailRequest) GetJobId

func (x *CreateTrailRequest) GetJobId() string

func (*CreateTrailRequest) ProtoMessage

func (*CreateTrailRequest) ProtoMessage()

func (*CreateTrailRequest) ProtoReflect

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

func (*CreateTrailRequest) Reset

func (x *CreateTrailRequest) Reset()

func (*CreateTrailRequest) SetAgentInstanceId

func (m *CreateTrailRequest) SetAgentInstanceId(v string)

func (*CreateTrailRequest) SetComputeInstanceId

func (m *CreateTrailRequest) SetComputeInstanceId(v string)

func (*CreateTrailRequest) SetData

func (m *CreateTrailRequest) SetData(v []*Trail)

func (*CreateTrailRequest) SetJobId

func (m *CreateTrailRequest) SetJobId(v string)

func (*CreateTrailRequest) String

func (x *CreateTrailRequest) String() string

type CreateTrailResponse

type CreateTrailResponse struct {
	TrailId string `protobuf:"bytes,1,opt,name=trail_id,json=trailId,proto3" json:"trail_id,omitempty"`
	Code    int64  `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTrailResponse) Descriptor deprecated

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

Deprecated: Use CreateTrailResponse.ProtoReflect.Descriptor instead.

func (*CreateTrailResponse) GetCode

func (x *CreateTrailResponse) GetCode() int64

func (*CreateTrailResponse) GetTrailId

func (x *CreateTrailResponse) GetTrailId() string

func (*CreateTrailResponse) ProtoMessage

func (*CreateTrailResponse) ProtoMessage()

func (*CreateTrailResponse) ProtoReflect

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

func (*CreateTrailResponse) Reset

func (x *CreateTrailResponse) Reset()

func (*CreateTrailResponse) SetCode

func (m *CreateTrailResponse) SetCode(v int64)

func (*CreateTrailResponse) SetTrailId

func (m *CreateTrailResponse) SetTrailId(v string)

func (*CreateTrailResponse) String

func (x *CreateTrailResponse) String() string

type ExternalAgentRegisterMetadata

type ExternalAgentRegisterMetadata struct {
	AgentInstanceId string `protobuf:"bytes,1,opt,name=agent_instance_id,json=agentInstanceId,proto3" json:"agent_instance_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ExternalAgentRegisterMetadata) Descriptor deprecated

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

Deprecated: Use ExternalAgentRegisterMetadata.ProtoReflect.Descriptor instead.

func (*ExternalAgentRegisterMetadata) GetAgentInstanceId

func (x *ExternalAgentRegisterMetadata) GetAgentInstanceId() string

func (*ExternalAgentRegisterMetadata) ProtoMessage

func (*ExternalAgentRegisterMetadata) ProtoMessage()

func (*ExternalAgentRegisterMetadata) ProtoReflect

func (*ExternalAgentRegisterMetadata) Reset

func (x *ExternalAgentRegisterMetadata) Reset()

func (*ExternalAgentRegisterMetadata) SetAgentInstanceId

func (m *ExternalAgentRegisterMetadata) SetAgentInstanceId(v string)

func (*ExternalAgentRegisterMetadata) String

type ExternalAgentRegisterRequest

type ExternalAgentRegisterRequest struct {
	FolderId          string `protobuf:"bytes,1,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	ComputeInstanceId string `protobuf:"bytes,2,opt,name=compute_instance_id,json=computeInstanceId,proto3" json:"compute_instance_id,omitempty"`
	Name              string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	AgentVersion      string `protobuf:"bytes,4,opt,name=agent_version,json=agentVersion,proto3" json:"agent_version,omitempty"`
	// contains filtered or unexported fields
}

func (*ExternalAgentRegisterRequest) Descriptor deprecated

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

Deprecated: Use ExternalAgentRegisterRequest.ProtoReflect.Descriptor instead.

func (*ExternalAgentRegisterRequest) GetAgentVersion

func (x *ExternalAgentRegisterRequest) GetAgentVersion() string

func (*ExternalAgentRegisterRequest) GetComputeInstanceId

func (x *ExternalAgentRegisterRequest) GetComputeInstanceId() string

func (*ExternalAgentRegisterRequest) GetFolderId

func (x *ExternalAgentRegisterRequest) GetFolderId() string

func (*ExternalAgentRegisterRequest) GetName

func (x *ExternalAgentRegisterRequest) GetName() string

func (*ExternalAgentRegisterRequest) ProtoMessage

func (*ExternalAgentRegisterRequest) ProtoMessage()

func (*ExternalAgentRegisterRequest) ProtoReflect

func (*ExternalAgentRegisterRequest) Reset

func (x *ExternalAgentRegisterRequest) Reset()

func (*ExternalAgentRegisterRequest) SetAgentVersion

func (m *ExternalAgentRegisterRequest) SetAgentVersion(v string)

func (*ExternalAgentRegisterRequest) SetComputeInstanceId

func (m *ExternalAgentRegisterRequest) SetComputeInstanceId(v string)

func (*ExternalAgentRegisterRequest) SetFolderId

func (m *ExternalAgentRegisterRequest) SetFolderId(v string)

func (*ExternalAgentRegisterRequest) SetName

func (m *ExternalAgentRegisterRequest) SetName(v string)

func (*ExternalAgentRegisterRequest) String

type File

type File struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Content []byte `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*File) Descriptor deprecated

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

Deprecated: Use File.ProtoReflect.Descriptor instead.

func (*File) GetContent

func (x *File) GetContent() []byte

func (*File) GetName

func (x *File) GetName() string

func (*File) ProtoMessage

func (*File) ProtoMessage()

func (*File) ProtoReflect

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

func (*File) Reset

func (x *File) Reset()

func (*File) SetContent

func (m *File) SetContent(v []byte)

func (*File) SetName

func (m *File) SetName(v string)

func (*File) String

func (x *File) String() string

type GetJobRequest

type GetJobRequest struct {
	ComputeInstanceId string `protobuf:"bytes,1,opt,name=compute_instance_id,json=computeInstanceId,proto3" json:"compute_instance_id,omitempty"`
	AgentInstanceId   string `protobuf:"bytes,2,opt,name=agent_instance_id,json=agentInstanceId,proto3" json:"agent_instance_id,omitempty"`
	JobId             string `protobuf:"bytes,3,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobRequest) Descriptor deprecated

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

Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead.

func (*GetJobRequest) GetAgentInstanceId

func (x *GetJobRequest) GetAgentInstanceId() string

func (*GetJobRequest) GetComputeInstanceId

func (x *GetJobRequest) GetComputeInstanceId() string

func (*GetJobRequest) GetJobId

func (x *GetJobRequest) GetJobId() string

func (*GetJobRequest) ProtoMessage

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) ProtoReflect

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

func (*GetJobRequest) Reset

func (x *GetJobRequest) Reset()

func (*GetJobRequest) SetAgentInstanceId

func (m *GetJobRequest) SetAgentInstanceId(v string)

func (*GetJobRequest) SetComputeInstanceId

func (m *GetJobRequest) SetComputeInstanceId(v string)

func (*GetJobRequest) SetJobId

func (m *GetJobRequest) SetJobId(v string)

func (*GetJobRequest) String

func (x *GetJobRequest) String() string

type GetJobTransientFile

type GetJobTransientFile struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Name  string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobTransientFile) Descriptor deprecated

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

Deprecated: Use GetJobTransientFile.ProtoReflect.Descriptor instead.

func (*GetJobTransientFile) GetJobId

func (x *GetJobTransientFile) GetJobId() string

func (*GetJobTransientFile) GetName

func (x *GetJobTransientFile) GetName() string

func (*GetJobTransientFile) ProtoMessage

func (*GetJobTransientFile) ProtoMessage()

func (*GetJobTransientFile) ProtoReflect

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

func (*GetJobTransientFile) Reset

func (x *GetJobTransientFile) Reset()

func (*GetJobTransientFile) SetJobId

func (m *GetJobTransientFile) SetJobId(v string)

func (*GetJobTransientFile) SetName

func (m *GetJobTransientFile) SetName(v string)

func (*GetJobTransientFile) String

func (x *GetJobTransientFile) String() string

type GetTestRequest

type GetTestRequest struct {
	TestId string `protobuf:"bytes,1,opt,name=test_id,json=testId,proto3" json:"test_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTestRequest) Descriptor deprecated

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

Deprecated: Use GetTestRequest.ProtoReflect.Descriptor instead.

func (*GetTestRequest) GetTestId

func (x *GetTestRequest) GetTestId() string

func (*GetTestRequest) ProtoMessage

func (*GetTestRequest) ProtoMessage()

func (*GetTestRequest) ProtoReflect

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

func (*GetTestRequest) Reset

func (x *GetTestRequest) Reset()

func (*GetTestRequest) SetTestId

func (m *GetTestRequest) SetTestId(v string)

func (*GetTestRequest) String

func (x *GetTestRequest) String() string

type Job

type Job struct {
	Id                     string                      `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Config                 string                      `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	Ammo                   *File                       `protobuf:"bytes,3,opt,name=ammo,proto3" json:"ammo,omitempty"`
	LoggingLogGroupId      string                      `protobuf:"bytes,4,opt,name=logging_log_group_id,json=loggingLogGroupId,proto3" json:"logging_log_group_id,omitempty"`
	TestData               *StorageObject              `protobuf:"bytes,5,opt,name=test_data,json=testData,proto3" json:"test_data,omitempty"`
	DataPayload            []*TestDataEntry            `protobuf:"bytes,6,rep,name=data_payload,json=dataPayload,proto3" json:"data_payload,omitempty"`
	ArtifactUploadSettings *TestArtifactUploadSettings `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Job) Descriptor deprecated

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetAmmo

func (x *Job) GetAmmo() *File

func (*Job) GetArtifactUploadSettings

func (x *Job) GetArtifactUploadSettings() *TestArtifactUploadSettings

func (*Job) GetConfig

func (x *Job) GetConfig() string

func (*Job) GetDataPayload

func (x *Job) GetDataPayload() []*TestDataEntry

func (*Job) GetId

func (x *Job) GetId() string

func (*Job) GetLoggingLogGroupId

func (x *Job) GetLoggingLogGroupId() string

func (*Job) GetTestData

func (x *Job) GetTestData() *StorageObject

func (*Job) ProtoMessage

func (*Job) ProtoMessage()

func (*Job) ProtoReflect

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

func (*Job) Reset

func (x *Job) Reset()

func (*Job) SetAmmo

func (m *Job) SetAmmo(v *File)

func (*Job) SetArtifactUploadSettings

func (m *Job) SetArtifactUploadSettings(v *TestArtifactUploadSettings)

func (*Job) SetConfig

func (m *Job) SetConfig(v string)

func (*Job) SetDataPayload

func (m *Job) SetDataPayload(v []*TestDataEntry)

func (*Job) SetId

func (m *Job) SetId(v string)

func (*Job) SetLoggingLogGroupId

func (m *Job) SetLoggingLogGroupId(v string)

func (*Job) SetTestData

func (m *Job) SetTestData(v *StorageObject)

func (*Job) String

func (x *Job) String() string

type JobServiceClient

type JobServiceClient interface {
	// Claims status for the specified job.
	ClaimStatus(ctx context.Context, in *ClaimJobStatusRequest, opts ...grpc.CallOption) (*ClaimJobStatusResponse, error)
	// Returns the job for the specified agent.
	Get(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error)
	// Returns the signal for the specified job.
	GetSignal(ctx context.Context, in *JobSignalRequest, opts ...grpc.CallOption) (*JobSignalResponse, error)
	GetTransientFile(ctx context.Context, in *GetJobTransientFile, opts ...grpc.CallOption) (*File, 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 {
	// Claims status for the specified job.
	ClaimStatus(context.Context, *ClaimJobStatusRequest) (*ClaimJobStatusResponse, error)
	// Returns the job for the specified agent.
	Get(context.Context, *GetJobRequest) (*Job, error)
	// Returns the signal for the specified job.
	GetSignal(context.Context, *JobSignalRequest) (*JobSignalResponse, error)
	GetTransientFile(context.Context, *GetJobTransientFile) (*File, error)
}

JobServiceServer is the server API for JobService service. All implementations should embed UnimplementedJobServiceServer for forward compatibility

type JobSignalRequest

type JobSignalRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*JobSignalRequest) Descriptor deprecated

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

Deprecated: Use JobSignalRequest.ProtoReflect.Descriptor instead.

func (*JobSignalRequest) GetJobId

func (x *JobSignalRequest) GetJobId() string

func (*JobSignalRequest) ProtoMessage

func (*JobSignalRequest) ProtoMessage()

func (*JobSignalRequest) ProtoReflect

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

func (*JobSignalRequest) Reset

func (x *JobSignalRequest) Reset()

func (*JobSignalRequest) SetJobId

func (m *JobSignalRequest) SetJobId(v string)

func (*JobSignalRequest) String

func (x *JobSignalRequest) String() string

type JobSignalResponse

type JobSignalResponse struct {
	Signal       JobSignalResponse_Signal ``                                                                                                    /* 130-byte string literal not displayed */
	WaitDuration float64                  `protobuf:"fixed64,2,opt,name=wait_duration,json=waitDuration,proto3" json:"wait_duration,omitempty"` // seconds
	RunIn        float64                  `protobuf:"fixed64,3,opt,name=run_in,json=runIn,proto3" json:"run_in,omitempty"`                      // seconds
	// contains filtered or unexported fields
}

func (*JobSignalResponse) Descriptor deprecated

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

Deprecated: Use JobSignalResponse.ProtoReflect.Descriptor instead.

func (*JobSignalResponse) GetRunIn

func (x *JobSignalResponse) GetRunIn() float64

func (*JobSignalResponse) GetSignal

func (*JobSignalResponse) GetWaitDuration

func (x *JobSignalResponse) GetWaitDuration() float64

func (*JobSignalResponse) ProtoMessage

func (*JobSignalResponse) ProtoMessage()

func (*JobSignalResponse) ProtoReflect

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

func (*JobSignalResponse) Reset

func (x *JobSignalResponse) Reset()

func (*JobSignalResponse) SetRunIn

func (m *JobSignalResponse) SetRunIn(v float64)

func (*JobSignalResponse) SetSignal

func (*JobSignalResponse) SetWaitDuration

func (m *JobSignalResponse) SetWaitDuration(v float64)

func (*JobSignalResponse) String

func (x *JobSignalResponse) String() string

type JobSignalResponse_Signal

type JobSignalResponse_Signal int32
const (
	JobSignalResponse_SIGNAL_UNSPECIFIED JobSignalResponse_Signal = 0
	JobSignalResponse_STOP               JobSignalResponse_Signal = 1
	JobSignalResponse_WAIT               JobSignalResponse_Signal = 2
	JobSignalResponse_RUN_IN             JobSignalResponse_Signal = 3
)

func (JobSignalResponse_Signal) Descriptor

func (JobSignalResponse_Signal) Enum

func (JobSignalResponse_Signal) EnumDescriptor deprecated

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

Deprecated: Use JobSignalResponse_Signal.Descriptor instead.

func (JobSignalResponse_Signal) Number

func (JobSignalResponse_Signal) String

func (x JobSignalResponse_Signal) String() string

func (JobSignalResponse_Signal) Type

type Metric

type Metric struct {
	MetricType  string  `protobuf:"bytes,1,opt,name=metric_type,json=metricType,proto3" json:"metric_type,omitempty"`
	MetricName  string  `protobuf:"bytes,2,opt,name=metric_name,json=metricName,proto3" json:"metric_name,omitempty"`
	MetricValue float64 `protobuf:"fixed64,3,opt,name=metric_value,json=metricValue,proto3" json:"metric_value,omitempty"`
	// contains filtered or unexported fields
}

func (*Metric) Descriptor deprecated

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

Deprecated: Use Metric.ProtoReflect.Descriptor instead.

func (*Metric) GetMetricName

func (x *Metric) GetMetricName() string

func (*Metric) GetMetricType

func (x *Metric) GetMetricType() string

func (*Metric) GetMetricValue

func (x *Metric) GetMetricValue() float64

func (*Metric) ProtoMessage

func (*Metric) ProtoMessage()

func (*Metric) ProtoReflect

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

func (*Metric) Reset

func (x *Metric) Reset()

func (*Metric) SetMetricName

func (m *Metric) SetMetricName(v string)

func (*Metric) SetMetricType

func (m *Metric) SetMetricType(v string)

func (*Metric) SetMetricValue

func (m *Metric) SetMetricValue(v float64)

func (*Metric) String

func (x *Metric) String() string

type MetricChunk

type MetricChunk struct {
	Data         []*Metric `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	Timestamp    int64     `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Comment      string    `protobuf:"bytes,3,opt,name=comment,proto3" json:"comment,omitempty"`
	InstanceHost string    `protobuf:"bytes,4,opt,name=instance_host,json=instanceHost,proto3" json:"instance_host,omitempty"`
	// contains filtered or unexported fields
}

func (*MetricChunk) Descriptor deprecated

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

Deprecated: Use MetricChunk.ProtoReflect.Descriptor instead.

func (*MetricChunk) GetComment

func (x *MetricChunk) GetComment() string

func (*MetricChunk) GetData

func (x *MetricChunk) GetData() []*Metric

func (*MetricChunk) GetInstanceHost

func (x *MetricChunk) GetInstanceHost() string

func (*MetricChunk) GetTimestamp

func (x *MetricChunk) GetTimestamp() int64

func (*MetricChunk) ProtoMessage

func (*MetricChunk) ProtoMessage()

func (*MetricChunk) ProtoReflect

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

func (*MetricChunk) Reset

func (x *MetricChunk) Reset()

func (*MetricChunk) SetComment

func (m *MetricChunk) SetComment(v string)

func (*MetricChunk) SetData

func (m *MetricChunk) SetData(v []*Metric)

func (*MetricChunk) SetInstanceHost

func (m *MetricChunk) SetInstanceHost(v string)

func (*MetricChunk) SetTimestamp

func (m *MetricChunk) SetTimestamp(v int64)

func (*MetricChunk) String

func (x *MetricChunk) String() string

type MonitoringServiceClient

type MonitoringServiceClient interface {
	// Saves monitoring events for specified job
	AddMetric(ctx context.Context, in *AddMetricRequest, opts ...grpc.CallOption) (*AddMetricResponse, error)
}

MonitoringServiceClient is the client API for MonitoringService 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 MonitoringServiceServer

type MonitoringServiceServer interface {
	// Saves monitoring events for specified job
	AddMetric(context.Context, *AddMetricRequest) (*AddMetricResponse, error)
}

MonitoringServiceServer is the server API for MonitoringService service. All implementations should embed UnimplementedMonitoringServiceServer for forward compatibility

type RegisterRequest

type RegisterRequest struct {
	ComputeInstanceId string `protobuf:"bytes,1,opt,name=compute_instance_id,json=computeInstanceId,proto3" json:"compute_instance_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterRequest) Descriptor deprecated

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

Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.

func (*RegisterRequest) GetComputeInstanceId

func (x *RegisterRequest) GetComputeInstanceId() string

func (*RegisterRequest) ProtoMessage

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) ProtoReflect

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

func (*RegisterRequest) Reset

func (x *RegisterRequest) Reset()

func (*RegisterRequest) SetComputeInstanceId

func (m *RegisterRequest) SetComputeInstanceId(v string)

func (*RegisterRequest) String

func (x *RegisterRequest) String() string

type RegisterResponse

type RegisterResponse struct {
	AgentInstanceId string `protobuf:"bytes,1,opt,name=agent_instance_id,json=agentInstanceId,proto3" json:"agent_instance_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterResponse) Descriptor deprecated

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

Deprecated: Use RegisterResponse.ProtoReflect.Descriptor instead.

func (*RegisterResponse) GetAgentInstanceId

func (x *RegisterResponse) GetAgentInstanceId() string

func (*RegisterResponse) ProtoMessage

func (*RegisterResponse) ProtoMessage()

func (*RegisterResponse) ProtoReflect

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

func (*RegisterResponse) Reset

func (x *RegisterResponse) Reset()

func (*RegisterResponse) SetAgentInstanceId

func (m *RegisterResponse) SetAgentInstanceId(v string)

func (*RegisterResponse) String

func (x *RegisterResponse) String() string

type StorageObject

type StorageObject struct {
	ObjectStorageBucket   string `protobuf:"bytes,1,opt,name=object_storage_bucket,json=objectStorageBucket,proto3" json:"object_storage_bucket,omitempty"`
	ObjectStorageFilename string `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StorageObject) Descriptor deprecated

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

Deprecated: Use StorageObject.ProtoReflect.Descriptor instead.

func (*StorageObject) GetObjectStorageBucket

func (x *StorageObject) GetObjectStorageBucket() string

func (*StorageObject) GetObjectStorageFilename

func (x *StorageObject) GetObjectStorageFilename() string

func (*StorageObject) ProtoMessage

func (*StorageObject) ProtoMessage()

func (*StorageObject) ProtoReflect

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

func (*StorageObject) Reset

func (x *StorageObject) Reset()

func (*StorageObject) SetObjectStorageBucket

func (m *StorageObject) SetObjectStorageBucket(v string)

func (*StorageObject) SetObjectStorageFilename

func (m *StorageObject) SetObjectStorageFilename(v string)

func (*StorageObject) String

func (x *StorageObject) String() string

type Test

type Test struct {
	Id          string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	FolderId    string                 `protobuf:"bytes,2,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	Name        string                 `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Description string                 `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Labels      map[string]string      `` /* 153-byte string literal not displayed */
	CreatedAt   *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	StartedAt   *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	FinishedAt  *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	UpdatedAt   *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	Generator   Test_Generator         `` /* 127-byte string literal not displayed */
	// AgentInstance ID where Test is running.
	AgentInstanceId string `protobuf:"bytes,11,opt,name=agent_instance_id,json=agentInstanceId,proto3" json:"agent_instance_id,omitempty"`
	// Target VM.
	TargetAddress string `protobuf:"bytes,12,opt,name=target_address,json=targetAddress,proto3" json:"target_address,omitempty"`
	TargetPort    int64  `protobuf:"varint,13,opt,name=target_port,json=targetPort,proto3" json:"target_port,omitempty"`
	// Version of object under test.
	TargetVersion string `protobuf:"bytes,14,opt,name=target_version,json=targetVersion,proto3" json:"target_version,omitempty"`
	// Test details
	Config string `protobuf:"bytes,15,opt,name=config,proto3" json:"config,omitempty"`
	// Types that are assignable to Ammo:
	//
	//	*Test_AmmoUrls
	//	*Test_AmmoId
	Ammo     isTest_Ammo `protobuf_oneof:"ammo"`
	Cases    []string    `protobuf:"bytes,18,rep,name=cases,proto3" json:"cases,omitempty"`
	Status   Test_Status `protobuf:"varint,19,opt,name=status,proto3,enum=yandex.cloud.loadtesting.agent.v1.Test_Status" json:"status,omitempty"`
	Errors   []string    `protobuf:"bytes,20,rep,name=errors,proto3" json:"errors,omitempty"`
	Favorite bool        `protobuf:"varint,21,opt,name=favorite,proto3" json:"favorite,omitempty"`
	// contains filtered or unexported fields
}

func (*Test) Descriptor deprecated

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

Deprecated: Use Test.ProtoReflect.Descriptor instead.

func (*Test) GetAgentInstanceId

func (x *Test) GetAgentInstanceId() string

func (*Test) GetAmmo

func (m *Test) GetAmmo() isTest_Ammo

func (*Test) GetAmmoId

func (x *Test) GetAmmoId() string

func (*Test) GetAmmoUrls

func (x *Test) GetAmmoUrls() string

func (*Test) GetCases

func (x *Test) GetCases() []string

func (*Test) GetConfig

func (x *Test) GetConfig() string

func (*Test) GetCreatedAt

func (x *Test) GetCreatedAt() *timestamppb.Timestamp

func (*Test) GetDescription

func (x *Test) GetDescription() string

func (*Test) GetErrors

func (x *Test) GetErrors() []string

func (*Test) GetFavorite

func (x *Test) GetFavorite() bool

func (*Test) GetFinishedAt

func (x *Test) GetFinishedAt() *timestamppb.Timestamp

func (*Test) GetFolderId

func (x *Test) GetFolderId() string

func (*Test) GetGenerator

func (x *Test) GetGenerator() Test_Generator

func (*Test) GetId

func (x *Test) GetId() string

func (*Test) GetLabels

func (x *Test) GetLabels() map[string]string

func (*Test) GetName

func (x *Test) GetName() string

func (*Test) GetStartedAt

func (x *Test) GetStartedAt() *timestamppb.Timestamp

func (*Test) GetStatus

func (x *Test) GetStatus() Test_Status

func (*Test) GetTargetAddress

func (x *Test) GetTargetAddress() string

func (*Test) GetTargetPort

func (x *Test) GetTargetPort() int64

func (*Test) GetTargetVersion

func (x *Test) GetTargetVersion() string

func (*Test) GetUpdatedAt

func (x *Test) GetUpdatedAt() *timestamppb.Timestamp

func (*Test) ProtoMessage

func (*Test) ProtoMessage()

func (*Test) ProtoReflect

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

func (*Test) Reset

func (x *Test) Reset()

func (*Test) SetAgentInstanceId

func (m *Test) SetAgentInstanceId(v string)

func (*Test) SetAmmo

func (m *Test) SetAmmo(v Test_Ammo)

func (*Test) SetAmmoId

func (m *Test) SetAmmoId(v string)

func (*Test) SetAmmoUrls

func (m *Test) SetAmmoUrls(v string)

func (*Test) SetCases

func (m *Test) SetCases(v []string)

func (*Test) SetConfig

func (m *Test) SetConfig(v string)

func (*Test) SetCreatedAt

func (m *Test) SetCreatedAt(v *timestamppb.Timestamp)

func (*Test) SetDescription

func (m *Test) SetDescription(v string)

func (*Test) SetErrors

func (m *Test) SetErrors(v []string)

func (*Test) SetFavorite

func (m *Test) SetFavorite(v bool)

func (*Test) SetFinishedAt

func (m *Test) SetFinishedAt(v *timestamppb.Timestamp)

func (*Test) SetFolderId

func (m *Test) SetFolderId(v string)

func (*Test) SetGenerator

func (m *Test) SetGenerator(v Test_Generator)

func (*Test) SetId

func (m *Test) SetId(v string)

func (*Test) SetLabels

func (m *Test) SetLabels(v map[string]string)

func (*Test) SetName

func (m *Test) SetName(v string)

func (*Test) SetStartedAt

func (m *Test) SetStartedAt(v *timestamppb.Timestamp)

func (*Test) SetStatus

func (m *Test) SetStatus(v Test_Status)

func (*Test) SetTargetAddress

func (m *Test) SetTargetAddress(v string)

func (*Test) SetTargetPort

func (m *Test) SetTargetPort(v int64)

func (*Test) SetTargetVersion

func (m *Test) SetTargetVersion(v string)

func (*Test) SetUpdatedAt

func (m *Test) SetUpdatedAt(v *timestamppb.Timestamp)

func (*Test) String

func (x *Test) String() string

type TestArtifactUploadSettings

type TestArtifactUploadSettings struct {
	OutputBucket  string   `protobuf:"bytes,1,opt,name=output_bucket,json=outputBucket,proto3" json:"output_bucket,omitempty"`
	OutputName    string   `protobuf:"bytes,2,opt,name=output_name,json=outputName,proto3" json:"output_name,omitempty"`
	IsArchive     bool     `protobuf:"varint,3,opt,name=is_archive,json=isArchive,proto3" json:"is_archive,omitempty"`
	FilterInclude []string `protobuf:"bytes,4,rep,name=filter_include,json=filterInclude,proto3" json:"filter_include,omitempty"`
	FilterExclude []string `protobuf:"bytes,5,rep,name=filter_exclude,json=filterExclude,proto3" json:"filter_exclude,omitempty"`
	// contains filtered or unexported fields
}

func (*TestArtifactUploadSettings) Descriptor deprecated

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

Deprecated: Use TestArtifactUploadSettings.ProtoReflect.Descriptor instead.

func (*TestArtifactUploadSettings) GetFilterExclude

func (x *TestArtifactUploadSettings) GetFilterExclude() []string

func (*TestArtifactUploadSettings) GetFilterInclude

func (x *TestArtifactUploadSettings) GetFilterInclude() []string

func (*TestArtifactUploadSettings) GetIsArchive

func (x *TestArtifactUploadSettings) GetIsArchive() bool

func (*TestArtifactUploadSettings) GetOutputBucket

func (x *TestArtifactUploadSettings) GetOutputBucket() string

func (*TestArtifactUploadSettings) GetOutputName

func (x *TestArtifactUploadSettings) GetOutputName() string

func (*TestArtifactUploadSettings) ProtoMessage

func (*TestArtifactUploadSettings) ProtoMessage()

func (*TestArtifactUploadSettings) ProtoReflect

func (*TestArtifactUploadSettings) Reset

func (x *TestArtifactUploadSettings) Reset()

func (*TestArtifactUploadSettings) SetFilterExclude

func (m *TestArtifactUploadSettings) SetFilterExclude(v []string)

func (*TestArtifactUploadSettings) SetFilterInclude

func (m *TestArtifactUploadSettings) SetFilterInclude(v []string)

func (*TestArtifactUploadSettings) SetIsArchive

func (m *TestArtifactUploadSettings) SetIsArchive(v bool)

func (*TestArtifactUploadSettings) SetOutputBucket

func (m *TestArtifactUploadSettings) SetOutputBucket(v string)

func (*TestArtifactUploadSettings) SetOutputName

func (m *TestArtifactUploadSettings) SetOutputName(v string)

func (*TestArtifactUploadSettings) String

func (x *TestArtifactUploadSettings) String() string

type TestDataEntry

type TestDataEntry struct {
	Name          string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	IsTransient   bool           `protobuf:"varint,2,opt,name=is_transient,json=isTransient,proto3" json:"is_transient,omitempty"`
	StorageObject *StorageObject `protobuf:"bytes,3,opt,name=storage_object,json=storageObject,proto3" json:"storage_object,omitempty"`
	// contains filtered or unexported fields
}

func (*TestDataEntry) Descriptor deprecated

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

Deprecated: Use TestDataEntry.ProtoReflect.Descriptor instead.

func (*TestDataEntry) GetIsTransient

func (x *TestDataEntry) GetIsTransient() bool

func (*TestDataEntry) GetName

func (x *TestDataEntry) GetName() string

func (*TestDataEntry) GetStorageObject

func (x *TestDataEntry) GetStorageObject() *StorageObject

func (*TestDataEntry) ProtoMessage

func (*TestDataEntry) ProtoMessage()

func (*TestDataEntry) ProtoReflect

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

func (*TestDataEntry) Reset

func (x *TestDataEntry) Reset()

func (*TestDataEntry) SetIsTransient

func (m *TestDataEntry) SetIsTransient(v bool)

func (*TestDataEntry) SetName

func (m *TestDataEntry) SetName(v string)

func (*TestDataEntry) SetStorageObject

func (m *TestDataEntry) SetStorageObject(v *StorageObject)

func (*TestDataEntry) String

func (x *TestDataEntry) String() string

type TestServiceClient

type TestServiceClient interface {
	// Returns test by test id.
	Get(ctx context.Context, in *GetTestRequest, opts ...grpc.CallOption) (*Test, error)
	// Updates the specified test.
	Update(ctx context.Context, in *UpdateTestRequest, opts ...grpc.CallOption) (*operation.Operation, error)
}

TestServiceClient is the client API for TestService 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 TestServiceServer

type TestServiceServer interface {
	// Returns test by test id.
	Get(context.Context, *GetTestRequest) (*Test, error)
	// Updates the specified test.
	Update(context.Context, *UpdateTestRequest) (*operation.Operation, error)
}

TestServiceServer is the server API for TestService service. All implementations should embed UnimplementedTestServiceServer for forward compatibility

type Test_Ammo

type Test_Ammo = isTest_Ammo

type Test_AmmoId

type Test_AmmoId struct {
	AmmoId string `protobuf:"bytes,17,opt,name=ammo_id,json=ammoId,proto3,oneof"`
}

type Test_AmmoUrls

type Test_AmmoUrls struct {
	AmmoUrls string `protobuf:"bytes,16,opt,name=ammo_urls,json=ammoUrls,proto3,oneof"`
}

type Test_Generator

type Test_Generator int32
const (
	Test_GENERATOR_UNSPECIFIED Test_Generator = 0
	Test_PANDORA               Test_Generator = 1
	Test_PHANTOM               Test_Generator = 2
	Test_JMETER                Test_Generator = 3
)

func (Test_Generator) Descriptor

func (Test_Generator) Enum

func (x Test_Generator) Enum() *Test_Generator

func (Test_Generator) EnumDescriptor deprecated

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

Deprecated: Use Test_Generator.Descriptor instead.

func (Test_Generator) Number

func (Test_Generator) String

func (x Test_Generator) String() string

func (Test_Generator) Type

type Test_Status

type Test_Status int32
const (
	Test_STATUS_UNSPECIFIED Test_Status = 0
	Test_CREATED            Test_Status = 1
	Test_INITIATED          Test_Status = 2
	Test_PREPARING          Test_Status = 3
	Test_RUNNING            Test_Status = 4
	Test_FINISHING          Test_Status = 5
	Test_DONE               Test_Status = 6
	Test_POST_PROCESSING    Test_Status = 7
	Test_FAILED             Test_Status = 8
	Test_STOPPING           Test_Status = 9
	Test_STOPPED            Test_Status = 10
	Test_AUTOSTOPPED        Test_Status = 11
	Test_WAITING            Test_Status = 12
	Test_DELETING           Test_Status = 13
	Test_LOST               Test_Status = 14
)

func (Test_Status) Descriptor

func (Test_Status) Enum

func (x Test_Status) Enum() *Test_Status

func (Test_Status) EnumDescriptor deprecated

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

Deprecated: Use Test_Status.Descriptor instead.

func (Test_Status) Number

func (x Test_Status) Number() protoreflect.EnumNumber

func (Test_Status) String

func (x Test_Status) String() string

func (Test_Status) Type

type Trail

type Trail struct {
	Overall       int64              `protobuf:"varint,1,opt,name=overall,proto3" json:"overall,omitempty"`
	CaseId        string             `protobuf:"bytes,2,opt,name=case_id,json=caseId,proto3" json:"case_id,omitempty"`
	Time          string             `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	Reqps         int64              `protobuf:"varint,4,opt,name=reqps,proto3" json:"reqps,omitempty"`
	Resps         int64              `protobuf:"varint,5,opt,name=resps,proto3" json:"resps,omitempty"`
	Expect        float64            `protobuf:"fixed64,6,opt,name=expect,proto3" json:"expect,omitempty"`
	Input         int64              `protobuf:"varint,7,opt,name=input,proto3" json:"input,omitempty"`
	Output        int64              `protobuf:"varint,8,opt,name=output,proto3" json:"output,omitempty"`
	ConnectTime   float64            `protobuf:"fixed64,9,opt,name=connect_time,json=connectTime,proto3" json:"connect_time,omitempty"`
	SendTime      float64            `protobuf:"fixed64,10,opt,name=send_time,json=sendTime,proto3" json:"send_time,omitempty"`
	Latency       float64            `protobuf:"fixed64,11,opt,name=latency,proto3" json:"latency,omitempty"`
	ReceiveTime   float64            `protobuf:"fixed64,12,opt,name=receive_time,json=receiveTime,proto3" json:"receive_time,omitempty"`
	Threads       int64              `protobuf:"varint,13,opt,name=threads,proto3" json:"threads,omitempty"`
	Q50           float64            `protobuf:"fixed64,14,opt,name=q50,proto3" json:"q50,omitempty"`
	Q75           float64            `protobuf:"fixed64,15,opt,name=q75,proto3" json:"q75,omitempty"`
	Q80           float64            `protobuf:"fixed64,16,opt,name=q80,proto3" json:"q80,omitempty"`
	Q85           float64            `protobuf:"fixed64,17,opt,name=q85,proto3" json:"q85,omitempty"`
	Q90           float64            `protobuf:"fixed64,18,opt,name=q90,proto3" json:"q90,omitempty"`
	Q95           float64            `protobuf:"fixed64,19,opt,name=q95,proto3" json:"q95,omitempty"`
	Q98           float64            `protobuf:"fixed64,20,opt,name=q98,proto3" json:"q98,omitempty"`
	Q99           float64            `protobuf:"fixed64,21,opt,name=q99,proto3" json:"q99,omitempty"`
	Q100          float64            `protobuf:"fixed64,22,opt,name=q100,proto3" json:"q100,omitempty"`
	HttpCodes     []*Trail_Codes     `protobuf:"bytes,23,rep,name=http_codes,json=httpCodes,proto3" json:"http_codes,omitempty"`
	NetCodes      []*Trail_Codes     `protobuf:"bytes,24,rep,name=net_codes,json=netCodes,proto3" json:"net_codes,omitempty"`
	TimeIntervals []*Trail_Intervals `protobuf:"bytes,25,rep,name=time_intervals,json=timeIntervals,proto3" json:"time_intervals,omitempty"`
	// contains filtered or unexported fields
}

func (*Trail) Descriptor deprecated

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

Deprecated: Use Trail.ProtoReflect.Descriptor instead.

func (*Trail) GetCaseId

func (x *Trail) GetCaseId() string

func (*Trail) GetConnectTime

func (x *Trail) GetConnectTime() float64

func (*Trail) GetExpect

func (x *Trail) GetExpect() float64

func (*Trail) GetHttpCodes

func (x *Trail) GetHttpCodes() []*Trail_Codes

func (*Trail) GetInput

func (x *Trail) GetInput() int64

func (*Trail) GetLatency

func (x *Trail) GetLatency() float64

func (*Trail) GetNetCodes

func (x *Trail) GetNetCodes() []*Trail_Codes

func (*Trail) GetOutput

func (x *Trail) GetOutput() int64

func (*Trail) GetOverall

func (x *Trail) GetOverall() int64

func (*Trail) GetQ100

func (x *Trail) GetQ100() float64

func (*Trail) GetQ50

func (x *Trail) GetQ50() float64

func (*Trail) GetQ75

func (x *Trail) GetQ75() float64

func (*Trail) GetQ80

func (x *Trail) GetQ80() float64

func (*Trail) GetQ85

func (x *Trail) GetQ85() float64

func (*Trail) GetQ90

func (x *Trail) GetQ90() float64

func (*Trail) GetQ95

func (x *Trail) GetQ95() float64

func (*Trail) GetQ98

func (x *Trail) GetQ98() float64

func (*Trail) GetQ99

func (x *Trail) GetQ99() float64

func (*Trail) GetReceiveTime

func (x *Trail) GetReceiveTime() float64

func (*Trail) GetReqps

func (x *Trail) GetReqps() int64

func (*Trail) GetResps

func (x *Trail) GetResps() int64

func (*Trail) GetSendTime

func (x *Trail) GetSendTime() float64

func (*Trail) GetThreads

func (x *Trail) GetThreads() int64

func (*Trail) GetTime

func (x *Trail) GetTime() string

func (*Trail) GetTimeIntervals

func (x *Trail) GetTimeIntervals() []*Trail_Intervals

func (*Trail) ProtoMessage

func (*Trail) ProtoMessage()

func (*Trail) ProtoReflect

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

func (*Trail) Reset

func (x *Trail) Reset()

func (*Trail) SetCaseId

func (m *Trail) SetCaseId(v string)

func (*Trail) SetConnectTime

func (m *Trail) SetConnectTime(v float64)

func (*Trail) SetExpect

func (m *Trail) SetExpect(v float64)

func (*Trail) SetHttpCodes

func (m *Trail) SetHttpCodes(v []*Trail_Codes)

func (*Trail) SetInput

func (m *Trail) SetInput(v int64)

func (*Trail) SetLatency

func (m *Trail) SetLatency(v float64)

func (*Trail) SetNetCodes

func (m *Trail) SetNetCodes(v []*Trail_Codes)

func (*Trail) SetOutput

func (m *Trail) SetOutput(v int64)

func (*Trail) SetOverall

func (m *Trail) SetOverall(v int64)

func (*Trail) SetQ100

func (m *Trail) SetQ100(v float64)

func (*Trail) SetQ50

func (m *Trail) SetQ50(v float64)

func (*Trail) SetQ75

func (m *Trail) SetQ75(v float64)

func (*Trail) SetQ80

func (m *Trail) SetQ80(v float64)

func (*Trail) SetQ85

func (m *Trail) SetQ85(v float64)

func (*Trail) SetQ90

func (m *Trail) SetQ90(v float64)

func (*Trail) SetQ95

func (m *Trail) SetQ95(v float64)

func (*Trail) SetQ98

func (m *Trail) SetQ98(v float64)

func (*Trail) SetQ99

func (m *Trail) SetQ99(v float64)

func (*Trail) SetReceiveTime

func (m *Trail) SetReceiveTime(v float64)

func (*Trail) SetReqps

func (m *Trail) SetReqps(v int64)

func (*Trail) SetResps

func (m *Trail) SetResps(v int64)

func (*Trail) SetSendTime

func (m *Trail) SetSendTime(v float64)

func (*Trail) SetThreads

func (m *Trail) SetThreads(v int64)

func (*Trail) SetTime

func (m *Trail) SetTime(v string)

func (*Trail) SetTimeIntervals

func (m *Trail) SetTimeIntervals(v []*Trail_Intervals)

func (*Trail) String

func (x *Trail) String() string

type TrailServiceClient

type TrailServiceClient interface {
	// Creates trail for specified job.
	Create(ctx context.Context, in *CreateTrailRequest, opts ...grpc.CallOption) (*CreateTrailResponse, error)
}

TrailServiceClient is the client API for TrailService 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 TrailServiceServer

type TrailServiceServer interface {
	// Creates trail for specified job.
	Create(context.Context, *CreateTrailRequest) (*CreateTrailResponse, error)
}

TrailServiceServer is the server API for TrailService service. All implementations should embed UnimplementedTrailServiceServer for forward compatibility

type Trail_Codes

type Trail_Codes struct {
	Code  int64 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Count int64 `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*Trail_Codes) Descriptor deprecated

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

Deprecated: Use Trail_Codes.ProtoReflect.Descriptor instead.

func (*Trail_Codes) GetCode

func (x *Trail_Codes) GetCode() int64

func (*Trail_Codes) GetCount

func (x *Trail_Codes) GetCount() int64

func (*Trail_Codes) ProtoMessage

func (*Trail_Codes) ProtoMessage()

func (*Trail_Codes) ProtoReflect

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

func (*Trail_Codes) Reset

func (x *Trail_Codes) Reset()

func (*Trail_Codes) SetCode

func (m *Trail_Codes) SetCode(v int64)

func (*Trail_Codes) SetCount

func (m *Trail_Codes) SetCount(v int64)

func (*Trail_Codes) String

func (x *Trail_Codes) String() string

type Trail_Intervals

type Trail_Intervals struct {
	To    float64 `protobuf:"fixed64,1,opt,name=to,proto3" json:"to,omitempty"`
	Count int64   `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*Trail_Intervals) Descriptor deprecated

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

Deprecated: Use Trail_Intervals.ProtoReflect.Descriptor instead.

func (*Trail_Intervals) GetCount

func (x *Trail_Intervals) GetCount() int64

func (*Trail_Intervals) GetTo

func (x *Trail_Intervals) GetTo() float64

func (*Trail_Intervals) ProtoMessage

func (*Trail_Intervals) ProtoMessage()

func (*Trail_Intervals) ProtoReflect

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

func (*Trail_Intervals) Reset

func (x *Trail_Intervals) Reset()

func (*Trail_Intervals) SetCount

func (m *Trail_Intervals) SetCount(v int64)

func (*Trail_Intervals) SetTo

func (m *Trail_Intervals) SetTo(v float64)

func (*Trail_Intervals) String

func (x *Trail_Intervals) String() string

type UnimplementedAgentRegistrationServiceServer

type UnimplementedAgentRegistrationServiceServer struct {
}

UnimplementedAgentRegistrationServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedAgentRegistrationServiceServer) ExternalAgentRegister

func (UnimplementedAgentRegistrationServiceServer) Register

type UnimplementedAgentServiceServer

type UnimplementedAgentServiceServer struct {
}

UnimplementedAgentServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedAgentServiceServer) ClaimStatus

type UnimplementedJobServiceServer

type UnimplementedJobServiceServer struct {
}

UnimplementedJobServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedJobServiceServer) ClaimStatus

func (UnimplementedJobServiceServer) Get

func (UnimplementedJobServiceServer) GetSignal

func (UnimplementedJobServiceServer) GetTransientFile

type UnimplementedMonitoringServiceServer

type UnimplementedMonitoringServiceServer struct {
}

UnimplementedMonitoringServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedMonitoringServiceServer) AddMetric

type UnimplementedTestServiceServer

type UnimplementedTestServiceServer struct {
}

UnimplementedTestServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedTestServiceServer) Get

func (UnimplementedTestServiceServer) Update

type UnimplementedTrailServiceServer

type UnimplementedTrailServiceServer struct {
}

UnimplementedTrailServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedTrailServiceServer) Create

type UnsafeAgentRegistrationServiceServer

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

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

type UnsafeAgentServiceServer

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

UnsafeAgentServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AgentServiceServer 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 UnsafeMonitoringServiceServer

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

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

type UnsafeTestServiceServer

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

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

type UnsafeTrailServiceServer

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

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

type UpdateTestMetadata

type UpdateTestMetadata struct {
	TestId string `protobuf:"bytes,1,opt,name=test_id,json=testId,proto3" json:"test_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateTestMetadata) Descriptor deprecated

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

Deprecated: Use UpdateTestMetadata.ProtoReflect.Descriptor instead.

func (*UpdateTestMetadata) GetTestId

func (x *UpdateTestMetadata) GetTestId() string

func (*UpdateTestMetadata) ProtoMessage

func (*UpdateTestMetadata) ProtoMessage()

func (*UpdateTestMetadata) ProtoReflect

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

func (*UpdateTestMetadata) Reset

func (x *UpdateTestMetadata) Reset()

func (*UpdateTestMetadata) SetTestId

func (m *UpdateTestMetadata) SetTestId(v string)

func (*UpdateTestMetadata) String

func (x *UpdateTestMetadata) String() string

type UpdateTestRequest

type UpdateTestRequest struct {
	TestId     string                 `protobuf:"bytes,1,opt,name=test_id,json=testId,proto3" json:"test_id,omitempty"`
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// Deprecated: Marked as deprecated in yandex/cloud/loadtesting/agent/v1/test_service.proto.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Deprecated: Marked as deprecated in yandex/cloud/loadtesting/agent/v1/test_service.proto.
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// Deprecated: Marked as deprecated in yandex/cloud/loadtesting/agent/v1/test_service.proto.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Deprecated: Marked as deprecated in yandex/cloud/loadtesting/agent/v1/test_service.proto.
	Favorite bool `protobuf:"varint,6,opt,name=favorite,proto3" json:"favorite,omitempty"`
	// Deprecated: Marked as deprecated in yandex/cloud/loadtesting/agent/v1/test_service.proto.
	TargetVersion    string `protobuf:"bytes,7,opt,name=target_version,json=targetVersion,proto3" json:"target_version,omitempty"`
	ImbalancePoint   int64  `protobuf:"varint,8,opt,name=imbalance_point,json=imbalancePoint,proto3" json:"imbalance_point,omitempty"`
	ImbalanceTs      int64  `protobuf:"varint,9,opt,name=imbalance_ts,json=imbalanceTs,proto3" json:"imbalance_ts,omitempty"`
	ImbalanceComment string `protobuf:"bytes,10,opt,name=imbalance_comment,json=imbalanceComment,proto3" json:"imbalance_comment,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateTestRequest) Descriptor deprecated

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

Deprecated: Use UpdateTestRequest.ProtoReflect.Descriptor instead.

func (*UpdateTestRequest) GetDescription deprecated

func (x *UpdateTestRequest) GetDescription() string

Deprecated: Marked as deprecated in yandex/cloud/loadtesting/agent/v1/test_service.proto.

func (*UpdateTestRequest) GetFavorite deprecated

func (x *UpdateTestRequest) GetFavorite() bool

Deprecated: Marked as deprecated in yandex/cloud/loadtesting/agent/v1/test_service.proto.

func (*UpdateTestRequest) GetImbalanceComment

func (x *UpdateTestRequest) GetImbalanceComment() string

func (*UpdateTestRequest) GetImbalancePoint

func (x *UpdateTestRequest) GetImbalancePoint() int64

func (*UpdateTestRequest) GetImbalanceTs

func (x *UpdateTestRequest) GetImbalanceTs() int64

func (*UpdateTestRequest) GetLabels deprecated

func (x *UpdateTestRequest) GetLabels() map[string]string

Deprecated: Marked as deprecated in yandex/cloud/loadtesting/agent/v1/test_service.proto.

func (*UpdateTestRequest) GetName deprecated

func (x *UpdateTestRequest) GetName() string

Deprecated: Marked as deprecated in yandex/cloud/loadtesting/agent/v1/test_service.proto.

func (*UpdateTestRequest) GetTargetVersion deprecated

func (x *UpdateTestRequest) GetTargetVersion() string

Deprecated: Marked as deprecated in yandex/cloud/loadtesting/agent/v1/test_service.proto.

func (*UpdateTestRequest) GetTestId

func (x *UpdateTestRequest) GetTestId() string

func (*UpdateTestRequest) GetUpdateMask

func (x *UpdateTestRequest) GetUpdateMask() *fieldmaskpb.FieldMask

func (*UpdateTestRequest) ProtoMessage

func (*UpdateTestRequest) ProtoMessage()

func (*UpdateTestRequest) ProtoReflect

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

func (*UpdateTestRequest) Reset

func (x *UpdateTestRequest) Reset()

func (*UpdateTestRequest) SetDescription

func (m *UpdateTestRequest) SetDescription(v string)

func (*UpdateTestRequest) SetFavorite

func (m *UpdateTestRequest) SetFavorite(v bool)

func (*UpdateTestRequest) SetImbalanceComment

func (m *UpdateTestRequest) SetImbalanceComment(v string)

func (*UpdateTestRequest) SetImbalancePoint

func (m *UpdateTestRequest) SetImbalancePoint(v int64)

func (*UpdateTestRequest) SetImbalanceTs

func (m *UpdateTestRequest) SetImbalanceTs(v int64)

func (*UpdateTestRequest) SetLabels

func (m *UpdateTestRequest) SetLabels(v map[string]string)

func (*UpdateTestRequest) SetName

func (m *UpdateTestRequest) SetName(v string)

func (*UpdateTestRequest) SetTargetVersion

func (m *UpdateTestRequest) SetTargetVersion(v string)

func (*UpdateTestRequest) SetTestId

func (m *UpdateTestRequest) SetTestId(v string)

func (*UpdateTestRequest) SetUpdateMask

func (m *UpdateTestRequest) SetUpdateMask(v *fieldmaskpb.FieldMask)

func (*UpdateTestRequest) String

func (x *UpdateTestRequest) String() string

Jump to

Keyboard shortcuts

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