bindings

package
v0.0.0-...-aedf96a Latest Latest
Warning

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

 Go to latest Published: Feb 3, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	SuiteAction_name = map[int32]string{
		0: "SERIALIZE_SUITE_METADATA",
		1: "EXECUTE_TEST",
	}
	SuiteAction_value = map[string]int32{
		"SERIALIZE_SUITE_METADATA": 0,
		"EXECUTE_TEST":             1,
	}
)

Enum value maps for SuiteAction.

View Source 
var File_suite_metadata_serializing_service_proto protoreflect.FileDescriptor
View Source 
var File_suite_registration_service_proto protoreflect.FileDescriptor
View Source 
var File_test_execution_service_proto protoreflect.FileDescriptor

Functions

func RegisterSuiteMetadataSerializationServiceServer 

func RegisterSuiteMetadataSerializationServiceServer(s *grpc.Server, srv SuiteMetadataSerializationServiceServer)

func RegisterSuiteRegistrationServiceServer 

func RegisterSuiteRegistrationServiceServer(s *grpc.Server, srv SuiteRegistrationServiceServer)

func RegisterTestExecutionServiceServer 

func RegisterTestExecutionServiceServer(s *grpc.Server, srv TestExecutionServiceServer)

Types

type PartitionConnectionInfo 

type PartitionConnectionInfo struct {

	// Whether network traffic is allowed between the two partitions
	IsBlocked bool `protobuf:"varint,1,opt,name=is_blocked,json=isBlocked,proto3" json:"is_blocked,omitempty"`
	// contains filtered or unexported fields
}

func (*PartitionConnectionInfo) Descriptor deprecated 

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

Deprecated: Use PartitionConnectionInfo.ProtoReflect.Descriptor instead.

func (*PartitionConnectionInfo) GetIsBlocked 

func (x *PartitionConnectionInfo) GetIsBlocked() bool

func (*PartitionConnectionInfo) ProtoMessage 

func (*PartitionConnectionInfo) ProtoMessage()

func (*PartitionConnectionInfo) ProtoReflect 

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

func (*PartitionConnectionInfo) Reset 

func (x *PartitionConnectionInfo) Reset()

func (*PartitionConnectionInfo) String 

func (x *PartitionConnectionInfo) String() string

type PartitionConnections 

type PartitionConnections struct {
	ConnectionInfo map[string]*PartitionConnectionInfo `` /* 191-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PartitionConnections) Descriptor deprecated 

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

Deprecated: Use PartitionConnections.ProtoReflect.Descriptor instead.

func (*PartitionConnections) GetConnectionInfo 

func (x *PartitionConnections) GetConnectionInfo() map[string]*PartitionConnectionInfo

func (*PartitionConnections) ProtoMessage 

func (*PartitionConnections) ProtoMessage()

func (*PartitionConnections) ProtoReflect 

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

func (*PartitionConnections) Reset 

func (x *PartitionConnections) Reset()

func (*PartitionConnections) String 

func (x *PartitionConnections) String() string

type PartitionServices 

type PartitionServices struct {

	// "Set" of service IDs in partition
	ServiceIdSet map[string]bool `` /* 188-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PartitionServices) Descriptor deprecated 

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

Deprecated: Use PartitionServices.ProtoReflect.Descriptor instead.

func (*PartitionServices) GetServiceIdSet 

func (x *PartitionServices) GetServiceIdSet() map[string]bool

func (*PartitionServices) ProtoMessage 

func (*PartitionServices) ProtoMessage()

func (*PartitionServices) ProtoReflect 

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

func (*PartitionServices) Reset 

func (x *PartitionServices) Reset()

func (*PartitionServices) String 

func (x *PartitionServices) String() string

type RegisterServiceArgs 

type RegisterServiceArgs struct {

	// ID that will be used to identify the service going forward
	ServiceId string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	// If emptystring, the default partition ID will be used
	PartitionId string `protobuf:"bytes,2,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	// "Set" of files that the service needs and the API container should make available upon service start
	// The key of the map is a user-meaningful identifier
	FilesToGenerate map[string]bool `` /* 197-byte string literal not displayed */
	// contains filtered or unexported fields
}

