result_flow

package
v0.0.0-...-712ccb0 Latest Latest
Warning

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

Go to latest
Published: Apr 22, 2024 License: BSD-3-Clause Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "SUCCEEDED",
		2: "FAILED",
		3: "TIMED_OUT",
		4: "ABORTED",
	}
	State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"SUCCEEDED":         1,
		"FAILED":            2,
		"TIMED_OUT":         3,
		"ABORTED":           4,
	}
)

Enum value maps for State.

View Source
var File_test_platform_result_flow_common_proto protoreflect.FileDescriptor
View Source
var File_test_platform_result_flow_ctp_proto protoreflect.FileDescriptor
View Source
var File_test_platform_result_flow_publish_proto protoreflect.FileDescriptor
View Source
var File_test_platform_result_flow_test_runner_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BigqueryConfig

type BigqueryConfig struct {
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	Dataset string `protobuf:"bytes,2,opt,name=dataset,proto3" json:"dataset,omitempty"`
	Table   string `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

BigqueryConfig contains the config to interact with Bigquery.

func (*BigqueryConfig) Descriptor deprecated

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

Deprecated: Use BigqueryConfig.ProtoReflect.Descriptor instead.

func (*BigqueryConfig) GetDataset

func (x *BigqueryConfig) GetDataset() string

func (*BigqueryConfig) GetProject

func (x *BigqueryConfig) GetProject() string

func (*BigqueryConfig) GetTable

func (x *BigqueryConfig) GetTable() string

func (*BigqueryConfig) ProtoMessage

func (*BigqueryConfig) ProtoMessage()

func (*BigqueryConfig) ProtoReflect

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

func (*BigqueryConfig) Reset

func (x *BigqueryConfig) Reset()

func (*BigqueryConfig) String

func (x *BigqueryConfig) String() string

type BuildbucketConfig

type BuildbucketConfig struct {
	Host    string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	Bucket  string `protobuf:"bytes,3,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Builder string `protobuf:"bytes,4,opt,name=builder,proto3" json:"builder,omitempty"`
	// contains filtered or unexported fields
}

BuildbucketConfig contains the config to interact with Buildbucket.

func (*BuildbucketConfig) Descriptor deprecated

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

Deprecated: Use BuildbucketConfig.ProtoReflect.Descriptor instead.

func (*BuildbucketConfig) GetBucket

func (x *BuildbucketConfig) GetBucket() string

func (*BuildbucketConfig) GetBuilder

func (x *BuildbucketConfig) GetBuilder() string

func (*BuildbucketConfig) GetHost

func (x *BuildbucketConfig) GetHost() string

func (*BuildbucketConfig) GetProject

func (x *BuildbucketConfig) GetProject() string

func (*BuildbucketConfig) ProtoMessage

func (*BuildbucketConfig) ProtoMessage()

func (*BuildbucketConfig) ProtoReflect

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

func (*BuildbucketConfig) Reset

func (x *BuildbucketConfig) Reset()

func (*BuildbucketConfig) String

func (x *BuildbucketConfig) String() string

type CTPRequest

type CTPRequest struct {

	// The source config for fetching a CTP build.
	Ctp *Source `protobuf:"bytes,1,opt,name=ctp,proto3" json:"ctp,omitempty"`
	// The target to upload the result flow output.
	TestPlanRun *Target `protobuf:"bytes,2,opt,name=test_plan_run,json=testPlanRun,proto3" json:"test_plan_run,omitempty"`
	// Hard deadline for execution.
	//
	// CTP command should abort beyond this deadline.
	Deadline *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=deadline,proto3" json:"deadline,omitempty"`
	// contains filtered or unexported fields
}

CTPRequest defines the input of `result_flow ctp`.

func (*CTPRequest) Descriptor deprecated

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

Deprecated: Use CTPRequest.ProtoReflect.Descriptor instead.

func (*CTPRequest) GetCtp

func (x *CTPRequest) GetCtp() *Source

func (*CTPRequest) GetDeadline

