// Code generated by protoc-gen-go. DO NOT EDIT.
// source: code.justin.tv/eventbus/controlplane/rpc/event_streams.proto

package rpc

import proto "github.com/golang/protobuf/proto"
import fmt "fmt"
import math "math"
import timestamp "github.com/golang/protobuf/ptypes/timestamp"
import wrappers "github.com/golang/protobuf/ptypes/wrappers"

// 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.ProtoPackageIsVersion2 // please upgrade the proto package

type EventType struct {
	// TODO (nw): do we actually want to include all of these for now?
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description          string   `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	RepoFilepath         string   `protobuf:"bytes,4,opt,name=repo_filepath,json=repoFilepath,proto3" json:"repo_filepath,omitempty"`
	Deprecated           bool     `protobuf:"varint,5,opt,name=deprecated,proto3" json:"deprecated,omitempty"`
	LdapGroup            string   `protobuf:"bytes,6,opt,name=ldap_group,json=ldapGroup,proto3" json:"ldap_group,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *EventType) Reset()         { *m = EventType{} }
func (m *EventType) String() string { return proto.CompactTextString(m) }
func (*EventType) ProtoMessage()    {}
func (*EventType) Descriptor() ([]byte, []int) {
	return fileDescriptor_event_streams_b2fb4ccd6fdde033, []int{0}
}
func (m *EventType) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_EventType.Unmarshal(m, b)
}
func (m *EventType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_EventType.Marshal(b, m, deterministic)
}
func (dst *EventType) XXX_Merge(src proto.Message) {
	xxx_messageInfo_EventType.Merge(dst, src)
}
func (m *EventType) XXX_Size() int {
	return xxx_messageInfo_EventType.Size(m)
}
func (m *EventType) XXX_DiscardUnknown() {
	xxx_messageInfo_EventType.DiscardUnknown(m)
}

var xxx_messageInfo_EventType proto.InternalMessageInfo

func (m *EventType) GetId() string {
	if m != nil {
		return m.Id
	}
	return ""
}

func (m *EventType) GetName() string {
	if m != nil {
		return m.Name
	}
	return ""
}

func (m *EventType) GetDescription() string {
	if m != nil {
		return m.Description
	}
	return ""
}

func (m *EventType) GetRepoFilepath() string {
	if m != nil {
		return m.RepoFilepath
	}
	return ""
}

func (m *EventType) GetDeprecated() bool {
	if m != nil {
		return m.Deprecated
	}
	return false
}

func (m *EventType) GetLdapGroup() string {
	if m != nil {
		return m.LdapGroup
	}
	return ""
}

type ListEventTypesReq struct {
	// TODO (nw): should this be in a wrapping struct which indicates these are various filtering options? Maybe.
	LdapGroup            string   `protobuf:"bytes,1,opt,name=ldap_group,json=ldapGroup,proto3" json:"ldap_group,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ListEventTypesReq) Reset()         { *m = ListEventTypesReq{} }
func (m *ListEventTypesReq) String() string { return proto.CompactTextString(m) }
func (*ListEventTypesReq) ProtoMessage()    {}
func (*ListEventTypesReq) Descriptor() ([]byte, []int) {
	return fileDescriptor_event_streams_b2fb4ccd6fdde033, []int{1}
}
func (m *ListEventTypesReq) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListEventTypesReq.Unmarshal(m, b)
}
func (m *ListEventTypesReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListEventTypesReq.Marshal(b, m, deterministic)
}
func (dst *ListEventTypesReq) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListEventTypesReq.Merge(dst, src)
}
func (m *ListEventTypesReq) XXX_Size() int {
	return xxx_messageInfo_ListEventTypesReq.Size(m)
}
func (m *ListEventTypesReq) XXX_DiscardUnknown() {
	xxx_messageInfo_ListEventTypesReq.DiscardUnknown(m)
}

var xxx_messageInfo_ListEventTypesReq proto.InternalMessageInfo

func (m *ListEventTypesReq) GetLdapGroup() string {
	if m != nil {
		return m.LdapGroup
	}
	return ""
}

type ListEventTypesResp struct {
	EventTypes           []*EventType `protobuf:"bytes,1,rep,name=event_types,json=eventTypes,proto3" json:"event_types,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (m *ListEventTypesResp) Reset()         { *m = ListEventTypesResp{} }
func (m *ListEventTypesResp) String() string { return proto.CompactTextString(m) }
func (*ListEventTypesResp) ProtoMessage()    {}
func (*ListEventTypesResp) Descriptor() ([]byte, []int) {
	return fileDescriptor_event_streams_b2fb4ccd6fdde033, []int{2}
}
func (m *ListEventTypesResp) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListEventTypesResp.Unmarshal(m, b)
}
func (m *ListEventTypesResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListEventTypesResp.Marshal(b, m, deterministic)
}
func (dst *ListEventTypesResp) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListEventTypesResp.Merge(dst, src)
}
func (m *ListEventTypesResp) XXX_Size() int {
	return xxx_messageInfo_ListEventTypesResp.Size(m)
}
func (m *ListEventTypesResp) XXX_DiscardUnknown() {
	xxx_messageInfo_ListEventTypesResp.DiscardUnknown(m)
}