============================================================================================== 

Register Service

==============================================================================================

func (*RegisterServiceArgs) Descriptor deprecated 

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

Deprecated: Use RegisterServiceArgs.ProtoReflect.Descriptor instead.

func (*RegisterServiceArgs) GetFilesToGenerate 

func (x *RegisterServiceArgs) GetFilesToGenerate() map[string]bool

func (*RegisterServiceArgs) GetPartitionId 

func (x *RegisterServiceArgs) GetPartitionId() string

func (*RegisterServiceArgs) GetServiceId 

func (x *RegisterServiceArgs) GetServiceId() string

func (*RegisterServiceArgs) ProtoMessage 

func (*RegisterServiceArgs) ProtoMessage()

func (*RegisterServiceArgs) ProtoReflect 

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

func (*RegisterServiceArgs) Reset 

func (x *RegisterServiceArgs) Reset()

func (*RegisterServiceArgs) String 

func (x *RegisterServiceArgs) String() string

type RegisterServiceResponse 

type RegisterServiceResponse struct {

	// Mapping of user-created key in the request -> filepath (RELATIVE to the suite execution volume root!) where
	//  the file was created
	GeneratedFilesRelativeFilepaths map[string]string `` /* 246-byte string literal not displayed */
	// The IP address that the service will receive when it starts
	IpAddr string `protobuf:"bytes,2,opt,name=ip_addr,json=ipAddr,proto3" json:"ip_addr,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterServiceResponse) Descriptor deprecated 

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

Deprecated: Use RegisterServiceResponse.ProtoReflect.Descriptor instead.

func (*RegisterServiceResponse) GetGeneratedFilesRelativeFilepaths 

func (x *RegisterServiceResponse) GetGeneratedFilesRelativeFilepaths() map[string]string

func (*RegisterServiceResponse) GetIpAddr 

func (x *RegisterServiceResponse) GetIpAddr() string

func (*RegisterServiceResponse) ProtoMessage 

func (*RegisterServiceResponse) ProtoMessage()

func (*RegisterServiceResponse) ProtoReflect 

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

func (*RegisterServiceResponse) Reset 

func (x *RegisterServiceResponse) Reset()

func (*RegisterServiceResponse) String 

func (x *RegisterServiceResponse) String() string

type RegisterTestExecutionArgs 

type RegisterTestExecutionArgs struct {

	// TODO This should actually be unnecessary - we should pass in testsuite metadata at API container startup time,
	//  so that registration just says "I'm starting" and the API container can look up the timeout
	TimeoutSeconds uint64 `protobuf:"varint,1,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
	// contains filtered or unexported fields
}

============================================================================================== 

Register Test Execution

==============================================================================================

func (*RegisterTestExecutionArgs) Descriptor deprecated 

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

Deprecated: Use RegisterTestExecutionArgs.ProtoReflect.Descriptor instead.

func (*RegisterTestExecutionArgs) GetTimeoutSeconds 

func (x *RegisterTestExecutionArgs) GetTimeoutSeconds() uint64

func (*RegisterTestExecutionArgs) ProtoMessage 

func (*RegisterTestExecutionArgs) ProtoMessage()

func (*RegisterTestExecutionArgs) ProtoReflect 

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

func (*RegisterTestExecutionArgs) Reset 

func (x *RegisterTestExecutionArgs) Reset()

func (*RegisterTestExecutionArgs) String 

func (x *RegisterTestExecutionArgs) String() string

type RemoveServiceArgs 