func (x *CTPRequest) GetDeadline() *timestamppb.Timestamp

func (*CTPRequest) GetTestPlanRun

func (x *CTPRequest) GetTestPlanRun() *Target

func (*CTPRequest) ProtoMessage

func (*CTPRequest) ProtoMessage()

func (*CTPRequest) ProtoReflect

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

func (*CTPRequest) Reset

func (x *CTPRequest) Reset()

func (*CTPRequest) String

func (x *CTPRequest) String() string

type CTPResponse

type CTPResponse struct {

	// `result_flow ctp` exits with exit code 0 unless there is an
	// infrastructure failure. When the exit code is 0, `state` indicates the
	// best known state of the ctp command execution (see comments on State enum).
	State State `protobuf:"varint,1,opt,name=state,proto3,enum=test_platform.result_flow.State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

CTPResponse defines the output of `result_flow ctp`.

func (*CTPResponse) Descriptor deprecated

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

Deprecated: Use CTPResponse.ProtoReflect.Descriptor instead.

func (*CTPResponse) GetState

func (x *CTPResponse) GetState() State

func (*CTPResponse) ProtoMessage

func (*CTPResponse) ProtoMessage()

func (*CTPResponse) ProtoReflect

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

func (*CTPResponse) Reset

func (x *CTPResponse) Reset()

func (*CTPResponse) String

func (x *CTPResponse) String() string

type PubSubConfig

type PubSubConfig struct {
	Project              string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	Topic                string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Subscription         string `protobuf:"bytes,3,opt,name=subscription,proto3" json:"subscription,omitempty"`
	MaxReceivingMessages int32  `protobuf:"varint,4,opt,name=max_receiving_messages,json=maxReceivingMessages,proto3" json:"max_receiving_messages,omitempty"`
	// contains filtered or unexported fields
}

PubSubConfig contains the config to interact with Pub/Sub.

func (*PubSubConfig) Descriptor deprecated

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

Deprecated: Use PubSubConfig.ProtoReflect.Descriptor instead.

func (*PubSubConfig) GetMaxReceivingMessages

func (x *PubSubConfig) GetMaxReceivingMessages() int32

func (*PubSubConfig) GetProject

func (x *PubSubConfig) GetProject() string

func (*PubSubConfig) GetSubscription

func (x *PubSubConfig) GetSubscription() string

func (*PubSubConfig) GetTopic

func (x *PubSubConfig) GetTopic() string

func (*PubSubConfig) ProtoMessage

func (*PubSubConfig) ProtoMessage()

func (*PubSubConfig) ProtoReflect

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

func (*PubSubConfig) Reset

func (x *PubSubConfig) Reset()

func (*PubSubConfig) String

func (x *PubSubConfig) String() string

type PublishRequest

type PublishRequest struct {

	// Subscribers call Buildbucket to fetch the build information via this ID.
	BuildId int64 `protobuf:"varint,1,opt,name=build_id,json=buildId,proto3" json:"build_id,omitempty"`
	// Should not be used, as the parent CTP build may contain multiple
	// TestPlanRuns. Use parent_uid below.
	//
	// Deprecated: Do not use.
	ParentBuildId int64 `protobuf:"varint,2,opt,name=parent_build_id,json=parentBuildId,proto3" json:"parent_build_id,omitempty"`
	// PubSub endpoint to publish a CTP build.
	Ctp *PubSubConfig `protobuf:"bytes,3,opt,name=ctp,proto3" json:"ctp,omitempty"`
	// PubSub endpoint to publish a test runner build.
	TestRunner *PubSubConfig `protobuf:"bytes,4,opt,name=test_runner,json=testRunner,proto3" json:"test_runner,omitempty"`
	// Hard deadline for execution.
	//
	// Publish command should abort beyond this deadline.
	Deadline *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=deadline,proto3" json:"deadline,omitempty"`
	// True if subscribers should fetch the build's final status from
	// Buildbucket. The message may be earlier than the build's completion. If
	// the Buildbucket's response does not contain its final status, subscribers
	// should retry. Otherwise, subscribers should expect an intermediate status
	// of the build.
	ShouldPollForCompletion bool `` /* 135-byte string literal not displayed */
	// The UID of the parent test plan run, which kicks off this test run.
	// Placed inside the pubsub message for test_runner builds.
	ParentUid string `protobuf:"bytes,7,opt,name=parent_uid,json=parentUid,proto3" json:"parent_uid,omitempty"`
	// contains filtered or unexported fields
}