var xxx_messageInfo_ListEventTypesResp proto.InternalMessageInfo

func (m *ListEventTypesResp) GetEventTypes() []*EventType {
	if m != nil {
		return m.EventTypes
	}
	return nil
}

type ListEventStreamsReq struct {
	Cursor               string   `protobuf:"bytes,1,opt,name=cursor,proto3" json:"cursor,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ListEventStreamsReq) Reset()         { *m = ListEventStreamsReq{} }
func (m *ListEventStreamsReq) String() string { return proto.CompactTextString(m) }
func (*ListEventStreamsReq) ProtoMessage()    {}
func (*ListEventStreamsReq) Descriptor() ([]byte, []int) {
	return fileDescriptor_event_streams_b2fb4ccd6fdde033, []int{3}
}
func (m *ListEventStreamsReq) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListEventStreamsReq.Unmarshal(m, b)
}
func (m *ListEventStreamsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListEventStreamsReq.Marshal(b, m, deterministic)
}
func (dst *ListEventStreamsReq) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListEventStreamsReq.Merge(dst, src)
}
func (m *ListEventStreamsReq) XXX_Size() int {
	return xxx_messageInfo_ListEventStreamsReq.Size(m)
}
func (m *ListEventStreamsReq) XXX_DiscardUnknown() {
	xxx_messageInfo_ListEventStreamsReq.DiscardUnknown(m)
}

var xxx_messageInfo_ListEventStreamsReq proto.InternalMessageInfo

func (m *ListEventStreamsReq) GetCursor() string {
	if m != nil {
		return m.Cursor
	}
	return ""
}

type ListEventStreamsResp struct {
	EventStreams []*EventStream `protobuf:"bytes,1,rep,name=event_streams,json=eventStreams,proto3" json:"event_streams,omitempty"`
	// If next_cursor is returned, it is an opaque string to get the next page of results
	NextCursor           string   `protobuf:"bytes,2,opt,name=next_cursor,json=nextCursor,proto3" json:"next_cursor,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ListEventStreamsResp) Reset()         { *m = ListEventStreamsResp{} }
func (m *ListEventStreamsResp) String() string { return proto.CompactTextString(m) }
func (*ListEventStreamsResp) ProtoMessage()    {}
func (*ListEventStreamsResp) Descriptor() ([]byte, []int) {
	return fileDescriptor_event_streams_b2fb4ccd6fdde033, []int{4}
}
func (m *ListEventStreamsResp) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_ListEventStreamsResp.Unmarshal(m, b)
}
func (m *ListEventStreamsResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_ListEventStreamsResp.Marshal(b, m, deterministic)
}
func (dst *ListEventStreamsResp) XXX_Merge(src proto.Message) {
	xxx_messageInfo_ListEventStreamsResp.Merge(dst, src)
}
func (m *ListEventStreamsResp) XXX_Size() int {
	return xxx_messageInfo_ListEventStreamsResp.Size(m)
}
func (m *ListEventStreamsResp) XXX_DiscardUnknown() {
	xxx_messageInfo_ListEventStreamsResp.DiscardUnknown(m)
}

var xxx_messageInfo_ListEventStreamsResp proto.InternalMessageInfo

func (m *ListEventStreamsResp) GetEventStreams() []*EventStream {
	if m != nil {
		return m.EventStreams
	}
	return nil
}

func (m *ListEventStreamsResp) GetNextCursor() string {
	if m != nil {
		return m.NextCursor
	}
	return ""
}

type GetEventStreamReq struct {
	EventType            string   `protobuf:"bytes,1,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
	Environment          string   `protobuf:"bytes,2,opt,name=environment,proto3" json:"environment,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *GetEventStreamReq) Reset()         { *m = GetEventStreamReq{} }
func (m *GetEventStreamReq) String() string { return proto.CompactTextString(m) }
func (*GetEventStreamReq) ProtoMessage()    {}
func (*GetEventStreamReq) Descriptor() ([]byte, []int) {
	return fileDescriptor_event_streams_b2fb4ccd6fdde033, []int{5}
}
func (m *GetEventStreamReq) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_GetEventStreamReq.Unmarshal(m, b)
}
func (m *GetEventStreamReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_GetEventStreamReq.Marshal(b, m, deterministic)
}
func (dst *GetEventStreamReq) XXX_Merge(src proto.Message) {
	xxx_messageInfo_GetEventStreamReq.Merge(dst, src)
}
func (m *GetEventStreamReq) XXX_Size() int {
	return xxx_messageInfo_GetEventStreamReq.Size(m)
}
func (m *GetEventStreamReq) XXX_DiscardUnknown() {
	xxx_messageInfo_GetEventStreamReq.DiscardUnknown(m)
}

