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

package dgn

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

type RedundancyProperties_SlateBrand int32

const (
	RedundancyProperties_WHITE_LABEL RedundancyProperties_SlateBrand = 0
	RedundancyProperties_PURPLE      RedundancyProperties_SlateBrand = 1
)

var RedundancyProperties_SlateBrand_name = map[int32]string{
	0: "WHITE_LABEL",
	1: "PURPLE",
}

var RedundancyProperties_SlateBrand_value = map[string]int32{
	"WHITE_LABEL": 0,
	"PURPLE":      1,
}

func (x RedundancyProperties_SlateBrand) String() string {
	return proto.EnumName(RedundancyProperties_SlateBrand_name, int32(x))
}

func (RedundancyProperties_SlateBrand) EnumDescriptor() ([]byte, []int) {
	return fileDescriptor_055f8166dc61495a, []int{1, 0}
}

// A channel contains all streams associated with that channel.
// i.e. channel = "lirik", streams = {live, backup, delay}
type Channel struct {
	Streams              []*Stream `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

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

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

var xxx_messageInfo_Channel proto.InternalMessageInfo

func (m *Channel) GetStreams() []*Stream {
	if m != nil {
		return m.Streams
	}
	return nil
}

// Information surrounding which redundancy features are allowed
type RedundancyProperties struct {
	// Try to connect to backup streams on disconnect
	AllowFailoverToBackup bool `protobuf:"varint,1,opt,name=allow_failover_to_backup,json=allowFailoverToBackup,proto3" json:"allow_failover_to_backup,omitempty"`
	// Show a slate on disconnect
	DisconnectSlateDuration *duration.Duration              `protobuf:"bytes,2,opt,name=disconnect_slate_duration,json=disconnectSlateDuration,proto3" json:"disconnect_slate_duration,omitempty"`
	SlateBrand              RedundancyProperties_SlateBrand `protobuf:"varint,3,opt,name=slate_brand,json=slateBrand,proto3,enum=dgn.RedundancyProperties_SlateBrand" json:"slate_brand,omitempty"`
	XXX_NoUnkeyedLiteral    struct{}                        `json:"-"`
	XXX_unrecognized        []byte                          `json:"-"`
	XXX_sizecache           int32                           `json:"-"`
}

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

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

var xxx_messageInfo_RedundancyProperties proto.InternalMessageInfo

func (m *RedundancyProperties) GetAllowFailoverToBackup() bool {
	if m != nil {
		return m.AllowFailoverToBackup
	}
	return false
}

func (m *RedundancyProperties) GetDisconnectSlateDuration() *duration.Duration {
	if m != nil {
		return m.DisconnectSlateDuration
	}
	return nil
}

func (m *RedundancyProperties) GetSlateBrand() RedundancyProperties_SlateBrand {
	if m != nil {
		return m.SlateBrand
	}
	return RedundancyProperties_WHITE_LABEL
}

type TranscodeStack struct {
	TranscodeType        string   `protobuf:"bytes,1,opt,name=transcode_type,json=transcodeType,proto3" json:"transcode_type,omitempty"`
	EncoderType          string   `protobuf:"bytes,2,opt,name=encoder_type,json=encoderType,proto3" json:"encoder_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *TranscodeStack) Reset()         { *m = TranscodeStack{} }
func (m *TranscodeStack) String() string { return proto.CompactTextString(m) }
func (*TranscodeStack) ProtoMessage()    {}
func (*TranscodeStack) Descriptor() ([]byte, []int) {
	return fileDescriptor_055f8166dc61495a, []int{2}
}

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

var xxx_messageInfo_TranscodeStack proto.InternalMessageInfo

func (m *TranscodeStack) GetTranscodeType() string {
	if m != nil {
		return m.TranscodeType
	}
	return ""
}

func (m *TranscodeStack) GetEncoderType() string {
	if m != nil {
		return m.EncoderType
	}
	return ""
}

// A stream represents a single RTMP ingest
type Stream struct {
	//"lirik"
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	//live, backup, delay, spanish? camera angles? mostly just live for now.
	Format string `protobuf:"bytes,2,opt,name=format,proto3" json:"format,omitempty"`
	//connect here with RTMP to pull the channel
	RTMPEndpoint string `protobuf:"bytes,3,opt,name=RTMP_endpoint,json=RTMPEndpoint,proto3" json:"RTMP_endpoint,omitempty"`
	//make twirp requests to [NGST](https://git-aws.internal.justin.tv/video/goingest/tree/master/pkg/ngst/ngst.md) here to do things like make sure the stream still exists
	TwirpEndpoint string `protobuf:"bytes,11,opt,name=twirp_endpoint,json=twirpEndpoint,proto3" json:"twirp_endpoint,omitempty"`
	//unique sessionID tied to the broadcast. not really used for anything now.
	SessionID string `protobuf:"bytes,6,opt,name=sessionID,proto3" json:"sessionID,omitempty"`
	// url-style params that came in with the stream key
	Params map[string]string `protobuf:"bytes,7,rep,name=params,proto3" json:"params,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	// whether the daemon has successfully retreived this stream recently
	Healthy bool `protobuf:"varint,8,opt,name=healthy,proto3" json:"healthy,omitempty"`
	// unix epoch of when the stream was last successfully retreived
	LastSeen int64 `protobuf:"varint,9,opt,name=last_seen,json=lastSeen,proto3" json:"last_seen,omitempty"`
	//mimicking the old usher behavior of delay_length
	DelayLength uint32 `protobuf:"varint,10,opt,name=delay_length,json=delayLength,proto3" json:"delay_length,omitempty"`
	//RTMP Metadata associated with a stream
	RtmpMetadata map[string]string `protobuf:"bytes,12,rep,name=rtmp_metadata,json=rtmpMetadata,proto3" json:"rtmp_metadata,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	ChannelId    string            `protobuf:"bytes,14,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
	//Client IP assosciated with the specific stream
	ClientIp string `protobuf:"bytes,15,opt,name=client_ip,json=clientIp,proto3" json:"client_ip,omitempty"`
	// S3 bucket to be used for this broadcast
	S3Bucket string `protobuf:"bytes,16,opt,name=s3_bucket,json=s3Bucket,proto3" json:"s3_bucket,omitempty"`
	// The SNS ARN to be used to send notifcations for this bucket
	SnsEndpoint string `protobuf:"bytes,17,opt,name=sns_endpoint,json=snsEndpoint,proto3" json:"sns_endpoint,omitempty"`
	// The S3 prefix to be used for this broadcast
	S3Prefix string `protobuf:"bytes,18,opt,name=s3_prefix,json=s3Prefix,proto3" json:"s3_prefix,omitempty"`
	//This represents the time at which the stream started
	StartTime int64 `protobuf:"varint,19,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// The full rtmp Url which can be used for playback and gotranscoder to connect to
	RtmpUrl string `protobuf:"bytes,20,opt,name=rtmp_url,json=rtmpUrl,proto3" json:"rtmp_url,omitempty"`
	// The CDN url which is to be used to record static vod manifests , used for LVS streams
	CdnUrl string `protobuf:"bytes,21,opt,name=cdn_url,json=cdnUrl,proto3" json:"cdn_url,omitempty"`
	// flag which specifies if we are using low latency mode here
	LowLatency bool `protobuf:"varint,22,opt,name=low_latency,json=lowLatency,proto3" json:"low_latency,omitempty"`
	// number of consecutive failed health checks
	FailedHealthChecks int64 `protobuf:"varint,23,opt,name=failed_health_checks,json=failedHealthChecks,proto3" json:"failed_health_checks,omitempty"`
	// Capabilities surrounding which redundancy features are allowed
	RedundancyProperties *RedundancyProperties `protobuf:"bytes,24,opt,name=redundancy_properties,json=redundancyProperties,proto3" json:"redundancy_properties,omitempty"`
	//Latency mode for the broadcast, this seeting in Digestion is mainly used for LVS
	//latency mode for twitch streams are stored in channel properties
	LatencyMode            string            `protobuf:"bytes,25,opt,name=latency_mode,json=latencyMode,proto3" json:"latency_mode,omitempty"`
	RedundancySourceStream *StreamRequest    `protobuf:"bytes,26,opt,name=redundancy_source_stream,json=redundancySourceStream,proto3" json:"redundancy_source_stream,omitempty"`
	TranscodeStacks        []*TranscodeStack `protobuf:"bytes,27,rep,name=transcode_stacks,json=transcodeStacks,proto3" json:"transcode_stacks,omitempty"`
	CustomerId             string            `protobuf:"bytes,28,opt,name=customer_id,json=customerId,proto3" json:"customer_id,omitempty"`
	ContentId              string            `protobuf:"bytes,29,opt,name=content_id,json=contentId,proto3" json:"content_id,omitempty"`
	XXX_NoUnkeyedLiteral   struct{}          `json:"-"`
	XXX_unrecognized       []byte            `json:"-"`
	XXX_sizecache          int32             `json:"-"`
}

func (m *Stream) Reset()         { *m = Stream{} }
func (m *Stream) String() string { return proto.CompactTextString(m) }
func (*Stream) ProtoMessage()    {}
func (*Stream) Descriptor() ([]byte, []int) {
	return fileDescriptor_055f8166dc61495a, []int{3}
}

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

var xxx_messageInfo_Stream proto.InternalMessageInfo

func (m *Stream) GetChannel() string {
	if m != nil {
		return m.Channel
	}
	return ""
}

func (m *Stream) GetFormat() string {
	if m != nil {
		return m.Format
	}
	return ""
}

func (m *Stream) GetRTMPEndpoint() string {
	if m != nil {
		return m.RTMPEndpoint
	}
	return ""
}

func (m *Stream) GetTwirpEndpoint() string {
	if m != nil {
		return m.TwirpEndpoint
	}
	return ""
}

func (m *Stream) GetSessionID() string {
	if m != nil {
		return m.SessionID
	}
	return ""
}

func (m *Stream) GetParams() map[string]string {
	if m != nil {
		return m.Params
	}
	return nil
}

func (m *Stream) GetHealthy() bool {
	if m != nil {
		return m.Healthy
	}
	return false
}

func (m *Stream) GetLastSeen() int64 {
	if m != nil {
		return m.LastSeen
	}
	return 0
}

func (m *Stream) GetDelayLength() uint32 {
	if m != nil {
		return m.DelayLength
	}
	return 0
}

func (m *Stream) GetRtmpMetadata() map[string]string {
	if m != nil {
		return m.RtmpMetadata
	}
	return nil
}

func (m *Stream) GetChannelId() string {
	if m != nil {
		return m.ChannelId
	}
	return ""
}

func (m *Stream) GetClientIp() string {
	if m != nil {
		return m.ClientIp
	}
	return ""
}

func (m *Stream) GetS3Bucket() string {
	if m != nil {
		return m.S3Bucket
	}
	return ""
}

func (m *Stream) GetSnsEndpoint() string {
	if m != nil {
		return m.SnsEndpoint
	}
	return ""
}

func (m *Stream) GetS3Prefix() string {
	if m != nil {
		return m.S3Prefix
	}
	return ""
}

func (m *Stream) GetStartTime() int64 {
	if m != nil {
		return m.StartTime
	}
	return 0
}

func (m *Stream) GetRtmpUrl() string {
	if m != nil {
		return m.RtmpUrl
	}
	return ""
}

func (m *Stream) GetCdnUrl() string {
	if m != nil {
		return m.CdnUrl
	}
	return ""
}

func (m *Stream) GetLowLatency() bool {
	if m != nil {
		return m.LowLatency
	}
	return false
}

func (m *Stream) GetFailedHealthChecks() int64 {
	if m != nil {
		return m.FailedHealthChecks
	}
	return 0
}

func (m *Stream) GetRedundancyProperties() *RedundancyProperties {
	if m != nil {
		return m.RedundancyProperties
	}
	return nil
}

func (m *Stream) GetLatencyMode() string {
	if m != nil {
		return m.LatencyMode
	}
	return ""
}

func (m *Stream) GetRedundancySourceStream() *StreamRequest {
	if m != nil {
		return m.RedundancySourceStream
	}
	return nil
}

func (m *Stream) GetTranscodeStacks() []*TranscodeStack {
	if m != nil {
		return m.TranscodeStacks
	}
	return nil
}

func (m *Stream) GetCustomerId() string {
	if m != nil {
		return m.CustomerId
	}
	return ""
}

func (m *Stream) GetContentId() string {
	if m != nil {
		return m.ContentId
	}
	return ""
}

type StreamAuthRequest struct {
	// widely referred to elsewhere as just 'stream key', i call this fullStreamKey to distinguish it from
	// just the SHA1 as web considers a streamkey
	// looks like `live_123355_aksldjfhlksdjfh` or however an authorized key looks
	// basically whatever you could put into obs as a stream key will work here
	// params will be broken into the `params`
	FullStreamKey string `protobuf:"bytes,1,opt,name=fullStreamKey,proto3" json:"fullStreamKey,omitempty"`
	// the internal NGST/usher name for the stream, like `live_user_lirik`
	RTMPName string `protobuf:"bytes,2,opt,name=RTMP_name,json=RTMPName,proto3" json:"RTMP_name,omitempty"`
	// when authing, NGST must fill out these endpoints so that clients can pull/query the live streams
	RTMPEndpoint string `protobuf:"bytes,3,opt,name=RTMP_endpoint,json=RTMPEndpoint,proto3" json:"RTMP_endpoint,omitempty"`
	// when authing, NGST must fill out these endpoints so that clients can pull/query the live streams
	JSONEndpoint string `protobuf:"bytes,4,opt,name=JSON_endpoint,json=JSONEndpoint,proto3" json:"JSON_endpoint,omitempty"`
	// when authing, NGST must fill out these endpoints so that clients can pull/query the live streams
	GRPCEndpoint string `protobuf:"bytes,5,opt,name=GRPC_endpoint,json=GRPCEndpoint,proto3" json:"GRPC_endpoint,omitempty"`
	// when authing, NGST must fill out these endpoints so that clients can pull/query the live streams
	TwirpEndpoint        string   `protobuf:"bytes,6,opt,name=twirp_endpoint,json=twirpEndpoint,proto3" json:"twirp_endpoint,omitempty"`
	Uuid                 string   `protobuf:"bytes,7,opt,name=uuid,proto3" json:"uuid,omitempty"`
	ClientIp             string   `protobuf:"bytes,8,opt,name=client_ip,json=clientIp,proto3" json:"client_ip,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *StreamAuthRequest) Reset()         { *m = StreamAuthRequest{} }
func (m *StreamAuthRequest) String() string { return proto.CompactTextString(m) }
func (*StreamAuthRequest) ProtoMessage()    {}
func (*StreamAuthRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_055f8166dc61495a, []int{4}
}

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

var xxx_messageInfo_StreamAuthRequest proto.InternalMessageInfo

func (m *StreamAuthRequest) GetFullStreamKey() string {
	if m != nil {
		return m.FullStreamKey
	}
	return ""
}

func (m *StreamAuthRequest) GetRTMPName() string {
	if m != nil {
		return m.RTMPName
	}
	return ""
}

func (m *StreamAuthRequest) GetRTMPEndpoint() string {
	if m != nil {
		return m.RTMPEndpoint
	}
	return ""
}

func (m *StreamAuthRequest) GetJSONEndpoint() string {
	if m != nil {
		return m.JSONEndpoint
	}
	return ""
}

func (m *StreamAuthRequest) GetGRPCEndpoint() string {
	if m != nil {
		return m.GRPCEndpoint
	}
	return ""
}

func (m *StreamAuthRequest) GetTwirpEndpoint() string {
	if m != nil {
		return m.TwirpEndpoint
	}
	return ""
}

func (m *StreamAuthRequest) GetUuid() string {
	if m != nil {
		return m.Uuid
	}
	return ""
}

func (m *StreamAuthRequest) GetClientIp() string {
	if m != nil {
		return m.ClientIp
	}
	return ""
}

// uniquely identifies a channel
type ChannelRequest struct {
	Channel              string   `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *ChannelRequest) Reset()         { *m = ChannelRequest{} }
func (m *ChannelRequest) String() string { return proto.CompactTextString(m) }
func (*ChannelRequest) ProtoMessage()    {}
func (*ChannelRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_055f8166dc61495a, []int{5}
}

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

var xxx_messageInfo_ChannelRequest proto.InternalMessageInfo

func (m *ChannelRequest) GetChannel() string {
	if m != nil {
		return m.Channel
	}
	return ""
}

// uniquely identifies a stream
type StreamRequest struct {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	Format  string `protobuf:"bytes,2,opt,name=format,proto3" json:"format,omitempty"`
	// optional session_id, to ensure the correct session is specified (useful on delete)
	SessionID            string   `protobuf:"bytes,3,opt,name=sessionID,proto3" json:"sessionID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *StreamRequest) Reset()         { *m = StreamRequest{} }
func (m *StreamRequest) String() string { return proto.CompactTextString(m) }
func (*StreamRequest) ProtoMessage()    {}
func (*StreamRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_055f8166dc61495a, []int{6}
}

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

var xxx_messageInfo_StreamRequest proto.InternalMessageInfo

func (m *StreamRequest) GetChannel() string {
	if m != nil {
		return m.Channel
	}
	return ""
}

func (m *StreamRequest) GetFormat() string {
	if m != nil {
		return m.Format
	}
	return ""
}

func (m *StreamRequest) GetSessionID() string {
	if m != nil {
		return m.SessionID
	}
	return ""
}

type HealthRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *HealthRequest) Reset()         { *m = HealthRequest{} }
func (m *HealthRequest) String() string { return proto.CompactTextString(m) }
func (*HealthRequest) ProtoMessage()    {}
func (*HealthRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_055f8166dc61495a, []int{7}
}

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

var xxx_messageInfo_HealthRequest proto.InternalMessageInfo

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

func (m *Health) Reset()         { *m = Health{} }
func (m *Health) String() string { return proto.CompactTextString(m) }
func (*Health) ProtoMessage()    {}
func (*Health) Descriptor() ([]byte, []int) {
	return fileDescriptor_055f8166dc61495a, []int{8}
}

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

var xxx_messageInfo_Health proto.InternalMessageInfo

func (m *Health) GetInfo() string {
	if m != nil {
		return m.Info
	}
	return ""
}

// used for scanning digestion db, you must indicate what shard you are part of.
// if you just want to scan the entire db, set segment to 0 and total_segments to 1
type AllStreamsRequest struct {
	// which scan shard member you are
	Segment int64 `protobuf:"varint,1,opt,name=segment,proto3" json:"segment,omitempty"`
	// how many scan shard members tehre are in total
	TotalSegments        int64    `protobuf:"varint,2,opt,name=total_segments,json=totalSegments,proto3" json:"total_segments,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *AllStreamsRequest) Reset()         { *m = AllStreamsRequest{} }
func (m *AllStreamsRequest) String() string { return proto.CompactTextString(m) }
func (*AllStreamsRequest) ProtoMessage()    {}
func (*AllStreamsRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_055f8166dc61495a, []int{9}
}

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

var xxx_messageInfo_AllStreamsRequest proto.InternalMessageInfo

func (m *AllStreamsRequest) GetSegment() int64 {
	if m != nil {
		return m.Segment
	}
	return 0
}

func (m *AllStreamsRequest) GetTotalSegments() int64 {
	if m != nil {
		return m.TotalSegments
	}
	return 0
}

type StreamList struct {
	Streams              []*Stream `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (m *StreamList) Reset()         { *m = StreamList{} }
func (m *StreamList) String() string { return proto.CompactTextString(m) }
func (*StreamList) ProtoMessage()    {}
func (*StreamList) Descriptor() ([]byte, []int) {
	return fileDescriptor_055f8166dc61495a, []int{10}
}

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

var xxx_messageInfo_StreamList proto.InternalMessageInfo

func (m *StreamList) GetStreams() []*Stream {
	if m != nil {
		return m.Streams
	}
	return nil
}

type SetStreamHealthRequest struct {
	// uniquely identify a stream
	StreamRequest *StreamRequest `protobuf:"bytes,1,opt,name=stream_request,json=streamRequest,proto3" json:"stream_request,omitempty"`
	// if healthy, set healthy to true and set last_seen to now
	// otherwise, set healthy to false and dont touch last_seen
	Healthy bool `protobuf:"varint,2,opt,name=healthy,proto3" json:"healthy,omitempty"`
	// number of consecutive failed health checks
	FailedHealthChecks   int64    `protobuf:"varint,3,opt,name=failed_health_checks,json=failedHealthChecks,proto3" json:"failed_health_checks,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *SetStreamHealthRequest) Reset()         { *m = SetStreamHealthRequest{} }
func (m *SetStreamHealthRequest) String() string { return proto.CompactTextString(m) }
func (*SetStreamHealthRequest) ProtoMessage()    {}
func (*SetStreamHealthRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_055f8166dc61495a, []int{11}
}

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

var xxx_messageInfo_SetStreamHealthRequest proto.InternalMessageInfo

func (m *SetStreamHealthRequest) GetStreamRequest() *StreamRequest {
	if m != nil {
		return m.StreamRequest
	}
	return nil
}

func (m *SetStreamHealthRequest) GetHealthy() bool {
	if m != nil {
		return m.Healthy
	}
	return false
}

func (m *SetStreamHealthRequest) GetFailedHealthChecks() int64 {
	if m != nil {
		return m.FailedHealthChecks
	}
	return 0
}

type SetStreamHealthResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *SetStreamHealthResponse) Reset()         { *m = SetStreamHealthResponse{} }
func (m *SetStreamHealthResponse) String() string { return proto.CompactTextString(m) }
func (*SetStreamHealthResponse) ProtoMessage()    {}
func (*SetStreamHealthResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_055f8166dc61495a, []int{12}
}

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

var xxx_messageInfo_SetStreamHealthResponse proto.InternalMessageInfo

type UpdateMetadataRequest struct {
	// uniquely identify a stream
	StreamRequest *StreamRequest `protobuf:"bytes,1,opt,name=stream_request,json=streamRequest,proto3" json:"stream_request,omitempty"`
	// RTMP Metadata associated with a stream
	RtmpMetadata         map[string]string `protobuf:"bytes,2,rep,name=rtmp_metadata,json=rtmpMetadata,proto3" json:"rtmp_metadata,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (m *UpdateMetadataRequest) Reset()         { *m = UpdateMetadataRequest{} }
func (m *UpdateMetadataRequest) String() string { return proto.CompactTextString(m) }
func (*UpdateMetadataRequest) ProtoMessage()    {}
func (*UpdateMetadataRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_055f8166dc61495a, []int{13}
}

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

var xxx_messageInfo_UpdateMetadataRequest proto.InternalMessageInfo

func (m *UpdateMetadataRequest) GetStreamRequest() *StreamRequest {
	if m != nil {
		return m.StreamRequest
	}
	return nil
}

func (m *UpdateMetadataRequest) GetRtmpMetadata() map[string]string {
	if m != nil {
		return m.RtmpMetadata
	}
	return nil
}

type UpdateMetadataResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *UpdateMetadataResponse) Reset()         { *m = UpdateMetadataResponse{} }
func (m *UpdateMetadataResponse) String() string { return proto.CompactTextString(m) }
func (*UpdateMetadataResponse) ProtoMessage()    {}
func (*UpdateMetadataResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_055f8166dc61495a, []int{14}
}

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

var xxx_messageInfo_UpdateMetadataResponse proto.InternalMessageInfo

type UpdateRedundancySourceRequest struct {
	Stitcher             *StreamRequest `protobuf:"bytes,1,opt,name=stitcher,proto3" json:"stitcher,omitempty"`
	Source               *StreamRequest `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (m *UpdateRedundancySourceRequest) Reset()         { *m = UpdateRedundancySourceRequest{} }
func (m *UpdateRedundancySourceRequest) String() string { return proto.CompactTextString(m) }
func (*UpdateRedundancySourceRequest) ProtoMessage()    {}
func (*UpdateRedundancySourceRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_055f8166dc61495a, []int{15}
}

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

var xxx_messageInfo_UpdateRedundancySourceRequest proto.InternalMessageInfo

func (m *UpdateRedundancySourceRequest) GetStitcher() *StreamRequest {
	if m != nil {
		return m.Stitcher
	}
	return nil
}

func (m *UpdateRedundancySourceRequest) GetSource() *StreamRequest {
	if m != nil {
		return m.Source
	}
	return nil
}

type UpdateRedundancySourceResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *UpdateRedundancySourceResponse) Reset()         { *m = UpdateRedundancySourceResponse{} }
func (m *UpdateRedundancySourceResponse) String() string { return proto.CompactTextString(m) }
func (*UpdateRedundancySourceResponse) ProtoMessage()    {}
func (*UpdateRedundancySourceResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_055f8166dc61495a, []int{16}
}

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

var xxx_messageInfo_UpdateRedundancySourceResponse proto.InternalMessageInfo

type CheckIngestHealthResponse struct {
	// The stream as found in DigestionDB
	Stream *Stream `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	// Whether the health check succeeded
	IngestOK bool `protobuf:"varint,2,opt,name=ingestOK,proto3" json:"ingestOK,omitempty"`
	// True if the checked process is waiting for a reingest
	IsInSlate            bool     `protobuf:"varint,3,opt,name=is_in_slate,json=isInSlate,proto3" json:"is_in_slate,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *CheckIngestHealthResponse) Reset()         { *m = CheckIngestHealthResponse{} }
func (m *CheckIngestHealthResponse) String() string { return proto.CompactTextString(m) }
func (*CheckIngestHealthResponse) ProtoMessage()    {}
func (*CheckIngestHealthResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_055f8166dc61495a, []int{17}
}

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

var xxx_messageInfo_CheckIngestHealthResponse proto.InternalMessageInfo

func (m *CheckIngestHealthResponse) GetStream() *Stream {
	if m != nil {
		return m.Stream
	}
	return nil
}

func (m *CheckIngestHealthResponse) GetIngestOK() bool {
	if m != nil {
		return m.IngestOK
	}
	return false
}

func (m *CheckIngestHealthResponse) GetIsInSlate() bool {
	if m != nil {
		return m.IsInSlate
	}
	return false
}

type PutIngestMetadataRequest struct {
	// Channel name
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// Metadata to insert encoded as a base64 string
	Metadata string `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// ISO-8601 UTC time that the client requested the metadata to be inserted.
	RequestedAt string `protobuf:"bytes,3,opt,name=requested_at,json=requestedAt,proto3" json:"requested_at,omitempty"`
	// SNS topic id to notify after insertion
	SnsTopicId string `protobuf:"bytes,4,opt,name=sns_topic_id,json=snsTopicId,proto3" json:"sns_topic_id,omitempty"`
	// Rate limit allowed for the stream
	RateLimit            uint32   `protobuf:"varint,5,opt,name=rate_limit,json=rateLimit,proto3" json:"rate_limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *PutIngestMetadataRequest) Reset()         { *m = PutIngestMetadataRequest{} }
func (m *PutIngestMetadataRequest) String() string { return proto.CompactTextString(m) }
func (*PutIngestMetadataRequest) ProtoMessage()    {}
func (*PutIngestMetadataRequest) Descriptor() ([]byte, []int) {
	return fileDescriptor_055f8166dc61495a, []int{18}
}

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

var xxx_messageInfo_PutIngestMetadataRequest proto.InternalMessageInfo

func (m *PutIngestMetadataRequest) GetChannel() string {
	if m != nil {
		return m.Channel
	}
	return ""
}

func (m *PutIngestMetadataRequest) GetMetadata() string {
	if m != nil {
		return m.Metadata
	}
	return ""
}

func (m *PutIngestMetadataRequest) GetRequestedAt() string {
	if m != nil {
		return m.RequestedAt
	}
	return ""
}

func (m *PutIngestMetadataRequest) GetSnsTopicId() string {
	if m != nil {
		return m.SnsTopicId
	}
	return ""
}

func (m *PutIngestMetadataRequest) GetRateLimit() uint32 {
	if m != nil {
		return m.RateLimit
	}
	return 0
}

type PutIngestMetadataResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *PutIngestMetadataResponse) Reset()         { *m = PutIngestMetadataResponse{} }
func (m *PutIngestMetadataResponse) String() string { return proto.CompactTextString(m) }
func (*PutIngestMetadataResponse) ProtoMessage()    {}
func (*PutIngestMetadataResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor_055f8166dc61495a, []int{19}
}

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

var xxx_messageInfo_PutIngestMetadataResponse proto.InternalMessageInfo

func init() {
	proto.RegisterEnum("dgn.RedundancyProperties_SlateBrand", RedundancyProperties_SlateBrand_name, RedundancyProperties_SlateBrand_value)
	proto.RegisterType((*Channel)(nil), "dgn.Channel")
	proto.RegisterType((*RedundancyProperties)(nil), "dgn.RedundancyProperties")
	proto.RegisterType((*TranscodeStack)(nil), "dgn.TranscodeStack")
	proto.RegisterType((*Stream)(nil), "dgn.Stream")
	proto.RegisterMapType((map[string]string)(nil), "dgn.Stream.ParamsEntry")
	proto.RegisterMapType((map[string]string)(nil), "dgn.Stream.RtmpMetadataEntry")
	proto.RegisterType((*StreamAuthRequest)(nil), "dgn.StreamAuthRequest")
	proto.RegisterType((*ChannelRequest)(nil), "dgn.ChannelRequest")
	proto.RegisterType((*StreamRequest)(nil), "dgn.StreamRequest")
	proto.RegisterType((*HealthRequest)(nil), "dgn.HealthRequest")
	proto.RegisterType((*Health)(nil), "dgn.Health")
	proto.RegisterType((*AllStreamsRequest)(nil), "dgn.AllStreamsRequest")
	proto.RegisterType((*StreamList)(nil), "dgn.StreamList")
	proto.RegisterType((*SetStreamHealthRequest)(nil), "dgn.SetStreamHealthRequest")
	proto.RegisterType((*SetStreamHealthResponse)(nil), "dgn.SetStreamHealthResponse")
	proto.RegisterType((*UpdateMetadataRequest)(nil), "dgn.UpdateMetadataRequest")
	proto.RegisterMapType((map[string]string)(nil), "dgn.UpdateMetadataRequest.RtmpMetadataEntry")
	proto.RegisterType((*UpdateMetadataResponse)(nil), "dgn.UpdateMetadataResponse")
	proto.RegisterType((*UpdateRedundancySourceRequest)(nil), "dgn.UpdateRedundancySourceRequest")
	proto.RegisterType((*UpdateRedundancySourceResponse)(nil), "dgn.UpdateRedundancySourceResponse")
	proto.RegisterType((*CheckIngestHealthResponse)(nil), "dgn.CheckIngestHealthResponse")
	proto.RegisterType((*PutIngestMetadataRequest)(nil), "dgn.PutIngestMetadataRequest")
	proto.RegisterType((*PutIngestMetadataResponse)(nil), "dgn.PutIngestMetadataResponse")
}

func init() { proto.RegisterFile("dgn.proto", fileDescriptor_055f8166dc61495a) }

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