go/test_platform/multibot/requests.pb.go - mirrors/cros/chromiumos/infra/proto - Git at Google

 // Code generated by protoc-gen-go. DO NOT EDIT.
 // source: test_platform/multibot/requests.proto

 package test_platform_multibot

 import (
 	fmt "fmt"
 	proto "github.com/golang/protobuf/proto"
 	test_platform "go.chromium.org/chromiumos/infra/proto/go/test_platform"
 	phosphorus "go.chromium.org/chromiumos/infra/proto/go/test_platform/phosphorus"
 	math "math"
 )

 // Reference imports to suppress errors if they are not otherwise used.
 var _ = proto.Marshal
 var _ = fmt.Errorf
 var _ = math.Inf

 // This is a compile-time assertion to ensure that this generated file
 // is compatible with the proto package it is being compiled against.
 // A compilation error at this line likely means your copy of the
 // proto package needs to be updated.
 const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package

 // External API for requesting a multi-bot job
 type LeaderRequest struct {
 	// What test to run with the multi-bot task
 	Payload *test_platform.Request_Test `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
 	// What attributes to require and provision for follower tasks
 	FollowerSpecs        []*FollowerSpec `protobuf:"bytes,2,rep,name=follower_specs,json=followerSpecs,proto3" json:"follower_specs,omitempty"`
 	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
 	XXX_unrecognized     []byte          `json:"-"`
 	XXX_sizecache        int32           `json:"-"`
 }

 func (m *LeaderRequest) Reset()         { *m = LeaderRequest{} }
 func (m *LeaderRequest) String() string { return proto.CompactTextString(m) }
 func (*LeaderRequest) ProtoMessage()    {}
 func (*LeaderRequest) Descriptor() ([]byte, []int) {
 	return fileDescriptor_912b836f52cd13db, []int{0}
 }

 func (m *LeaderRequest) XXX_Unmarshal(b []byte) error {
 	return xxx_messageInfo_LeaderRequest.Unmarshal(m, b)
 }
 func (m *LeaderRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
 	return xxx_messageInfo_LeaderRequest.Marshal(b, m, deterministic)
 }
 func (m *LeaderRequest) XXX_Merge(src proto.Message) {
 	xxx_messageInfo_LeaderRequest.Merge(m, src)
 }
 func (m *LeaderRequest) XXX_Size() int {
 	return xxx_messageInfo_LeaderRequest.Size(m)
 }
 func (m *LeaderRequest) XXX_DiscardUnknown() {
 	xxx_messageInfo_LeaderRequest.DiscardUnknown(m)
 }

 var xxx_messageInfo_LeaderRequest proto.InternalMessageInfo

 func (m *LeaderRequest) GetPayload() *test_platform.Request_Test {
 	if m != nil {
 		return m.Payload
 	}
 	return nil
 }

 func (m *LeaderRequest) GetFollowerSpecs() []*FollowerSpec {
 	if m != nil {
 		return m.FollowerSpecs
 	}
 	return nil
 }

 // Internal per-bot request for follower task
 type FollowerRequest struct {
 	// Pubsub subscription to use for this follower task (pre-existing)
 	SubscriptionName string `protobuf:"bytes,1,opt,name=subscription_name,json=subscriptionName,proto3" json:"subscription_name,omitempty"`
 	// Attribute filter to apply to judge whether incoming messages are 'for you'
 	IncomingFilter map[string]string `protobuf:"bytes,2,rep,name=incoming_filter,json=incomingFilter,proto3" json:"incoming_filter,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
 	// Attributes to apply to outgoing messages to address them to the leader
 	OutgoingAttributes map[string]string `protobuf:"bytes,3,rep,name=outgoing_attributes,json=outgoingAttributes,proto3" json:"outgoing_attributes,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
 	// Prejob request parameters
 	Prejob               *phosphorus.PrejobRequest `protobuf:"bytes,4,opt,name=prejob,proto3" json:"prejob,omitempty"`
 	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
 	XXX_unrecognized     []byte                    `json:"-"`
 	XXX_sizecache        int32                     `json:"-"`
 }

 func (m *FollowerRequest) Reset()         { *m = FollowerRequest{} }
 func (m *FollowerRequest) String() string { return proto.CompactTextString(m) }
 func (*FollowerRequest) ProtoMessage()    {}
 func (*FollowerRequest) Descriptor() ([]byte, []int) {
 	return fileDescriptor_912b836f52cd13db, []int{1}
 }

 func (m *FollowerRequest) XXX_Unmarshal(b []byte) error {
 	return xxx_messageInfo_FollowerRequest.Unmarshal(m, b)
 }
 func (m *FollowerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
 	return xxx_messageInfo_FollowerRequest.Marshal(b, m, deterministic)
 }
 func (m *FollowerRequest) XXX_Merge(src proto.Message) {
 	xxx_messageInfo_FollowerRequest.Merge(m, src)
 }
 func (m *FollowerRequest) XXX_Size() int {
 	return xxx_messageInfo_FollowerRequest.Size(m)
 }
 func (m *FollowerRequest) XXX_DiscardUnknown() {
 	xxx_messageInfo_FollowerRequest.DiscardUnknown(m)
 }

 var xxx_messageInfo_FollowerRequest proto.InternalMessageInfo

 func (m *FollowerRequest) GetSubscriptionName() string {
 	if m != nil {
 		return m.SubscriptionName
 	}
 	return ""
 }

 func (m *FollowerRequest) GetIncomingFilter() map[string]string {
 	if m != nil {
 		return m.IncomingFilter
 	}
 	return nil
 }

 func (m *FollowerRequest) GetOutgoingAttributes() map[string]string {
 	if m != nil {
 		return m.OutgoingAttributes
 	}
 	return nil
 }

 func (m *FollowerRequest) GetPrejob() *phosphorus.PrejobRequest {
 	if m != nil {
 		return m.Prejob
 	}
 	return nil
 }

 func init() {
 	proto.RegisterType((*LeaderRequest)(nil), "test_platform.multibot.LeaderRequest")
 	proto.RegisterType((*FollowerRequest)(nil), "test_platform.multibot.FollowerRequest")
 	proto.RegisterMapType((map[string]string)(nil), "test_platform.multibot.FollowerRequest.IncomingFilterEntry")
 	proto.RegisterMapType((map[string]string)(nil), "test_platform.multibot.FollowerRequest.OutgoingAttributesEntry")
 }

 func init() {
 	proto.RegisterFile("test_platform/multibot/requests.proto", fileDescriptor_912b836f52cd13db)
 }

 var fileDescriptor_912b836f52cd13db = []byte{
 	// 386 bytes of a gzipped FileDescriptorProto
 	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x94, 0x52, 0x5d, 0x8b, 0xd3, 0x40,
 	0x14, 0x25, 0x8d, 0x56, 0x9c, 0xd2, 0x0f, 0xa7, 0xa2, 0x21, 0x7d, 0x29, 0x55, 0xb1, 0x20, 0xa4,
 	0x50, 0x11, 0x44, 0x1f, 0x4a, 0x1f, 0x5a, 0x10, 0x45, 0x25, 0xfa, 0x1e, 0x26, 0xe9, 0x4d, 0x3b,
 	0x9a, 0xe4, 0xce, 0xce, 0x4c, 0x76, 0xe9, 0xef, 0xd8, 0x5f, 0xb8, 0xff, 0x64, 0x69, 0x32, 0xd9,
 	0x6d, 0xba, 0x2d, 0xbb, 0xfb, 0x96, 0x7b, 0xcf, 0x39, 0xf7, 0x9c, 0x9b, 0xb9, 0xe4, 0x9d, 0x06,
 	0xa5, 0x03, 0x91, 0x30, 0x1d, 0xa3, 0x4c, 0x27, 0x69, 0x9e, 0x68, 0x1e, 0xa2, 0x9e, 0x48, 0x38,
 	0xcb, 0x41, 0x69, 0xe5, 0x09, 0x89, 0x1a, 0xe9, 0xab, 0x1a, 0xcd, 0xab, 0x68, 0xee, 0x81, 0x5c,
 	0x6c, 0x50, 0x89, 0x0d, 0xca, 0x5c, 0x4d, 0x84, 0x84, 0x7f, 0x18, 0x96, 0x72, 0xf7, 0xcd, 0x09,
 	0x97, 0x08, 0xd3, 0x14, 0x33, 0x43, 0x1a, 0xd4, 0x49, 0x26, 0x41, 0x09, 0x8e, 0x2e, 0x2d, 0xd2,
 	0xfe, 0x01, 0x6c, 0x05, 0xd2, 0x2f, 0xfb, 0xf4, 0x13, 0x79, 0x26, 0xd8, 0x36, 0x41, 0xb6, 0x72,
 	0xac, 0xa1, 0x35, 0x6e, 0x4d, 0x07, 0x5e, 0x3d, 0xa4, 0x21, 0x7a, 0x7f, 0x41, 0x69, 0xbf, 0xe2,
 	0xd2, 0xef, 0xa4, 0x13, 0x63, 0x92, 0xe0, 0x05, 0xc8, 0x40, 0x09, 0x88, 0x94, 0xd3, 0x18, 0xda,
 	0xe3, 0xd6, 0xf4, 0xad, 0x77, 0x7c, 0x45, 0x6f, 0x69, 0xd8, 0x7f, 0x04, 0x44, 0x7e, 0x3b, 0xde,
 	0xab, 0xd4, 0xe8, 0xca, 0x26, 0xdd, 0x0a, 0xaf, 0x72, 0x7d, 0x20, 0x2f, 0x54, 0x1e, 0xaa, 0x48,
 	0x72, 0xa1, 0x39, 0x66, 0x41, 0xc6, 0x52, 0x28, 0x12, 0x3e, 0xf7, 0x7b, 0xfb, 0xc0, 0x4f, 0x96,
 	0x02, 0x5d, 0x91, 0x2e, 0xcf, 0x22, 0x4c, 0x79, 0xb6, 0x0e, 0x62, 0x9e, 0x68, 0x90, 0x26, 0xce,
 	0xd7, 0xfb, 0xe2, 0x54, 0xdb, 0x7d, 0x33, 0xf2, 0x65, 0xa1, 0x5e, 0x64, 0x5a, 0x6e, 0xfd, 0x0e,
 	0xaf, 0x35, 0xa9, 0x20, 0x7d, 0xcc, 0xf5, 0x1a, 0x77, 0x2e, 0x4c, 0x6b, 0xc9, 0xc3, 0x5c, 0x83,
 	0x72, 0xec, 0xc2, 0x69, 0xf6, 0x50, 0xa7, 0x5f, 0x66, 0xc4, 0xfc, 0x66, 0x42, 0xe9, 0x46, 0xf1,
 	0x0e, 0x40, 0x67, 0xa4, 0x59, 0x1e, 0x80, 0xf3, 0xa4, 0x78, 0x9b, 0xf7, 0x07, 0x26, 0xb7, 0x87,
 	0xe2, 0xfd, 0x2e, 0x78, 0xc6, 0xc4, 0x37, 0x32, 0x77, 0x4e, 0xfa, 0x47, 0x36, 0xa3, 0x3d, 0x62,
 	0xff, 0x87, 0xad, 0xf9, 0x9d, 0xbb, 0x4f, 0xfa, 0x92, 0x3c, 0x3d, 0x67, 0x49, 0x0e, 0x4e, 0xa3,
 	0xe8, 0x95, 0xc5, 0x97, 0xc6, 0x67, 0xcb, 0x5d, 0x90, 0xd7, 0x27, 0x22, 0x3f, 0x66, 0x4c, 0xd8,
 	0x2c, 0x0e, 0xf0, 0xe3, 0x75, 0x00, 0x00, 0x00, 0xff, 0xff, 0x33, 0x45, 0x2a, 0xec, 0x2a, 0x03,
 	0x00, 0x00,
 }
	// Code generated by protoc-gen-go. DO NOT EDIT.
	// source: test_platform/multibot/requests.proto

	package test_platform_multibot

	import (
	fmt "fmt"
	proto "github.com/golang/protobuf/proto"
	test_platform "go.chromium.org/chromiumos/infra/proto/go/test_platform"
	phosphorus "go.chromium.org/chromiumos/infra/proto/go/test_platform/phosphorus"
	math "math"
	)

	// Reference imports to suppress errors if they are not otherwise used.
	var _ = proto.Marshal
	var _ = fmt.Errorf
	var _ = math.Inf

	// This is a compile-time assertion to ensure that this generated file
	// is compatible with the proto package it is being compiled against.
	// A compilation error at this line likely means your copy of the
	// proto package needs to be updated.
	const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package

	// External API for requesting a multi-bot job
	type LeaderRequest struct {
	// What test to run with the multi-bot task
	Payload *test_platform.Request_Test `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// What attributes to require and provision for follower tasks
	FollowerSpecs []*FollowerSpec `protobuf:"bytes,2,rep,name=follower_specs,json=followerSpecs,proto3" json:"follower_specs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized []byte `json:"-"`
	XXX_sizecache int32 `json:"-"`
	}

	func (m LeaderRequest) Reset() { m = LeaderRequest{} }
	func (m *LeaderRequest) String() string { return proto.CompactTextString(m) }
	func (*LeaderRequest) ProtoMessage() {}
	func (*LeaderRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_912b836f52cd13db, []int{0}
	}

	func (m *LeaderRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_LeaderRequest.Unmarshal(m, b)
	}
	func (m *LeaderRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_LeaderRequest.Marshal(b, m, deterministic)
	}
	func (m *LeaderRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_LeaderRequest.Merge(m, src)
	}
	func (m *LeaderRequest) XXX_Size() int {
	return xxx_messageInfo_LeaderRequest.Size(m)
	}
	func (m *LeaderRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_LeaderRequest.DiscardUnknown(m)
	}

	var xxx_messageInfo_LeaderRequest proto.InternalMessageInfo

	func (m LeaderRequest) GetPayload() test_platform.Request_Test {
	if m != nil {
	return m.Payload
	}
	return nil
	}

	func (m LeaderRequest) GetFollowerSpecs() []FollowerSpec {
	if m != nil {
	return m.FollowerSpecs
	}
	return nil
	}

	// Internal per-bot request for follower task
	type FollowerRequest struct {
	// Pubsub subscription to use for this follower task (pre-existing)
	SubscriptionName string `protobuf:"bytes,1,opt,name=subscription_name,json=subscriptionName,proto3" json:"subscription_name,omitempty"`
	// Attribute filter to apply to judge whether incoming messages are 'for you'
	IncomingFilter map[string]string `protobuf:"bytes,2,rep,name=incoming_filter,json=incomingFilter,proto3" json:"incoming_filter,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// Attributes to apply to outgoing messages to address them to the leader
	OutgoingAttributes map[string]string `protobuf:"bytes,3,rep,name=outgoing_attributes,json=outgoingAttributes,proto3" json:"outgoing_attributes,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// Prejob request parameters
	Prejob *phosphorus.PrejobRequest `protobuf:"bytes,4,opt,name=prejob,proto3" json:"prejob,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized []byte `json:"-"`
	XXX_sizecache int32 `json:"-"`
	}

	func (m FollowerRequest) Reset() { m = FollowerRequest{} }
	func (m *FollowerRequest) String() string { return proto.CompactTextString(m) }
	func (*FollowerRequest) ProtoMessage() {}
	func (*FollowerRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_912b836f52cd13db, []int{1}
	}

	func (m *FollowerRequest) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_FollowerRequest.Unmarshal(m, b)
	}
	func (m *FollowerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_FollowerRequest.Marshal(b, m, deterministic)
	}
	func (m *FollowerRequest) XXX_Merge(src proto.Message) {
	xxx_messageInfo_FollowerRequest.Merge(m, src)
	}
	func (m *FollowerRequest) XXX_Size() int {
	return xxx_messageInfo_FollowerRequest.Size(m)
	}
	func (m *FollowerRequest) XXX_DiscardUnknown() {
	xxx_messageInfo_FollowerRequest.DiscardUnknown(m)
	}

	var xxx_messageInfo_FollowerRequest proto.InternalMessageInfo

	func (m *FollowerRequest) GetSubscriptionName() string {
	if m != nil {
	return m.SubscriptionName
	}
	return ""
	}

	func (m *FollowerRequest) GetIncomingFilter() map[string]string {
	if m != nil {
	return m.IncomingFilter
	}
	return nil
	}

	func (m *FollowerRequest) GetOutgoingAttributes() map[string]string {
	if m != nil {
	return m.OutgoingAttributes
	}
	return nil
	}

	func (m FollowerRequest) GetPrejob() phosphorus.PrejobRequest {
	if m != nil {
	return m.Prejob
	}
	return nil
	}

	func init() {
	proto.RegisterType((*LeaderRequest)(nil), "test_platform.multibot.LeaderRequest")
	proto.RegisterType((*FollowerRequest)(nil), "test_platform.multibot.FollowerRequest")
	proto.RegisterMapType((map[string]string)(nil), "test_platform.multibot.FollowerRequest.IncomingFilterEntry")
	proto.RegisterMapType((map[string]string)(nil), "test_platform.multibot.FollowerRequest.OutgoingAttributesEntry")
	}

	func init() {
	proto.RegisterFile("test_platform/multibot/requests.proto", fileDescriptor_912b836f52cd13db)
	}

	var fileDescriptor_912b836f52cd13db = []byte{
	// 386 bytes of a gzipped FileDescriptorProto
	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x94, 0x52, 0x5d, 0x8b, 0xd3, 0x40,
	0x14, 0x25, 0x8d, 0x56, 0x9c, 0xd2, 0x0f, 0xa7, 0xa2, 0x21, 0x7d, 0x29, 0x55, 0xb1, 0x20, 0xa4,
	0x50, 0x11, 0x44, 0x1f, 0x4a, 0x1f, 0x5a, 0x10, 0x45, 0x25, 0xfa, 0x1e, 0x26, 0xe9, 0x4d, 0x3b,
	0x9a, 0xe4, 0xce, 0xce, 0x4c, 0x76, 0xe9, 0xef, 0xd8, 0x5f, 0xb8, 0xff, 0x64, 0x69, 0x32, 0xd9,
	0x6d, 0xba, 0x2d, 0xbb, 0xfb, 0x96, 0x7b, 0xcf, 0x39, 0xf7, 0x9c, 0x9b, 0xb9, 0xe4, 0x9d, 0x06,
	0xa5, 0x03, 0x91, 0x30, 0x1d, 0xa3, 0x4c, 0x27, 0x69, 0x9e, 0x68, 0x1e, 0xa2, 0x9e, 0x48, 0x38,
	0xcb, 0x41, 0x69, 0xe5, 0x09, 0x89, 0x1a, 0xe9, 0xab, 0x1a, 0xcd, 0xab, 0x68, 0xee, 0x81, 0x5c,
	0x6c, 0x50, 0x89, 0x0d, 0xca, 0x5c, 0x4d, 0x84, 0x84, 0x7f, 0x18, 0x96, 0x72, 0xf7, 0xcd, 0x09,
	0x97, 0x08, 0xd3, 0x14, 0x33, 0x43, 0x1a, 0xd4, 0x49, 0x26, 0x41, 0x09, 0x8e, 0x2e, 0x2d, 0xd2,
	0xfe, 0x01, 0x6c, 0x05, 0xd2, 0x2f, 0xfb, 0xf4, 0x13, 0x79, 0x26, 0xd8, 0x36, 0x41, 0xb6, 0x72,
	0xac, 0xa1, 0x35, 0x6e, 0x4d, 0x07, 0x5e, 0x3d, 0xa4, 0x21, 0x7a, 0x7f, 0x41, 0x69, 0xbf, 0xe2,
	0xd2, 0xef, 0xa4, 0x13, 0x63, 0x92, 0xe0, 0x05, 0xc8, 0x40, 0x09, 0x88, 0x94, 0xd3, 0x18, 0xda,
	0xe3, 0xd6, 0xf4, 0xad, 0x77, 0x7c, 0x45, 0x6f, 0x69, 0xd8, 0x7f, 0x04, 0x44, 0x7e, 0x3b, 0xde,
	0xab, 0xd4, 0xe8, 0xca, 0x26, 0xdd, 0x0a, 0xaf, 0x72, 0x7d, 0x20, 0x2f, 0x54, 0x1e, 0xaa, 0x48,
	0x72, 0xa1, 0x39, 0x66, 0x41, 0xc6, 0x52, 0x28, 0x12, 0x3e, 0xf7, 0x7b, 0xfb, 0xc0, 0x4f, 0x96,
	0x02, 0x5d, 0x91, 0x2e, 0xcf, 0x22, 0x4c, 0x79, 0xb6, 0x0e, 0x62, 0x9e, 0x68, 0x90, 0x26, 0xce,
	0xd7, 0xfb, 0xe2, 0x54, 0xdb, 0x7d, 0x33, 0xf2, 0x65, 0xa1, 0x5e, 0x64, 0x5a, 0x6e, 0xfd, 0x0e,
	0xaf, 0x35, 0xa9, 0x20, 0x7d, 0xcc, 0xf5, 0x1a, 0x77, 0x2e, 0x4c, 0x6b, 0xc9, 0xc3, 0x5c, 0x83,
	0x72, 0xec, 0xc2, 0x69, 0xf6, 0x50, 0xa7, 0x5f, 0x66, 0xc4, 0xfc, 0x66, 0x42, 0xe9, 0x46, 0xf1,
	0x0e, 0x40, 0x67, 0xa4, 0x59, 0x1e, 0x80, 0xf3, 0xa4, 0x78, 0x9b, 0xf7, 0x07, 0x26, 0xb7, 0x87,
	0xe2, 0xfd, 0x2e, 0x78, 0xc6, 0xc4, 0x37, 0x32, 0x77, 0x4e, 0xfa, 0x47, 0x36, 0xa3, 0x3d, 0x62,
	0xff, 0x87, 0xad, 0xf9, 0x9d, 0xbb, 0x4f, 0xfa, 0x92, 0x3c, 0x3d, 0x67, 0x49, 0x0e, 0x4e, 0xa3,
	0xe8, 0x95, 0xc5, 0x97, 0xc6, 0x67, 0xcb, 0x5d, 0x90, 0xd7, 0x27, 0x22, 0x3f, 0x66, 0x4c, 0xd8,
	0x2c, 0x0e, 0xf0, 0xe3, 0x75, 0x00, 0x00, 0x00, 0xff, 0xff, 0x33, 0x45, 0x2a, 0xec, 0x2a, 0x03,
	0x00, 0x00,
	}