var xxx_messageInfo_GetEventStreamReq proto.InternalMessageInfo

func (m *GetEventStreamReq) GetEventType() string {
	if m != nil {
		return m.EventType
	}
	return ""
}

func (m *GetEventStreamReq) GetEnvironment() string {
	if m != nil {
		return m.Environment
	}
	return ""
}

type GetEventStreamStatsReq struct {
	EventType            string   `protobuf:"bytes,1,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
	Environment          string   `protobuf:"bytes,2,opt,name=environment,proto3" json:"environment,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *GetEventStreamStatsReq) Reset()         { *m = GetEventStreamStatsReq{} }
func (m *GetEventStreamStatsReq) String() string { return proto.CompactTextString(m) }
func (*GetEventStreamStatsReq) ProtoMessage()    {}
func (*GetEventStreamStatsReq) Descriptor() ([]byte, []int) {
	return fileDescriptor_event_streams_b2fb4ccd6fdde033, []int{6}
}
func (m *GetEventStreamStatsReq) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_GetEventStreamStatsReq.Unmarshal(m, b)
}
func (m *GetEventStreamStatsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_GetEventStreamStatsReq.Marshal(b, m, deterministic)
}
func (dst *GetEventStreamStatsReq) XXX_Merge(src proto.Message) {
	xxx_messageInfo_GetEventStreamStatsReq.Merge(dst, src)
}
func (m *GetEventStreamStatsReq) XXX_Size() int {
	return xxx_messageInfo_GetEventStreamStatsReq.Size(m)
}
func (m *GetEventStreamStatsReq) XXX_DiscardUnknown() {
	xxx_messageInfo_GetEventStreamStatsReq.DiscardUnknown(m)
}

var xxx_messageInfo_GetEventStreamStatsReq proto.InternalMessageInfo

func (m *GetEventStreamStatsReq) GetEventType() string {
	if m != nil {
		return m.EventType
	}
	return ""
}

func (m *GetEventStreamStatsReq) GetEnvironment() string {
	if m != nil {
		return m.Environment
	}
	return ""
}

