v1

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Sep 17, 2020 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Component_Kind_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "DRIVER",
	2: "SERVER",
	3: "CLIENT",
}
View Source 
var Component_Kind_value = map[string]int32{
	"UNSPECIFIED": 0,
	"DRIVER":      1,
	"SERVER":      2,
	"CLIENT":      3,
}
View Source 
var Event_Kind_name = map[int32]string{
	0: "INTERNAL_ERROR",
	1: "QUEUE",
	2: "ACCEPT",
	3: "PROVISION",
	4: "RUN",
	5: "DONE",
	6: "ERROR",
}
View Source 
var Event_Kind_value = map[string]int32{
	"INTERNAL_ERROR": 0,
	"QUEUE":          1,
	"ACCEPT":         2,
	"PROVISION":      3,
	"RUN":            4,
	"DONE":           5,
	"ERROR":          6,
}

Functions

func RegisterSchedulingServiceServer 

func RegisterSchedulingServiceServer(s *grpc.Server, srv SchedulingServiceServer)

Types

type Component 

type Component struct {
	// The name and version of the container image as it appears in a registry.
	//
	// When using GCR, this will likely be a fully-qualified domain name and path
	// plus a tag or sha256 hash. For example, a Java worker image may be
	// similar to one of the following:
	//
	//   - gcr.io/grpc-testing/java_worker:v3.2.19
	//   - gcr.io/grpc-testing/java_worker@sha256:82b6360a84c19f23ed7ee9...
	//
	// The "latest" tag is automatically set by the registry, and there
	// are no guarantees that it will point to a specific image. It should be
	// avoided.
	ContainerImage string `protobuf:"bytes,1,opt,name=container_image,json=containerImage,proto3" json:"container_image,omitempty"`
	// The kind which assigns the responsibilities of this container.
	Kind Component_Kind `protobuf:"varint,2,opt,name=kind,proto3,enum=grpc.testing.benchmarking.scheduling.v1.Component_Kind" json:"kind,omitempty"`
	// The pool where the component should run. This must match the "pool" label
	// on a node to be scheduled on it.
	Pool                 string   `protobuf:"bytes,3,opt,name=pool,proto3" json:"pool,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Component) Descriptor 

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

func (*Component) GetContainerImage 

func (m *Component) GetContainerImage() string

func (*Component) GetKind 

func (m *Component) GetKind() Component_Kind

func (*Component) GetPool 

func (m *Component) GetPool() string

func (*Component) ProtoMessage 

func (*Component) ProtoMessage()

func (*Component) Reset 

func (m *Component) Reset()

func (*Component) String 

func (m *Component) String() string

func (*Component) XXX_DiscardUnknown 

func (m *Component) XXX_DiscardUnknown()

func (*Component) XXX_Marshal 

func (m *Component) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Component) XXX_Merge 

func (m *Component) XXX_Merge(src proto.Message)

func (*Component) XXX_Size 

func (m *Component) XXX_Size() int

func (*Component) XXX_Unmarshal 

func (m *Component) XXX_Unmarshal(b []byte) error

type Component_Kind 

type Component_Kind int32
const (
	// No kind was specified, so the service will attempt to infer one.
	//
	// This inference works as follows:
	//   1. If this field belongs to the driver_container of the
	//      StartTestSessionRequest, this kind is inferred to be a driver.
	//   2. Otherwise, this field is inferred to be a client worker.
	Component_UNSPECIFIED Component_Kind = 0
	// Orchestrates the test amongst workers and reports the result.
	Component_DRIVER Component_Kind = 1
	// Processes incoming requests from client containers.
	Component_SERVER Component_Kind = 2
	// Sends outgoing requests to a server container.
	Component_CLIENT Component_Kind = 3
)

func (Component_Kind) EnumDescriptor 

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

func (Component_Kind) String 

func (x Component_Kind) String() string

type Event 

type Event struct {
	// The name of the subject of the event. This may be the name of a test
	// session or the name of one of its components.
	Subject string `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"`
	// The kind of event.
	Kind Event_Kind `protobuf:"varint,2,opt,name=kind,proto3,enum=grpc.testing.benchmarking.scheduling.v1.Event_Kind" json:"kind,omitempty"`
	// The point in time when the event was noticed.
	Time *timestamp.Timestamp `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// A string containing a description of the event, if applicable.
	Description          string   `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Event) Descriptor 

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

func (*Event) GetDescription 

func (m *Event) GetDescription() string

func (*Event) GetKind 

func (m *Event) GetKind() Event_Kind

func (*Event) GetSubject 

func (m *Event) GetSubject() string

func (*Event) GetTime 

func (m *Event) GetTime() *timestamp.Timestamp

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) String 

func (m *Event) String() string

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event) XXX_Merge 

