proto

package
v0.0.0-...-dd72184 Latest Latest
Warning

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

 Go to latest Published: Oct 12, 2023 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_autoradio_proto protoreflect.FileDescriptor
View Source 
var File_presence_proto protoreflect.FileDescriptor
View Source 
var File_status_proto protoreflect.FileDescriptor
View Source 
var GossipService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "autoradio.GossipService",
	HandlerType: (*GossipServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Exchange",
			Handler:    _GossipService_Exchange_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "status.proto",
}

GossipService_ServiceDesc is the grpc.ServiceDesc for GossipService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterGossipServiceServer 

func RegisterGossipServiceServer(s grpc.ServiceRegistrar, srv GossipServiceServer)

Types

type EncodingParams 

type EncodingParams struct {
	SourcePath string  `protobuf:"bytes,1,opt,name=source_path,json=sourcePath,proto3" json:"source_path,omitempty"`
	Format     string  `protobuf:"bytes,2,opt,name=format,proto3" json:"format,omitempty"`
	BitRate    int32   `protobuf:"varint,3,opt,name=bit_rate,json=bitRate,proto3" json:"bit_rate,omitempty"`
	SampleRate int32   `protobuf:"varint,4,opt,name=sample_rate,json=sampleRate,proto3" json:"sample_rate,omitempty"`
	Channels   int32   `protobuf:"varint,5,opt,name=channels,proto3" json:"channels,omitempty"`
	StereoMode string  `protobuf:"bytes,6,opt,name=stereo_mode,json=stereoMode,proto3" json:"stereo_mode,omitempty"`
	Quality    float32 `protobuf:"fixed32,7,opt,name=quality,proto3" json:"quality,omitempty"`
	// contains filtered or unexported fields
}

func (*EncodingParams) DebugString 

func (p *EncodingParams) DebugString() string

func (*EncodingParams) Descriptor deprecated 

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

Deprecated: Use EncodingParams.ProtoReflect.Descriptor instead.

func (*EncodingParams) GetBitRate 

func (x *EncodingParams) GetBitRate() int32

func (*EncodingParams) GetChannels 

func (x *EncodingParams) GetChannels() int32

func (*EncodingParams) GetFormat 

func (x *EncodingParams) GetFormat() string

func (*EncodingParams) GetQuality 

func (x *EncodingParams) GetQuality() float32

func (*EncodingParams) GetSampleRate 

func (x *EncodingParams) GetSampleRate() int32

func (*EncodingParams) GetSourcePath 

func (x *EncodingParams) GetSourcePath() string

func (*EncodingParams) GetStereoMode 

func (x *EncodingParams) GetStereoMode() string

func (*EncodingParams) ProtoMessage 

func (*EncodingParams) ProtoMessage()

func (*EncodingParams) ProtoReflect 

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

func (*EncodingParams) Reset 

func (x *EncodingParams) Reset()

func (*EncodingParams) String 

func (x *EncodingParams) String() string

func (*EncodingParams) Valid 

func (p *EncodingParams) Valid() error

Valid returns true if the EncodingParams seem to make sense. We try to be as close to the liquidsoap capabilities as possible.

type Endpoint 

type Endpoint struct {
	Name  string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Addrs []string `protobuf:"bytes,2,rep,name=addrs,proto3" json:"addrs,omitempty"`
	// contains filtered or unexported fields
}

func NewEndpointWithIPAndPort 

func NewEndpointWithIPAndPort(name string, ips []net.IP, port int) *Endpoint

NewEndpointWithIPAndPort creates an Endpoint with the specified IP address and port.

func (*Endpoint) Descriptor deprecated 

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

Deprecated: Use Endpoint.ProtoReflect.Descriptor instead.

func (*Endpoint) GetAddrs 

func (x *Endpoint) GetAddrs() []string

func (*Endpoint) GetName 

func (x *Endpoint) GetName() string

func (*Endpoint) ProtoMessage 

func (*Endpoint) ProtoMessage()

func (*Endpoint) ProtoReflect 

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

func (*Endpoint) Reset 

func (x *Endpoint) Reset()

func (*Endpoint) String 

func (x *Endpoint) String() string

type ExchangeRequest 