type EventStream struct {
	EventType            string               `protobuf:"bytes,1,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"`
	Environment          string               `protobuf:"bytes,2,opt,name=environment,proto3" json:"environment,omitempty"`
	DisplayName          string               `protobuf:"bytes,3,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	ShortDescription     string               `protobuf:"bytes,4,opt,name=short_description,json=shortDescription,proto3" json:"short_description,omitempty"`
	ActiveSince          *timestamp.Timestamp `protobuf:"bytes,5,opt,name=active_since,json=activeSince,proto3" json:"active_since,omitempty"`
	Description          string               `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	Stats                *EventStreamStats    `protobuf:"bytes,7,opt,name=stats,proto3" json:"stats,omitempty"`
	Schema               string               `protobuf:"bytes,8,opt,name=schema,proto3" json:"schema,omitempty"`
	RepoFilepath         string               `protobuf:"bytes,9,opt,name=repo_filepath,json=repoFilepath,proto3" json:"repo_filepath,omitempty"`
	AuthorizedFields     []*AuthorizedField   `protobuf:"bytes,10,rep,name=authorized_fields,json=authorizedFields,proto3" json:"authorized_fields,omitempty"`
	Deprecated           bool                 `protobuf:"varint,11,opt,name=deprecated,proto3" json:"deprecated,omitempty"`
	LdapGroup            string               `protobuf:"bytes,12,opt,name=ldap_group,json=ldapGroup,proto3" json:"ldap_group,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (m *EventStream) Reset()         { *m = EventStream{} }
func (m *EventStream) String() string { return proto.CompactTextString(m) }
func (*EventStream) ProtoMessage()    {}
func (*EventStream) Descriptor() ([]byte, []int) {
	return fileDescriptor_event_streams_b2fb4ccd6fdde033, []int{7}
}
func (m *EventStream) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_EventStream.Unmarshal(m, b)
}
func (m *EventStream) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_EventStream.Marshal(b, m, deterministic)
}
func (dst *EventStream) XXX_Merge(src proto.Message) {
	xxx_messageInfo_EventStream.Merge(dst, src)
}
func (m *EventStream) XXX_Size() int {
	return xxx_messageInfo_EventStream.Size(m)
}
func (m *EventStream) XXX_DiscardUnknown() {
	xxx_messageInfo_EventStream.DiscardUnknown(m)
}

var xxx_messageInfo_EventStream proto.InternalMessageInfo

func (m *EventStream) GetEventType() string {
	if m != nil {
		return m.EventType
	}
	return ""
}

func (m *EventStream) GetEnvironment() string {
	if m != nil {
		return m.Environment
	}
	return ""
}

func (m *EventStream) GetDisplayName() string {
	if m != nil {
		return m.DisplayName
	}
	return ""
}

func (m *EventStream) GetShortDescription() string {
	if m != nil {
		return m.ShortDescription
	}
	return ""
}

func (m *EventStream) GetActiveSince() *timestamp.Timestamp {
	if m != nil {
		return m.ActiveSince
	}
	return nil
}

func (m *EventStream) GetDescription() string {
	if m != nil {
		return m.Description
	}
	return ""
}

func (m *EventStream) GetStats() *EventStreamStats {
	if m != nil {
		return m.Stats
	}
	return nil
}

func (m *EventStream) GetSchema() string {
	if m != nil {
		return m.Schema
	}
	return ""
}

func (m *EventStream) GetRepoFilepath() string {
	if m != nil {
		return m.RepoFilepath
	}
	return ""
}

func (m *EventStream) GetAuthorizedFields() []*AuthorizedField {
	if m != nil {
		return m.AuthorizedFields
	}
	return nil
}

func (m *EventStream) GetDeprecated() bool {
	if m != nil {
		return m.Deprecated
	}
	return false
}

func (m *EventStream) GetLdapGroup() string {
	if m != nil {
		return m.LdapGroup
	}
	return ""
}

// EventStreamStats gives some basic stats about the event.
// We use wrapper types here so that we can meaningfully provide 'null' values
// for stats we do not currently know.
type EventStreamStats struct {
	TpsMean              *wrappers.DoubleValue   `protobuf:"bytes,1,opt,name=tps_mean,json=tpsMean,proto3" json:"tps_mean,omitempty"` // Deprecated: Do not use.
	Tps_95Th             *wrappers.DoubleValue   `protobuf:"bytes,2,opt,name=tps_95th,json=tps95th,proto3" json:"tps_95th,omitempty"` // Deprecated: Do not use.
	MeanEventsPerMinute  *wrappers.DoubleValue   `protobuf:"bytes,3,opt,name=mean_events_per_minute,json=meanEventsPerMinute,proto3" json:"mean_events_per_minute,omitempty"`
	MaxEventsPerMinute   *wrappers.DoubleValue   `protobuf:"bytes,4,opt,name=max_events_per_minute,json=maxEventsPerMinute,proto3" json:"max_events_per_minute,omitempty"`
	MinEventsPerMinute   *wrappers.DoubleValue   `protobuf:"bytes,5,opt,name=min_events_per_minute,json=minEventsPerMinute,proto3" json:"min_events_per_minute,omitempty"`
	MeanEventPayloadSize *wrappers.DoubleValue   `protobuf:"bytes,6,opt,name=mean_event_payload_size,json=meanEventPayloadSize,proto3" json:"mean_event_payload_size,omitempty"`
	PublisherCount       uint32                  `protobuf:"varint,7,opt,name=publisher_count,json=publisherCount,proto3" json:"publisher_count,omitempty"`    // Deprecated: Do not use.
	SubscriberCount      uint32                  `protobuf:"varint,8,opt,name=subscriber_count,json=subscriberCount,proto3" json:"subscriber_count,omitempty"` // Deprecated: Do not use.
	Publishers           []*PublisherServiceInfo `protobuf:"bytes,9,rep,name=publishers,proto3" json:"publishers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (m *EventStreamStats) Reset()         { *m = EventStreamStats{} }
func (m *EventStreamStats) String() string { return proto.CompactTextString(m) }
func (*EventStreamStats) ProtoMessage()    {}
func (*EventStreamStats) Descriptor() ([]byte, []int) {
	return fileDescriptor_event_streams_b2fb4ccd6fdde033, []int{8}
}
func (m *EventStreamStats) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_EventStreamStats.Unmarshal(m, b)
}
func (m *EventStreamStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_EventStreamStats.Marshal(b, m, deterministic)
}
func (dst *EventStreamStats) XXX_Merge(src proto.Message) {
	xxx_messageInfo_EventStreamStats.Merge(dst, src)
}
func (m *EventStreamStats) XXX_Size() int {
	return xxx_messageInfo_EventStreamStats.Size(m)
}
func (m *EventStreamStats) XXX_DiscardUnknown() {
	xxx_messageInfo_EventStreamStats.DiscardUnknown(m)
}

var xxx_messageInfo_EventStreamStats proto.InternalMessageInfo

// Deprecated: Do not use.
func (m *EventStreamStats) GetTpsMean() *wrappers.DoubleValue {
	if m != nil {
		return m.TpsMean
	}
	return nil
}

// Deprecated: Do not use.
func (m *EventStreamStats) GetTps_95Th() *wrappers.DoubleValue {
	if m != nil {
		return m.Tps_95Th
	}
	return nil
}

func (m *EventStreamStats) GetMeanEventsPerMinute() *wrappers.DoubleValue {
	if m != nil {
		return m.MeanEventsPerMinute
	}
	return nil
}