type RemoveServiceArgs struct {
	ServiceId string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	// How long to wait for the service to gracefully stop before hard killing it
	ContainerStopTimeoutSeconds uint64 `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

============================================================================================== 

Remove Service

==============================================================================================

func (*RemoveServiceArgs) Descriptor deprecated 

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

Deprecated: Use RemoveServiceArgs.ProtoReflect.Descriptor instead.

func (*RemoveServiceArgs) GetContainerStopTimeoutSeconds 

func (x *RemoveServiceArgs) GetContainerStopTimeoutSeconds() uint64

func (*RemoveServiceArgs) GetServiceId 

func (x *RemoveServiceArgs) GetServiceId() string

func (*RemoveServiceArgs) ProtoMessage 

func (*RemoveServiceArgs) ProtoMessage()

func (*RemoveServiceArgs) ProtoReflect 

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

func (*RemoveServiceArgs) Reset 

func (x *RemoveServiceArgs) Reset()

func (*RemoveServiceArgs) String 

func (x *RemoveServiceArgs) String() string

type RepartitionArgs 

type RepartitionArgs struct {

	// Definition of partitionId -> services that should be inside the partition after repartitioning
	PartitionServices map[string]*PartitionServices `` /* 200-byte string literal not displayed */
	// Definition of partitionIdA -> partitionIdB -> information defining the connection between A <-> B
	PartitionConnections map[string]*PartitionConnections `` /* 209-byte string literal not displayed */
	// Information about the default inter-partition connection to set up if one is not defined in the
	//  partition connections map
	DefaultConnection *PartitionConnectionInfo `protobuf:"bytes,3,opt,name=default_connection,json=defaultConnection,proto3" json:"default_connection,omitempty"`
	// contains filtered or unexported fields
}

============================================================================================== 

Repartition

==============================================================================================

func (*RepartitionArgs) Descriptor deprecated 

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

Deprecated: Use RepartitionArgs.ProtoReflect.Descriptor instead.

func (*RepartitionArgs) GetDefaultConnection 

func (x *RepartitionArgs) GetDefaultConnection() *PartitionConnectionInfo

func (*RepartitionArgs) GetPartitionConnections 

func (x *RepartitionArgs) GetPartitionConnections() map[string]*PartitionConnections

func (*RepartitionArgs) GetPartitionServices 

func (x *RepartitionArgs) GetPartitionServices() map[string]*PartitionServices

func (*RepartitionArgs) ProtoMessage 

func (*RepartitionArgs) ProtoMessage()

func (*RepartitionArgs) ProtoReflect 

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

func (*RepartitionArgs) Reset 

func (x *RepartitionArgs) Reset()

func (*RepartitionArgs) String 

func (x *RepartitionArgs) String() string

type StartServiceArgs 

type StartServiceArgs struct {

	// ID of the previously-registered service that should be started
	ServiceId   string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	DockerImage string `protobuf:"bytes,2,opt,name=docker_image,json=dockerImage,proto3" json:"docker_image,omitempty"`
	// "Set" of ports that the running service will listen on
	// This is a string because it's Docker port specification syntax, e.g. "80" (default TCP) or "80/udp"
	UsedPorts map[string]bool `` /* 177-byte string literal not displayed */
	// String array indicating the command that should be run inside the sevice's container on startup
	StartCmdArgs []string `protobuf:"bytes,4,rep,name=start_cmd_args,json=startCmdArgs,proto3" json:"start_cmd_args,omitempty"`
	// Docker environment variables that should be set in the service's container
	DockerEnvVars map[string]string `` /* 190-byte string literal not displayed */
	// The full path where the API container should execute the suite execution volume on the service container
	SuiteExecutionVolMntDirpath string `` /* 148-byte string literal not displayed */
	// Mapping of artifact_url -> filepath_on_container_to_mount_artifact_contents
	FilesArtifactMountDirpaths map[string]string `` /* 231-byte string literal not displayed */
	// contains filtered or unexported fields
}

============================================================================================== 

Start Service

==============================================================================================

func (*StartServiceArgs) Descriptor deprecated 

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

Deprecated: Use StartServiceArgs.ProtoReflect.Descriptor instead.

func (*StartServiceArgs) GetDockerEnvVars 

func (x *StartServiceArgs) GetDockerEnvVars() map[string]string

func (*StartServiceArgs) GetDockerImage 

func (x *StartServiceArgs) GetDockerImage() string

func (*StartServiceArgs) GetFilesArtifactMountDirpaths 

func (x *StartServiceArgs) GetFilesArtifactMountDirpaths() map[string]string

func (*StartServiceArgs) GetServiceId 

func (x *StartServiceArgs) GetServiceId() string

func (*StartServiceArgs) GetStartCmdArgs 

func (x *StartServiceArgs) GetStartCmdArgs() []string

func (*StartServiceArgs) GetSuiteExecutionVolMntDirpath 

func (x *StartServiceArgs) GetSuiteExecutionVolMntDirpath() string

func (*StartServiceArgs) GetUsedPorts 

func (x *StartServiceArgs) GetUsedPorts() map[string]bool

func (*StartServiceArgs) ProtoMessage 

func (*StartServiceArgs) ProtoMessage()

func (*StartServiceArgs) ProtoReflect 

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

func (*StartServiceArgs) Reset 

func (x *StartServiceArgs) Reset()

func (*StartServiceArgs) String 

func (x *StartServiceArgs) String() string

type SuiteAction 

type SuiteAction int32

Tells the suite what action it should perform, based on the args that the API container received 

const (
	// Indicates that the testsuite should operate in metadata-serializing mode, sending suite metadata to the
	//  API container
	SuiteAction_SERIALIZE_SUITE_METADATA SuiteAction = 0
	// Indicates that the testsuite should operate in test-executing mode, running a test
	SuiteAction_EXECUTE_TEST SuiteAction = 1
)

func (SuiteAction) Descriptor 

func (SuiteAction) Descriptor() protoreflect.EnumDescriptor

func (SuiteAction) Enum 

func (x SuiteAction) Enum() *SuiteAction

func (SuiteAction) EnumDescriptor deprecated 

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

Deprecated: Use SuiteAction.Descriptor instead.

func (SuiteAction) Number 

func (x SuiteAction) Number() protoreflect.EnumNumber

func (SuiteAction) String 

func (x SuiteAction) String() string

func (SuiteAction) Type 

func (SuiteAction) Type() protoreflect.EnumType

type SuiteMetadataSerializationServiceClient 

type SuiteMetadataSerializationServiceClient interface {
	SerializeSuiteMetadata(ctx context.Context, in *TestSuiteMetadata, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

SuiteMetadataSerializationServiceClient is the client API for SuiteMetadataSerializationService service.

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

func NewSuiteMetadataSerializationServiceClient 

func NewSuiteMetadataSerializationServiceClient(cc grpc.ClientConnInterface) SuiteMetadataSerializationServiceClient

type SuiteMetadataSerializationServiceServer 

type SuiteMetadataSerializationServiceServer interface {
	SerializeSuiteMetadata(context.Context, *TestSuiteMetadata) (*emptypb.Empty, error)
}

SuiteMetadataSerializationServiceServer is the server API for SuiteMetadataSerializationService service.

type SuiteRegistrationResponse 

type SuiteRegistrationResponse struct {
	SuiteAction SuiteAction `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SuiteRegistrationResponse) Descriptor deprecated 

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