PublishRequest defines the input of `result_flow publish`.

func (*PublishRequest) Descriptor deprecated

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

Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.

func (*PublishRequest) GetBuildId

func (x *PublishRequest) GetBuildId() int64

func (*PublishRequest) GetCtp

func (x *PublishRequest) GetCtp() *PubSubConfig

func (*PublishRequest) GetDeadline

func (x *PublishRequest) GetDeadline() *timestamppb.Timestamp

func (*PublishRequest) GetParentBuildId deprecated

func (x *PublishRequest) GetParentBuildId() int64

Deprecated: Do not use.

func (*PublishRequest) GetParentUid

func (x *PublishRequest) GetParentUid() string

func (*PublishRequest) GetShouldPollForCompletion

func (x *PublishRequest) GetShouldPollForCompletion() bool

func (*PublishRequest) GetTestRunner

func (x *PublishRequest) GetTestRunner() *PubSubConfig

func (*PublishRequest) ProtoMessage

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) ProtoReflect

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

func (*PublishRequest) Reset

func (x *PublishRequest) Reset()

func (*PublishRequest) String

func (x *PublishRequest) String() string

type PublishResponse

type PublishResponse struct {

	// `result_flow publish` exits with exit code 0 unless there is an
	// infrastructure failure. When the exit code is 0, `state` indicates the
	// best known state of the publish execution (see comments on State enum).
	State State `protobuf:"varint,1,opt,name=state,proto3,enum=test_platform.result_flow.State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

PublishRequest defines the output of `result_flow publish`.

func (*PublishResponse) Descriptor deprecated

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

Deprecated: Use PublishResponse.ProtoReflect.Descriptor instead.

func (*PublishResponse) GetState

func (x *PublishResponse) GetState() State

func (*PublishResponse) ProtoMessage

func (*PublishResponse) ProtoMessage()

func (*PublishResponse) ProtoReflect

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

func (*PublishResponse) Reset

func (x *PublishResponse) Reset()

func (*PublishResponse) String

func (x *PublishResponse) String() string

type Source

type Source struct {
	Pubsub *PubSubConfig      `protobuf:"bytes,1,opt,name=pubsub,proto3" json:"pubsub,omitempty"`
	Bb     *BuildbucketConfig `protobuf:"bytes,2,opt,name=bb,proto3" json:"bb,omitempty"`
	Fields []string           `protobuf:"bytes,3,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

Source is a wrapper for the source side configuration.

func (*Source) Descriptor deprecated

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

Deprecated: Use Source.ProtoReflect.Descriptor instead.

func (*Source) GetBb

func (x *Source) GetBb() *BuildbucketConfig

func (*Source) GetFields

func (x *Source) GetFields() []string

func (*Source) GetPubsub

func (x *Source) GetPubsub() *PubSubConfig

func (*Source) ProtoMessage

func (*Source) ProtoMessage()

func (*Source) ProtoReflect

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

func (*Source) Reset

func (x *Source) Reset()

func (*Source) String

func (x *Source) String() string

type State

type State int32

Values should be consistent with https://aip.dev/216

const (
	// Should not be used.
	State_STATE_UNSPECIFIED State = 0
	// Successfully executed the command.
	State_SUCCEEDED State = 1
	// Encountered failure during the run.
	State_FAILED State = 2
	// The command has hit the predefined deadline.
	State_TIMED_OUT State = 3
	// The command was aborted externally.
	State_ABORTED State = 4
)

func (State) Descriptor

func (State) Descriptor() protoreflect.EnumDescriptor

func (State) Enum

func (x State) Enum() *State

func (State) EnumDescriptor deprecated

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

Deprecated: Use State.Descriptor instead.

func (State) Number

func (x State) Number() protoreflect.EnumNumber

func (State) String

func (x State) String() string

func (State) Type

func (State) Type() protoreflect.EnumType

type Target

type Target struct {
	Bq *BigqueryConfig `protobuf:"bytes,1,opt,name=bq,proto3" json:"bq,omitempty"`
	// contains filtered or unexported fields
}

Target is a wrapper for the target side configuration.

func (*Target) Descriptor deprecated

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

Deprecated: Use Target.ProtoReflect.Descriptor instead.

func (*Target) GetBq

func (x *Target) GetBq() *BigqueryConfig

func (*Target) ProtoMessage

func (*Target) ProtoMessage()

func (*Target) ProtoReflect

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

func (*Target) Reset

func (x *Target) Reset()

func (*Target) String

func (x *Target) String() string

type TestRunnerRequest

type TestRunnerRequest struct {

	// The source config for fetching the test runner builds.
	TestRunner *Source `protobuf:"bytes,1,opt,name=test_runner,json=testRunner,proto3" json:"test_runner,omitempty"`
	// The target to upload test run results.
	TestRun *Target `protobuf:"bytes,2,opt,name=test_run,json=testRun,proto3" json:"test_run,omitempty"`
	// The target to upload test case results.
	TestCase *Target `protobuf:"bytes,3,opt,name=test_case,json=testCase,proto3" json:"test_case,omitempty"`
	// Hard deadline for execution.
	//
	// TestRunner command should abort beyond this deadline.
	Deadline *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=deadline,proto3" json:"deadline,omitempty"`
	// contains filtered or unexported fields
}

TestRunnerRequest defines the input of `result_flow test_runner`.

func (*TestRunnerRequest) Descriptor deprecated

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

Deprecated: Use TestRunnerRequest.ProtoReflect.Descriptor instead.

func (*TestRunnerRequest) GetDeadline

func (x *TestRunnerRequest) GetDeadline() *timestamppb.Timestamp

func (*TestRunnerRequest) GetTestCase

func (x *TestRunnerRequest) GetTestCase() *Target

func (*TestRunnerRequest) GetTestRun

func (x *TestRunnerRequest) GetTestRun() *Target

func (*TestRunnerRequest) GetTestRunner

func (x *TestRunnerRequest) GetTestRunner() *Source

func (*TestRunnerRequest) ProtoMessage

func (*TestRunnerRequest) ProtoMessage()

func (*TestRunnerRequest) ProtoReflect

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

func (*TestRunnerRequest) Reset

func (x *TestRunnerRequest) Reset()

func (*TestRunnerRequest) String

func (x *TestRunnerRequest) String() string

type TestRunnerResponse

type TestRunnerResponse struct {

	// `result_flow test_runner` exits with exit code 0 unless there is an
	// infrastructure failure. When the exit code is 0, `state` indicates the
	// best known state of the test_runner command execution (see comments on
	// State enum).
	State State `protobuf:"varint,1,opt,name=state,proto3,enum=test_platform.result_flow.State" json:"state,omitempty"`
	// contains filtered or unexported fields
}

TestRunnerResponse defines the output of `result_flow test_runner`.

func (*TestRunnerResponse) Descriptor deprecated

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

Deprecated: Use TestRunnerResponse.ProtoReflect.Descriptor instead.

func (*TestRunnerResponse) GetState

func (x *TestRunnerResponse) GetState() State

func (*TestRunnerResponse) ProtoMessage

func (*TestRunnerResponse) ProtoMessage()

func (*TestRunnerResponse) ProtoReflect

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

func (*TestRunnerResponse) Reset

func (x *TestRunnerResponse) Reset()

func (*TestRunnerResponse) String

func (x *TestRunnerResponse) String() string

Jump to

Keyboard shortcuts

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