func (m *EventStreamStats) GetMaxEventsPerMinute() *wrappers.DoubleValue {
	if m != nil {
		return m.MaxEventsPerMinute
	}
	return nil
}

func (m *EventStreamStats) GetMinEventsPerMinute() *wrappers.DoubleValue {
	if m != nil {
		return m.MinEventsPerMinute
	}
	return nil
}

func (m *EventStreamStats) GetMeanEventPayloadSize() *wrappers.DoubleValue {
	if m != nil {
		return m.MeanEventPayloadSize
	}
	return nil
}

// Deprecated: Do not use.
func (m *EventStreamStats) GetPublisherCount() uint32 {
	if m != nil {
		return m.PublisherCount
	}
	return 0
}

// Deprecated: Do not use.
func (m *EventStreamStats) GetSubscriberCount() uint32 {
	if m != nil {
		return m.SubscriberCount
	}
	return 0
}

func (m *EventStreamStats) GetPublishers() []*PublisherServiceInfo {
	if m != nil {
		return m.Publishers
	}
	return nil
}

type PublisherServiceInfo struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ServiceCatalogUrl    string   `protobuf:"bytes,2,opt,name=service_catalog_url,json=serviceCatalogUrl,proto3" json:"service_catalog_url,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *PublisherServiceInfo) Reset()         { *m = PublisherServiceInfo{} }
func (m *PublisherServiceInfo) String() string { return proto.CompactTextString(m) }
func (*PublisherServiceInfo) ProtoMessage()    {}
func (*PublisherServiceInfo) Descriptor() ([]byte, []int) {
	return fileDescriptor_event_streams_b2fb4ccd6fdde033, []int{9}
}
func (m *PublisherServiceInfo) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_PublisherServiceInfo.Unmarshal(m, b)
}
func (m *PublisherServiceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_PublisherServiceInfo.Marshal(b, m, deterministic)
}
func (dst *PublisherServiceInfo) XXX_Merge(src proto.Message) {
	xxx_messageInfo_PublisherServiceInfo.Merge(dst, src)
}
func (m *PublisherServiceInfo) XXX_Size() int {
	return xxx_messageInfo_PublisherServiceInfo.Size(m)
}
func (m *PublisherServiceInfo) XXX_DiscardUnknown() {
	xxx_messageInfo_PublisherServiceInfo.DiscardUnknown(m)
}

var xxx_messageInfo_PublisherServiceInfo proto.InternalMessageInfo

func (m *PublisherServiceInfo) GetName() string {
	if m != nil {
		return m.Name
	}
	return ""
}

func (m *PublisherServiceInfo) GetServiceCatalogUrl() string {
	if m != nil {
		return m.ServiceCatalogUrl
	}
	return ""
}

type AuthorizedField struct {
	MessageName          string   `protobuf:"bytes,1,opt,name=message_name,json=messageName,proto3" json:"message_name,omitempty"`
	FieldName            string   `protobuf:"bytes,2,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *AuthorizedField) Reset()         { *m = AuthorizedField{} }
func (m *AuthorizedField) String() string { return proto.CompactTextString(m) }
func (*AuthorizedField) ProtoMessage()    {}
func (*AuthorizedField) Descriptor() ([]byte, []int) {
	return fileDescriptor_event_streams_b2fb4ccd6fdde033, []int{10}
}
func (m *AuthorizedField) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_AuthorizedField.Unmarshal(m, b)
}
func (m *AuthorizedField) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_AuthorizedField.Marshal(b, m, deterministic)
}
func (dst *AuthorizedField) XXX_Merge(src proto.Message) {
	xxx_messageInfo_AuthorizedField.Merge(dst, src)
}
func (m *AuthorizedField) XXX_Size() int {
	return xxx_messageInfo_AuthorizedField.Size(m)
}
func (m *AuthorizedField) XXX_DiscardUnknown() {
	xxx_messageInfo_AuthorizedField.DiscardUnknown(m)
}

var xxx_messageInfo_AuthorizedField proto.InternalMessageInfo

func (m *AuthorizedField) GetMessageName() string {
	if m != nil {
		return m.MessageName
	}
	return ""
}

func (m *AuthorizedField) GetFieldName() string {
	if m != nil {
		return m.FieldName
	}
	return ""
}