Deprecated: Use SuiteRegistrationResponse.ProtoReflect.Descriptor instead.

func (*SuiteRegistrationResponse) GetSuiteAction 

func (x *SuiteRegistrationResponse) GetSuiteAction() SuiteAction

func (*SuiteRegistrationResponse) ProtoMessage 

func (*SuiteRegistrationResponse) ProtoMessage()

func (*SuiteRegistrationResponse) ProtoReflect 

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

func (*SuiteRegistrationResponse) Reset 

func (x *SuiteRegistrationResponse) Reset()

func (*SuiteRegistrationResponse) String 

func (x *SuiteRegistrationResponse) String() string

type SuiteRegistrationServiceClient 

type SuiteRegistrationServiceClient interface {
	RegisterSuite(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*SuiteRegistrationResponse, error)
}

SuiteRegistrationServiceClient is the client API for SuiteRegistrationService service.

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

func NewSuiteRegistrationServiceClient 

func NewSuiteRegistrationServiceClient(cc grpc.ClientConnInterface) SuiteRegistrationServiceClient

type SuiteRegistrationServiceServer 

type SuiteRegistrationServiceServer interface {
	RegisterSuite(context.Context, *emptypb.Empty) (*SuiteRegistrationResponse, error)
}

SuiteRegistrationServiceServer is the server API for SuiteRegistrationService service.