func (m *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

func (m *Event) XXX_Unmarshal(b []byte) error

type Event_Kind 

type Event_Kind int32
const (
	// An infrastructure problem. This is outside of the test runner's control,
	// and a bug should be filed if it is encountered.
	Event_INTERNAL_ERROR Event_Kind = 0
	// Waiting for an executor to process the test session.
	Event_QUEUE Event_Kind = 1
	// An executor has been assigned to provision and monitor the session;
	// however, work has not yet begun on this event's subject.
	Event_ACCEPT Event_Kind = 2
	// Reserving and configuring resources for the event's subject.
	Event_PROVISION Event_Kind = 3
	// Resources are responding with a healthy signal. However, this is not
	// indicative of a running test.
	Event_RUN Event_Kind = 4
	// Resources terminated or released as expected. It does not indicate that
	// the test was successful or the result was recorded.
	Event_DONE Event_Kind = 5
	// An irrecoverable error has caused the subject of the event to terminate.
	Event_ERROR Event_Kind = 6
)

func (Event_Kind) EnumDescriptor 

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

func (Event_Kind) String 

func (x Event_Kind) String() string

type SchedulingServiceClient 

type SchedulingServiceClient interface {
	// Starts a test session, which encapsulates a test's scenario, required
	// components and output settings.
	//
	// The scenario contains the configuration for the test itself. The components
	// represent physical or virtual resources that must be reserved and monitored
	// when running a test. The output settings specify where the result will be
	// saved.
	//
	// This is a long-running operation that is managed by the Operations service
	// on the same server.  The long-running operation will assign a unique
	// identifier to the session.
	//
	// The unique identifier can be used to poll for the session's status and
	// result. Streaming is not supported at present.
	//
	// It can also be used to cancel while in progress, but cancellations operate
	// like killing a running process. If they occur while result are being
	// reported, the persistent storage may receive some but not all of them.
	//
	// For the specification of a google.longrunning.Operation message, see the
	// Long-running AIP at https://aip.dev/151.
	StartTestSession(ctx context.Context, in *StartTestSessionRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
}

SchedulingServiceClient is the client API for SchedulingService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSchedulingServiceClient 

func NewSchedulingServiceClient(cc grpc.ClientConnInterface) SchedulingServiceClient

type SchedulingServiceServer 

type SchedulingServiceServer interface {
	// Starts a test session, which encapsulates a test's scenario, required
	// components and output settings.
	//
	// The scenario contains the configuration for the test itself. The components
	// represent physical or virtual resources that must be reserved and monitored
	// when running a test. The output settings specify where the result will be
	// saved.
	//
	// This is a long-running operation that is managed by the Operations service
	// on the same server.  The long-running operation will assign a unique
	// identifier to the session.
	//
	// The unique identifier can be used to poll for the session's status and
	// result. Streaming is not supported at present.
	//
	// It can also be used to cancel while in progress, but cancellations operate
	// like killing a running process. If they occur while result are being
	// reported, the persistent storage may receive some but not all of them.
	//
	// For the specification of a google.longrunning.Operation message, see the
	// Long-running AIP at https://aip.dev/151.
	StartTestSession(context.Context, *StartTestSessionRequest) (*longrunning.Operation, error)
}

SchedulingServiceServer is the server API for SchedulingService service.

type StartTestSessionRequest 

type StartTestSessionRequest struct {
	// The test scenario to run as a part of the test session.
	Scenario *testing.Scenario `protobuf:"bytes,1,opt,name=scenario,proto3" json:"scenario,omitempty"`
	// The component which orchestrates running the test scenarios amongst
	// workers.
	Driver *Component `protobuf:"bytes,2,opt,name=driver,proto3" json:"driver,omitempty"`
	// The components that are required as part of the test. Normally, this will
	// involve at least one server and a number of clients.
	Workers []*Component `protobuf:"bytes,3,rep,name=workers,proto3" json:"workers,omitempty"`
	// An optional location where the result should be written.
	//
	// Types that are valid to be assigned to ResultDestination:
	//	*StartTestSessionRequest_BqResultsTable
	//	*StartTestSessionRequest_GcsResultsFileUri
	ResultDestination    isStartTestSessionRequest_ResultDestination `protobuf_oneof:"result_destination"`
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

func (*StartTestSessionRequest) Descriptor 

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

func (*StartTestSessionRequest) GetBqResultsTable 

func (m *StartTestSessionRequest) GetBqResultsTable() string

func (*StartTestSessionRequest) GetDriver 

func (m *StartTestSessionRequest) GetDriver() *Component

func (*StartTestSessionRequest) GetGcsResultsFileUri 

func (m *StartTestSessionRequest) GetGcsResultsFileUri() string

func (*StartTestSessionRequest) GetResultDestination 

func (m *StartTestSessionRequest) GetResultDestination() isStartTestSessionRequest_ResultDestination

func (*StartTestSessionRequest) GetScenario 

func (m *StartTestSessionRequest) GetScenario() *testing.Scenario

func (*StartTestSessionRequest) GetWorkers 

func (m *StartTestSessionRequest) GetWorkers() []*Component

func (*StartTestSessionRequest) ProtoMessage 

func (*StartTestSessionRequest) ProtoMessage()

func (*StartTestSessionRequest) Reset 

func (m *StartTestSessionRequest) Reset()

func (*StartTestSessionRequest) String 

func (m *StartTestSessionRequest) String() string

func (*StartTestSessionRequest) XXX_DiscardUnknown 

func (m *StartTestSessionRequest) XXX_DiscardUnknown()

func (*StartTestSessionRequest) XXX_Marshal 

func (m *StartTestSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartTestSessionRequest) XXX_Merge 

func (m *StartTestSessionRequest) XXX_Merge(src proto.Message)

func (*StartTestSessionRequest) XXX_OneofWrappers 

func (*StartTestSessionRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*StartTestSessionRequest) XXX_Size 

func (m *StartTestSessionRequest) XXX_Size() int

func (*StartTestSessionRequest) XXX_Unmarshal 

func (m *StartTestSessionRequest) XXX_Unmarshal(b []byte) error

type StartTestSessionRequest_BqResultsTable 

type StartTestSessionRequest_BqResultsTable struct {
	BqResultsTable string `protobuf:"bytes,4,opt,name=bq_results_table,json=bqResultsTable,proto3,oneof"`
}

type StartTestSessionRequest_GcsResultsFileUri 

type StartTestSessionRequest_GcsResultsFileUri struct {
	GcsResultsFileUri string `protobuf:"bytes,5,opt,name=gcs_results_file_uri,json=gcsResultsFileUri,proto3,oneof"`
}

type TestSessionMetadata 

type TestSessionMetadata struct {
	// The latest event for the test session as a whole, assuming it has not been
	// terminated.
	LatestEvent *Event `protobuf:"bytes,1,opt,name=latest_event,json=latestEvent,proto3" json:"latest_event,omitempty"`
	// The version of the service that is processing this request.
	ServiceVersion string `protobuf:"bytes,2,opt,name=service_version,json=serviceVersion,proto3" json:"service_version,omitempty"`
	// The time that the server acknowledged the request to create a test session.
	CreateTime           *timestamp.Timestamp `protobuf:"bytes,3,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*TestSessionMetadata) Descriptor 

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

func (*TestSessionMetadata) GetCreateTime 

func (m *TestSessionMetadata) GetCreateTime() *timestamp.Timestamp

func (*TestSessionMetadata) GetLatestEvent 

func (m *TestSessionMetadata) GetLatestEvent() *Event

func (*TestSessionMetadata) GetServiceVersion 

func (m *TestSessionMetadata) GetServiceVersion() string

func (*TestSessionMetadata) ProtoMessage 

func (*TestSessionMetadata) ProtoMessage()

func (*TestSessionMetadata) Reset 

func (m *TestSessionMetadata) Reset()

func (*TestSessionMetadata) String 

func (m *TestSessionMetadata) String() string

func (*TestSessionMetadata) XXX_DiscardUnknown 

func (m *TestSessionMetadata) XXX_DiscardUnknown()

func (*TestSessionMetadata) XXX_Marshal 

func (m *TestSessionMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TestSessionMetadata) XXX_Merge 

func (m *TestSessionMetadata) XXX_Merge(src proto.Message)

func (*TestSessionMetadata) XXX_Size 

func (m *TestSessionMetadata) XXX_Size() int

func (*TestSessionMetadata) XXX_Unmarshal 

func (m *TestSessionMetadata) XXX_Unmarshal(b []byte) error

type TestSessionResult 

type TestSessionResult struct {
	// The logs of the driver, which contain legible descriptions of the errors
	// and any session results.
	DriverLogs []byte `protobuf:"bytes,2,opt,name=driver_logs,json=driverLogs,proto3" json:"driver_logs,omitempty"`
	// The amount of time that this session lived, including all actions from
	// scheduling to termination.
	TimeElapsed          *duration.Duration `protobuf:"bytes,3,opt,name=time_elapsed,json=timeElapsed,proto3" json:"time_elapsed,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*TestSessionResult) Descriptor 

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

func (*TestSessionResult) GetDriverLogs 

func (m *TestSessionResult) GetDriverLogs() []byte

func (*TestSessionResult) GetTimeElapsed 

func (m *TestSessionResult) GetTimeElapsed() *duration.Duration

func (*TestSessionResult) ProtoMessage 

func (*TestSessionResult) ProtoMessage()

func (*TestSessionResult) Reset 

func (m *TestSessionResult) Reset()

func (*TestSessionResult) String 

func (m *TestSessionResult) String() string

func (*TestSessionResult) XXX_DiscardUnknown 

func (m *TestSessionResult) XXX_DiscardUnknown()

func (*TestSessionResult) XXX_Marshal 

func (m *TestSessionResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TestSessionResult) XXX_Merge 

func (m *TestSessionResult) XXX_Merge(src proto.Message)

func (*TestSessionResult) XXX_Size 

func (m *TestSessionResult) XXX_Size() int

func (*TestSessionResult) XXX_Unmarshal 

func (m *TestSessionResult) XXX_Unmarshal(b []byte) error

type UnimplementedSchedulingServiceServer 

type UnimplementedSchedulingServiceServer struct {
}

UnimplementedSchedulingServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSchedulingServiceServer) StartTestSession 

func (*UnimplementedSchedulingServiceServer) StartTestSession(ctx context.Context, req *StartTestSessionRequest) (*longrunning.Operation, error)

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.