type ExchangeRequest struct {
	Nodes []*Status `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*ExchangeRequest) Descriptor deprecated 

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

Deprecated: Use ExchangeRequest.ProtoReflect.Descriptor instead.

func (*ExchangeRequest) GetNodes 

func (x *ExchangeRequest) GetNodes() []*Status

func (*ExchangeRequest) ProtoMessage 

func (*ExchangeRequest) ProtoMessage()

func (*ExchangeRequest) ProtoReflect 

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

func (*ExchangeRequest) Reset 

func (x *ExchangeRequest) Reset()

func (*ExchangeRequest) String 

func (x *ExchangeRequest) String() string

type ExchangeResponse 

type ExchangeResponse struct {
	Nodes []*Status `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*ExchangeResponse) Descriptor deprecated 

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

Deprecated: Use ExchangeResponse.ProtoReflect.Descriptor instead.

func (*ExchangeResponse) GetNodes 

func (x *ExchangeResponse) GetNodes() []*Status

func (*ExchangeResponse) ProtoMessage 

func (*ExchangeResponse) ProtoMessage()

func (*ExchangeResponse) ProtoReflect 

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

func (*ExchangeResponse) Reset 

func (x *ExchangeResponse) Reset()

func (*ExchangeResponse) String 

func (x *ExchangeResponse) String() string

type GossipServiceClient 

type GossipServiceClient interface {
	Exchange(ctx context.Context, in *ExchangeRequest, opts ...grpc.CallOption) (*ExchangeResponse, error)
}

GossipServiceClient is the client API for GossipService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewGossipServiceClient 

func NewGossipServiceClient(cc grpc.ClientConnInterface) GossipServiceClient

type GossipServiceServer 

type GossipServiceServer interface {
	Exchange(context.Context, *ExchangeRequest) (*ExchangeResponse, error)
	// contains filtered or unexported methods
}

GossipServiceServer is the server API for GossipService service. All implementations must embed UnimplementedGossipServiceServer for forward compatibility

type IcecastMount 