type TestExecutionInfo 

type TestExecutionInfo struct {

	// Name of the test that the testsuite container should execute
	TestName string `protobuf:"bytes,1,opt,name=test_name,json=testName,proto3" json:"test_name,omitempty"`
	// contains filtered or unexported fields
}

============================================================================================== 

Get Test Execution Info

==============================================================================================

func (*TestExecutionInfo) Descriptor deprecated 

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

Deprecated: Use TestExecutionInfo.ProtoReflect.Descriptor instead.

func (*TestExecutionInfo) GetTestName 

func (x *TestExecutionInfo) GetTestName() string

func (*TestExecutionInfo) ProtoMessage 

func (*TestExecutionInfo) ProtoMessage()

func (*TestExecutionInfo) ProtoReflect 

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

func (*TestExecutionInfo) Reset 

func (x *TestExecutionInfo) Reset()

func (*TestExecutionInfo) String 

func (x *TestExecutionInfo) String() string

type TestExecutionServiceClient 

type TestExecutionServiceClient interface {
	// Returns detailed information to the testsuite about what it should do during test execution -
	//  namely, what test it should run
	// This method should be called first by the testsuite
	GetTestExecutionInfo(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*TestExecutionInfo, error)
	// Registers that the testsuite is about to start executing test logic
	RegisterTestExecution(ctx context.Context, in *RegisterTestExecutionArgs, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Registers a service with the API container but doesn't start the container for it
	RegisterService(ctx context.Context, in *RegisterServiceArgs, opts ...grpc.CallOption) (*RegisterServiceResponse, error)
	// Starts a previously-registered service by creating a Docker container for it
	StartService(ctx context.Context, in *StartServiceArgs, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Instructs the API container to remove the given service
	RemoveService(ctx context.Context, in *RemoveServiceArgs, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Instructs the API container to repartition the test network
	Repartition(ctx context.Context, in *RepartitionArgs, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

TestExecutionServiceClient is the client API for TestExecutionService service.

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

func NewTestExecutionServiceClient 

func NewTestExecutionServiceClient(cc grpc.ClientConnInterface) TestExecutionServiceClient

type TestExecutionServiceServer 

type TestExecutionServiceServer interface {
	// Returns detailed information to the testsuite about what it should do during test execution -
	//  namely, what test it should run
	// This method should be called first by the testsuite
	GetTestExecutionInfo(context.Context, *emptypb.Empty) (*TestExecutionInfo, error)
	// Registers that the testsuite is about to start executing test logic
	RegisterTestExecution(context.Context, *RegisterTestExecutionArgs) (*emptypb.Empty, error)
	// Registers a service with the API container but doesn't start the container for it
	RegisterService(context.Context, *RegisterServiceArgs) (*RegisterServiceResponse, error)
	// Starts a previously-registered service by creating a Docker container for it
	StartService(context.Context, *StartServiceArgs) (*emptypb.Empty, error)
	// Instructs the API container to remove the given service
	RemoveService(context.Context, *RemoveServiceArgs) (*emptypb.Empty, error)
	// Instructs the API container to repartition the test network
	Repartition(context.Context, *RepartitionArgs) (*emptypb.Empty, error)
}

TestExecutionServiceServer is the server API for TestExecutionService service.

type TestMetadata 

type TestMetadata struct {
	IsPartitioningEnabled bool `` /* 127-byte string literal not displayed */
	// "Set" of artifact URLs used by the test
	UsedArtifactUrls map[string]bool `` /* 200-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TestMetadata) Descriptor deprecated 

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

Deprecated: Use TestMetadata.ProtoReflect.Descriptor instead.

func (*TestMetadata) GetIsPartitioningEnabled 

func (x *TestMetadata) GetIsPartitioningEnabled() bool

func (*TestMetadata) GetUsedArtifactUrls 

func (x *TestMetadata) GetUsedArtifactUrls() map[string]bool

func (*TestMetadata) ProtoMessage 

func (*TestMetadata) ProtoMessage()

func (*TestMetadata) ProtoReflect 

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

func (*TestMetadata) Reset 

func (x *TestMetadata) Reset()

func (*TestMetadata) String 

func (x *TestMetadata) String() string

type TestSuiteMetadata 

type TestSuiteMetadata struct {

	// Mapping of testName -> testMetadata
	TestMetadata     map[string]*TestMetadata `` /* 185-byte string literal not displayed */
	NetworkWidthBits uint32                   `protobuf:"varint,2,opt,name=network_width_bits,json=networkWidthBits,proto3" json:"network_width_bits,omitempty"`
	// contains filtered or unexported fields
}

func (*TestSuiteMetadata) Descriptor deprecated 

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

Deprecated: Use TestSuiteMetadata.ProtoReflect.Descriptor instead.

func (*TestSuiteMetadata) GetNetworkWidthBits 

func (x *TestSuiteMetadata) GetNetworkWidthBits() uint32

func (*TestSuiteMetadata) GetTestMetadata 

func (x *TestSuiteMetadata) GetTestMetadata() map[string]*TestMetadata

func (*TestSuiteMetadata) ProtoMessage 

func (*TestSuiteMetadata) ProtoMessage()

func (*TestSuiteMetadata) ProtoReflect 

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

func (*TestSuiteMetadata) Reset 

func (x *TestSuiteMetadata) Reset()

func (*TestSuiteMetadata) String 

func (x *TestSuiteMetadata) String() string

type UnimplementedSuiteMetadataSerializationServiceServer 

type UnimplementedSuiteMetadataSerializationServiceServer struct {
}

UnimplementedSuiteMetadataSerializationServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSuiteMetadataSerializationServiceServer) SerializeSuiteMetadata 

func (*UnimplementedSuiteMetadataSerializationServiceServer) SerializeSuiteMetadata(context.Context, *TestSuiteMetadata) (*emptypb.Empty, error)

type UnimplementedSuiteRegistrationServiceServer 

type UnimplementedSuiteRegistrationServiceServer struct {
}

UnimplementedSuiteRegistrationServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSuiteRegistrationServiceServer) RegisterSuite 

func (*UnimplementedSuiteRegistrationServiceServer) RegisterSuite(context.Context, *emptypb.Empty) (*SuiteRegistrationResponse, error)

type UnimplementedTestExecutionServiceServer 

type UnimplementedTestExecutionServiceServer struct {
}

UnimplementedTestExecutionServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedTestExecutionServiceServer) GetTestExecutionInfo 

func (*UnimplementedTestExecutionServiceServer) GetTestExecutionInfo(context.Context, *emptypb.Empty) (*TestExecutionInfo, error)

func (*UnimplementedTestExecutionServiceServer) RegisterService 

func (*UnimplementedTestExecutionServiceServer) RegisterService(context.Context, *RegisterServiceArgs) (*RegisterServiceResponse, error)

func (*UnimplementedTestExecutionServiceServer) RegisterTestExecution 

func (*UnimplementedTestExecutionServiceServer) RegisterTestExecution(context.Context, *RegisterTestExecutionArgs) (*emptypb.Empty, error)

func (*UnimplementedTestExecutionServiceServer) RemoveService 

func (*UnimplementedTestExecutionServiceServer) RemoveService(context.Context, *RemoveServiceArgs) (*emptypb.Empty, error)

func (*UnimplementedTestExecutionServiceServer) Repartition 

func (*UnimplementedTestExecutionServiceServer) Repartition(context.Context, *RepartitionArgs) (*emptypb.Empty, error)

func (*UnimplementedTestExecutionServiceServer) StartService 

func (*UnimplementedTestExecutionServiceServer) StartService(context.Context, *StartServiceArgs) (*emptypb.Empty, 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.