func init() {
	proto.RegisterType((*EventType)(nil), "code.justin.tv.eventbus.controlplane.EventType")
	proto.RegisterType((*ListEventTypesReq)(nil), "code.justin.tv.eventbus.controlplane.ListEventTypesReq")
	proto.RegisterType((*ListEventTypesResp)(nil), "code.justin.tv.eventbus.controlplane.ListEventTypesResp")
	proto.RegisterType((*ListEventStreamsReq)(nil), "code.justin.tv.eventbus.controlplane.ListEventStreamsReq")
	proto.RegisterType((*ListEventStreamsResp)(nil), "code.justin.tv.eventbus.controlplane.ListEventStreamsResp")
	proto.RegisterType((*GetEventStreamReq)(nil), "code.justin.tv.eventbus.controlplane.GetEventStreamReq")
	proto.RegisterType((*GetEventStreamStatsReq)(nil), "code.justin.tv.eventbus.controlplane.GetEventStreamStatsReq")
	proto.RegisterType((*EventStream)(nil), "code.justin.tv.eventbus.controlplane.EventStream")
	proto.RegisterType((*EventStreamStats)(nil), "code.justin.tv.eventbus.controlplane.EventStreamStats")
	proto.RegisterType((*PublisherServiceInfo)(nil), "code.justin.tv.eventbus.controlplane.PublisherServiceInfo")
	proto.RegisterType((*AuthorizedField)(nil), "code.justin.tv.eventbus.controlplane.AuthorizedField")
}

func init() {
	proto.RegisterFile("code.justin.tv/eventbus/controlplane/rpc/event_streams.proto", fileDescriptor_event_streams_b2fb4ccd6fdde033)
}