type IcecastMount struct {
	Path        string  `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Listeners   int32   `protobuf:"varint,2,opt,name=listeners,proto3" json:"listeners,omitempty"`
	BitRate     int32   `protobuf:"varint,3,opt,name=bit_rate,json=bitRate,proto3" json:"bit_rate,omitempty"`
	SampleRate  int32   `protobuf:"varint,4,opt,name=sample_rate,json=sampleRate,proto3" json:"sample_rate,omitempty"`
	Quality     float32 `protobuf:"fixed32,5,opt,name=quality,proto3" json:"quality,omitempty"`
	Channels    int32   `protobuf:"varint,6,opt,name=channels,proto3" json:"channels,omitempty"`
	Artist      string  `protobuf:"bytes,7,opt,name=artist,proto3" json:"artist,omitempty"`
	Title       string  `protobuf:"bytes,8,opt,name=title,proto3" json:"title,omitempty"`
	Name        string  `protobuf:"bytes,9,opt,name=name,proto3" json:"name,omitempty"`
	Description string  `protobuf:"bytes,10,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*IcecastMount) Descriptor deprecated 

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

Deprecated: Use IcecastMount.ProtoReflect.Descriptor instead.

func (*IcecastMount) GetArtist 

func (x *IcecastMount) GetArtist() string

func (*IcecastMount) GetBitRate 

func (x *IcecastMount) GetBitRate() int32

func (*IcecastMount) GetChannels 

func (x *IcecastMount) GetChannels() int32

func (*IcecastMount) GetDescription 

func (x *IcecastMount) GetDescription() string

func (*IcecastMount) GetListeners 

func (x *IcecastMount) GetListeners() int32

func (*IcecastMount) GetName 

func (x *IcecastMount) GetName() string

func (*IcecastMount) GetPath 

func (x *IcecastMount) GetPath() string

func (*IcecastMount) GetQuality 

func (x *IcecastMount) GetQuality() float32

func (*IcecastMount) GetSampleRate 

func (x *IcecastMount) GetSampleRate() int32

func (*IcecastMount) GetTitle 

func (x *IcecastMount) GetTitle() string

func (*IcecastMount) ProtoMessage 

func (*IcecastMount) ProtoMessage()

func (*IcecastMount) ProtoReflect 

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

func (*IcecastMount) Reset 

func (x *IcecastMount) Reset()

func (*IcecastMount) String 

func (x *IcecastMount) String() string

type Mount 

type Mount struct {
	Path            string          `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	SourceUsername  string          `protobuf:"bytes,2,opt,name=source_username,json=sourceUsername,proto3" json:"source_username,omitempty"`
	SourcePassword  string          `protobuf:"bytes,3,opt,name=source_password,json=sourcePassword,proto3" json:"source_password,omitempty"`
	RelayUrl        string          `protobuf:"bytes,4,opt,name=relay_url,json=relayUrl,proto3" json:"relay_url,omitempty"`
	FallbackPath    string          `protobuf:"bytes,5,opt,name=fallback_path,json=fallbackPath,proto3" json:"fallback_path,omitempty"`
	Transcode       bool            `protobuf:"varint,6,opt,name=transcode,proto3" json:"transcode,omitempty"`
	TranscodeParams *EncodingParams `protobuf:"bytes,7,opt,name=transcode_params,json=transcodeParams,proto3" json:"transcode_params,omitempty"`
	// contains filtered or unexported fields
}

func (*Mount) Descriptor deprecated 

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

Deprecated: Use Mount.ProtoReflect.Descriptor instead.

func (*Mount) GetFallbackPath 

func (x *Mount) GetFallbackPath() string

func (*Mount) GetPath 

func (x *Mount) GetPath() string

func (*Mount) GetRelayUrl 

func (x *Mount) GetRelayUrl() string

func (*Mount) GetSourcePassword 

func (x *Mount) GetSourcePassword() string

func (*Mount) GetSourceUsername 

func (x *Mount) GetSourceUsername() string

func (*Mount) GetTranscode 

func (x *Mount) GetTranscode() bool

func (*Mount) GetTranscodeParams 

func (x *Mount) GetTranscodeParams() *EncodingParams

func (*Mount) HasTranscoder 

func (m *Mount) HasTranscoder() bool

HasTranscoder returns true if the stream has transcoding sub-streams.

func (*Mount) IsRelay 

func (m *Mount) IsRelay() bool

IsRelay returns true if the stream is configured as a relay of an external source.

func (*Mount) ProtoMessage 

func (*Mount) ProtoMessage()

func (*Mount) ProtoReflect 

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

func (*Mount) Reset 

func (x *Mount) Reset()

func (*Mount) String 

func (x *Mount) String() string

func (*Mount) Valid 

func (m *Mount) Valid() error

Valid performs a consistency check and returns true if the configuration for the stream is correct.

type Status 

type Status struct {
	Name          string          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Timestamp     uint64          `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	IcecastOk     bool            `protobuf:"varint,3,opt,name=icecast_ok,json=icecastOk,proto3" json:"icecast_ok,omitempty"`
	IcecastMounts []*IcecastMount `protobuf:"bytes,4,rep,name=icecast_mounts,json=icecastMounts,proto3" json:"icecast_mounts,omitempty"`
	CurBandwidth  int32           `protobuf:"varint,5,opt,name=cur_bandwidth,json=curBandwidth,proto3" json:"cur_bandwidth,omitempty"`
	MaxBandwidth  int32           `protobuf:"varint,6,opt,name=max_bandwidth,json=maxBandwidth,proto3" json:"max_bandwidth,omitempty"`
	MaxListeners  int32           `protobuf:"varint,7,opt,name=max_listeners,json=maxListeners,proto3" json:"max_listeners,omitempty"`
	NumListeners  int32           `protobuf:"varint,8,opt,name=num_listeners,json=numListeners,proto3" json:"num_listeners,omitempty"`
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated 

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetCurBandwidth 

func (x *Status) GetCurBandwidth() int32

func (*Status) GetIcecastMounts 

func (x *Status) GetIcecastMounts() []*IcecastMount

func (*Status) GetIcecastOk 

func (x *Status) GetIcecastOk() bool

func (*Status) GetMaxBandwidth 

func (x *Status) GetMaxBandwidth() int32

func (*Status) GetMaxListeners 

func (x *Status) GetMaxListeners() int32

func (*Status) GetName 

func (x *Status) GetName() string

func (*Status) GetNumListeners 

func (x *Status) GetNumListeners() int32

func (*Status) GetTimestamp 

func (x *Status) GetTimestamp() uint64

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

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

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

func (x *Status) String() string

type UnimplementedGossipServiceServer 

type UnimplementedGossipServiceServer struct {
}

UnimplementedGossipServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedGossipServiceServer) Exchange 

func (UnimplementedGossipServiceServer) Exchange(context.Context, *ExchangeRequest) (*ExchangeResponse, error)

type UnsafeGossipServiceServer 

type UnsafeGossipServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeGossipServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GossipServiceServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.