// Code generated by protoc-gen-go. DO NOT EDIT.
// source: endpoints.proto

package pipeline_v1

import (
	fmt "fmt"
	proto "github.com/golang/protobuf/proto"
	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

// A description of how to connect to a Beam API endpoint.
type ApiServiceDescriptor struct {
	// (Required) The URL to connect to.
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// (Optional) The method for authentication. If unspecified, access to the
	// url is already being performed in a trusted context (e.g. localhost,
	// private network).
	Authentication       *AuthenticationSpec `protobuf:"bytes,2,opt,name=authentication,proto3" json:"authentication,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

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

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

var xxx_messageInfo_ApiServiceDescriptor proto.InternalMessageInfo

func (m *ApiServiceDescriptor) GetUrl() string {
	if m != nil {
		return m.Url
	}
	return ""
}

func (m *ApiServiceDescriptor) GetAuthentication() *AuthenticationSpec {
	if m != nil {
		return m.Authentication
	}
	return nil
}

type AuthenticationSpec struct {
	// (Required) A URN that describes the accompanying payload.
	// For any URN that is not recognized (by whomever is inspecting
	// it) the parameter payload should be treated as opaque and
	// passed as-is.
	Urn string `protobuf:"bytes,1,opt,name=urn,proto3" json:"urn,omitempty"`
	// (Optional) The data specifying any parameters to the URN. If
	// the URN does not require any arguments, this may be omitted.
	Payload              []byte   `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

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

var xxx_messageInfo_AuthenticationSpec proto.InternalMessageInfo

func (m *AuthenticationSpec) GetUrn() string {
	if m != nil {
		return m.Urn
	}
	return ""
}

func (m *AuthenticationSpec) GetPayload() []byte {
	if m != nil {
		return m.Payload
	}
	return nil
}

func init() {
	proto.RegisterType((*ApiServiceDescriptor)(nil), "org.apache.beam.model.pipeline.v1.ApiServiceDescriptor")
	proto.RegisterType((*AuthenticationSpec)(nil), "org.apache.beam.model.pipeline.v1.AuthenticationSpec")
}

func init() { proto.RegisterFile("endpoints.proto", fileDescriptor_6445e0c85107719d) }

var fileDescriptor_6445e0c85107719d = []byte{
	// 210 bytes of a gzipped FileDescriptorProto
	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0xe2, 0x4f, 0xcd, 0x4b, 0x29,
	0xc8, 0xcf, 0xcc, 0x2b, 0x29, 0xd6, 0x2b, 0x28, 0xca, 0x2f, 0xc9, 0x17, 0x52, 0xcc, 0x2f, 0x4a,
	0xd7, 0x4b, 0x2c, 0x48, 0x4c, 0xce, 0x48, 0xd5, 0x4b, 0x4a, 0x4d, 0xcc, 0xd5, 0xcb, 0xcd, 0x4f,
	0x49, 0xcd, 0xd1, 0x2b, 0xc8, 0x2c, 0x48, 0xcd, 0xc9, 0xcc, 0x4b, 0xd5, 0x2b, 0x33, 0x54, 0x6a,
	0x67, 0xe4, 0x12, 0x71, 0x2c, 0xc8, 0x0c, 0x4e, 0x2d, 0x2a, 0xcb, 0x4c, 0x4e, 0x75, 0x49, 0x2d,
	0x4e, 0x2e, 0xca, 0x2c, 0x28, 0xc9, 0x2f, 0x12, 0x12, 0xe0, 0x62, 0x2e, 0x2d, 0xca, 0x91, 0x60,
	0x54, 0x60, 0xd4, 0xe0, 0x0c, 0x02, 0x31, 0x85, 0x62, 0xb9, 0xf8, 0x12, 0x4b, 0x4b, 0x32, 0x52,
	0xf3, 0x4a, 0x32, 0x93, 0x13, 0x4b, 0x32, 0xf3, 0xf3, 0x24, 0x98, 0x14, 0x18, 0x35, 0xb8, 0x8d,
	0x4c, 0xf5, 0x08, 0x5a, 0xa3, 0xe7, 0x88, 0xa2, 0x31, 0xb8, 0x20, 0x35, 0x39, 0x08, 0xcd, 0x30,
	0x25, 0x07, 0x2e, 0x21, 0x4c, 0x55, 0x10, 0x67, 0xe4, 0x21, 0x9c, 0x91, 0x27, 0x24, 0xc1, 0xc5,
	0x5e, 0x90, 0x58, 0x99, 0x93, 0x9f, 0x98, 0x02, 0xb6, 0x9f, 0x27, 0x08, 0xc6, 0x75, 0xb2, 0xe6,
	0x22, 0xec, 0x61, 0x27, 0x4e, 0x57, 0x58, 0x20, 0x45, 0x71, 0xc3, 0xc4, 0xe3, 0xcb, 0x0c, 0x93,
	0xd8, 0xc0, 0x41, 0x66, 0x0c, 0x08, 0x00, 0x00, 0xff, 0xff, 0x1a, 0x49, 0x57, 0x74, 0x45, 0x01,
	0x00, 0x00,
}