var fileDescriptor_event_streams_b2fb4ccd6fdde033 = []byte{
	// 974 bytes of a gzipped FileDescriptorProto
	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x56, 0xcf, 0x6f, 0x1b, 0x45,
	0x14, 0xd6, 0xe6, 0x57, 0xe3, 0x67, 0xa7, 0x49, 0x26, 0x21, 0xac, 0x2c, 0x0a, 0xc1, 0x70, 0x88,
	0x84, 0xba, 0x16, 0x46, 0xa5, 0xa4, 0x2d, 0x07, 0x9a, 0xd2, 0x08, 0xa9, 0x85, 0x60, 0x87, 0x4a,
	0xe4, 0xb2, 0x1a, 0xef, 0xbe, 0xd8, 0x83, 0x76, 0x77, 0xa6, 0x33, 0xb3, 0x21, 0x8e, 0x84, 0x84,
	0xc4, 0x81, 0x1b, 0xfc, 0x25, 0x1c, 0xf9, 0xff, 0xd0, 0xcc, 0xac, 0xd7, 0x1b, 0xdb, 0x52, 0x9c,
	0xd0, 0xdb, 0xee, 0x7b, 0xef, 0xfb, 0xf6, 0xcd, 0x9b, 0xef, 0x9b, 0x59, 0x78, 0x16, 0xf1, 0x18,
	0x83, 0x5f, 0x72, 0xa5, 0x59, 0x16, 0xe8, 0x8b, 0x36, 0x5e, 0x60, 0xa6, 0xfb, 0xb9, 0x6a, 0x47,
	0x3c, 0xd3, 0x92, 0x27, 0x22, 0xa1, 0x19, 0xb6, 0xa5, 0x88, 0x5c, 0x26, 0x54, 0x5a, 0x22, 0x4d,
	0x55, 0x20, 0x24, 0xd7, 0x9c, 0x7c, 0x7a, 0x1d, 0x1d, 0x8c, 0xd1, 0x41, 0x15, 0xdd, 0x7c, 0x3a,
	0x60, 0x7a, 0x98, 0xf7, 0x83, 0x88, 0xa7, 0xed, 0x01, 0x4f, 0x68, 0x36, 0x68, 0x5b, 0x78, 0x3f,
	0x3f, 0x6f, 0x0b, 0x3d, 0x12, 0xa8, 0xda, 0x9a, 0xa5, 0xa8, 0x34, 0x4d, 0xc5, 0xe4, 0xc9, 0x7d,
	0xa2, 0x79, 0x78, 0x33, 0xf8, 0x57, 0x49, 0x85, 0x40, 0x39, 0x79, 0x70, 0xd0, 0xd6, 0xbf, 0x1e,
	0xd4, 0xbe, 0x35, 0x1d, 0x9d, 0x8e, 0x04, 0x92, 0xfb, 0xb0, 0xc4, 0x62, 0xdf, 0xdb, 0xf7, 0x0e,
	0x6a, 0xdd, 0x25, 0x16, 0x13, 0x02, 0x2b, 0x19, 0x4d, 0xd1, 0x5f, 0xb2, 0x11, 0xfb, 0x4c, 0xf6,
	0xa1, 0x1e, 0xa3, 0x8a, 0x24, 0x13, 0x9a, 0xf1, 0xcc, 0x5f, 0xb6, 0xa9, 0x6a, 0x88, 0x7c, 0x02,
	0x1b, 0x12, 0x05, 0x0f, 0xcf, 0x59, 0x82, 0x82, 0xea, 0xa1, 0xbf, 0x62, 0x6b, 0x1a, 0x26, 0xf8,
	0xb2, 0x88, 0x91, 0x0f, 0x01, 0x62, 0x14, 0x12, 0x23, 0xaa, 0x31, 0xf6, 0x57, 0xf7, 0xbd, 0x83,
	0xf5, 0x6e, 0x25, 0x42, 0x1e, 0x00, 0x24, 0x31, 0x15, 0xe1, 0x40, 0xf2, 0x5c, 0xf8, 0x6b, 0x96,
	0xa1, 0x66, 0x22, 0xc7, 0x26, 0xd0, 0xea, 0xc0, 0xf6, 0x2b, 0xa6, 0x74, 0xd9, 0xba, 0xea, 0xe2,
	0xdb, 0x29, 0x8c, 0x37, 0x8d, 0x39, 0x07, 0x32, 0x8d, 0x51, 0x82, 0x9c, 0x40, 0xdd, 0x6d, 0x9b,
	0x1d, 0x94, 0xef, 0xed, 0x2f, 0x1f, 0xd4, 0x3b, 0xed, 0x60, 0x91, 0x5d, 0x0b, 0x4a, 0xaa, 0x2e,
	0x60, 0xc9, 0xda, 0x7a, 0x08, 0x3b, 0xe5, 0x77, 0x7a, 0x4e, 0x0b, 0xa6, 0xbb, 0x3d, 0x58, 0x8b,
	0x72, 0xa9, 0xb8, 0x2c, 0x3a, 0x2b, 0xde, 0x5a, 0x7f, 0x7b, 0xb0, 0x3b, 0x5b, 0xaf, 0x04, 0x79,
	0x03, 0x1b, 0xd7, 0x04, 0x55, 0xf4, 0xf6, 0xf9, 0x2d, 0x7a, 0x73, 0x74, 0xdd, 0x06, 0x56, 0xb8,
	0xc9, 0x47, 0x50, 0xcf, 0xf0, 0x52, 0x87, 0x45, 0x37, 0x6e, 0x73, 0xc1, 0x84, 0x8e, 0x5c, 0x47,
	0xa7, 0xb0, 0x7d, 0x8c, 0xd5, 0x7e, 0x8a, 0xe1, 0x4e, 0xe6, 0x34, 0x1e, 0x6e, 0xb9, 0x6a, 0x23,
	0x0b, 0xcc, 0x2e, 0x98, 0xe4, 0x59, 0x8a, 0x99, 0x2e, 0x48, 0xab, 0xa1, 0xd6, 0xcf, 0xb0, 0x77,
	0x9d, 0xb5, 0xa7, 0xa9, 0x56, 0xef, 0x84, 0xfa, 0x9f, 0x15, 0xa8, 0x57, 0x88, 0xff, 0x37, 0x21,
	0xf9, 0x18, 0x1a, 0x31, 0x53, 0x22, 0xa1, 0xa3, 0xd0, 0x1a, 0x60, 0xac, 0x72, 0x17, 0xfb, 0xde,
	0xf8, 0xe0, 0x33, 0xd8, 0x56, 0x43, 0x2e, 0x75, 0x58, 0x75, 0x83, 0x53, 0xfa, 0x96, 0x4d, 0xbc,
	0xa8, 0x58, 0xe2, 0x6b, 0x68, 0xd0, 0x48, 0xb3, 0x0b, 0x0c, 0x15, 0xcb, 0x22, 0xb4, 0x7a, 0xaf,
	0x77, 0x9a, 0xc1, 0x80, 0xf3, 0x41, 0x82, 0xc1, 0xd8, 0xad, 0xc1, 0xe9, 0xd8, 0xd9, 0xdd, 0xba,
	0xab, 0xef, 0x99, 0xf2, 0x69, 0xcf, 0xad, 0xcd, 0x7a, 0xee, 0x15, 0xac, 0x2a, 0x33, 0x4e, 0xff,
	0x9e, 0x65, 0xfe, 0xf2, 0xd6, 0x1a, 0x71, 0x9b, 0xe1, 0x48, 0x8c, 0x54, 0x55, 0x34, 0xc4, 0x94,
	0xfa, 0xeb, 0x4e, 0xaa, 0xee, 0x6d, 0xd6, 0xd9, 0xb5, 0x39, 0xce, 0xee, 0xc3, 0x36, 0xcd, 0xf5,
	0x90, 0x4b, 0x76, 0x85, 0x71, 0x78, 0xce, 0x30, 0x89, 0x95, 0x0f, 0x56, 0xba, 0x8f, 0x16, 0x6b,
	0xeb, 0x9b, 0x12, 0xfe, 0xd2, 0xa0, 0xbb, 0x5b, 0xf4, 0x7a, 0x40, 0x4d, 0x9d, 0x1e, 0xf5, 0x1b,
	0x4e, 0x8f, 0xc6, 0xf4, 0x49, 0xf0, 0xd7, 0x2a, 0x6c, 0x4d, 0xaf, 0x9d, 0x3c, 0x85, 0x75, 0x2d,
	0x54, 0x98, 0x22, 0xcd, 0xac, 0x64, 0xea, 0x9d, 0x0f, 0x66, 0xf6, 0xe7, 0x05, 0xcf, 0xfb, 0x09,
	0xbe, 0xa1, 0x49, 0x8e, 0xcf, 0x97, 0x7c, 0xaf, 0x7b, 0x4f, 0x0b, 0xf5, 0x1a, 0x69, 0x36, 0x06,
	0x1f, 0x3e, 0xd2, 0x43, 0xab, 0xa7, 0x45, 0xc1, 0x06, 0x40, 0x7e, 0x84, 0x3d, 0xf3, 0xd5, 0xd0,
	0x4e, 0x43, 0x85, 0x02, 0x65, 0x98, 0xb2, 0x2c, 0xd7, 0x4e, 0x77, 0x37, 0x50, 0x75, 0x77, 0x0c,
	0xd6, 0xae, 0x46, 0x9d, 0xa0, 0x7c, 0x6d, 0x81, 0xe4, 0x07, 0x78, 0x2f, 0xa5, 0x97, 0x73, 0x18,
	0x57, 0x16, 0x60, 0x24, 0x29, 0xbd, 0x9c, 0x47, 0xc8, 0xe6, 0xb5, 0xb8, 0xba, 0x10, 0x21, 0x9b,
	0xe9, 0xb0, 0x07, 0xef, 0x4f, 0x16, 0x1d, 0x0a, 0x3a, 0x4a, 0x38, 0x8d, 0x43, 0xc5, 0xae, 0xd0,
	0xea, 0xfb, 0x26, 0xca, 0xdd, 0x72, 0xd5, 0x27, 0x0e, 0xda, 0x63, 0x57, 0xc6, 0x94, 0x9b, 0x22,
	0xef, 0x27, 0x4c, 0x0d, 0x51, 0x86, 0x11, 0xcf, 0x33, 0x6d, 0x0d, 0xb1, 0x61, 0xe7, 0x7d, 0xbf,
	0x4c, 0x1d, 0x99, 0x0c, 0x79, 0x08, 0x5b, 0x2a, 0xef, 0x1b, 0x0f, 0xf5, 0xcb, 0xea, 0xf5, 0xb2,
	0x7a, 0x73, 0x92, 0x73, 0xe5, 0x67, 0x00, 0x25, 0x81, 0xf2, 0x6b, 0x56, 0xd0, 0x4f, 0x16, 0x13,
	0xf4, 0xc9, 0x18, 0xd7, 0x43, 0x79, 0xc1, 0x22, 0xfc, 0x2e, 0x3b, 0xe7, 0xdd, 0x0a, 0x5b, 0xeb,
	0x0c, 0x76, 0xe7, 0xd5, 0x94, 0x17, 0xb0, 0x57, 0xb9, 0x80, 0x03, 0xd8, 0x51, 0xae, 0x24, 0x8c,
	0xa8, 0xa6, 0x09, 0x1f, 0x84, 0xb9, 0x4c, 0x8a, 0x53, 0x6c, 0xbb, 0x48, 0x1d, 0xb9, 0xcc, 0x4f,
	0x32, 0x69, 0xf5, 0x60, 0x73, 0xca, 0x50, 0xe6, 0x78, 0x4b, 0x51, 0x29, 0x3a, 0xc0, 0xb0, 0x42,
	0x5f, 0x2f, 0x62, 0xf6, 0x78, 0x7b, 0x00, 0x60, 0xad, 0x1b, 0x56, 0x7e, 0x00, 0x6a, 0x36, 0x62,
	0xd2, 0x9d, 0x3f, 0x96, 0xa1, 0x51, 0xbd, 0xb0, 0xc8, 0x6f, 0xb0, 0x62, 0x2e, 0x31, 0x72, 0xb8,
	0xd8, 0x44, 0xe6, 0x5c, 0x90, 0xcd, 0x27, 0x77, 0x85, 0x2a, 0x41, 0xde, 0xc2, 0xf2, 0x31, 0x6a,
	0xf2, 0x78, 0x31, 0x8a, 0x99, 0xdb, 0xad, 0x79, 0xfb, 0x4b, 0x95, 0xfc, 0xee, 0xc1, 0xfa, 0x31,
	0x6a, 0x77, 0x78, 0x3c, 0xbb, 0xcb, 0x87, 0xc7, 0x17, 0x60, 0xf3, 0x8e, 0xc7, 0x75, 0xe7, 0x4f,
	0x0f, 0x60, 0xf2, 0x3b, 0x43, 0x46, 0xc5, 0x1e, 0x3c, 0xbe, 0xe5, 0x20, 0xc7, 0x3f, 0x50, 0xcd,
	0xaf, 0xee, 0x06, 0x54, 0xe2, 0xf9, 0xea, 0xd9, 0xb2, 0x14, 0x51, 0x7f, 0xcd, 0x7a, 0xf5, 0x8b,
	0xff, 0x02, 0x00, 0x00, 0xff, 0xff, 0x3f, 0x5f, 0x1b, 0xa0, 0x33, 0x0b, 0x00, 0x00,
}
