Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterAudioServiceServer(s grpc.ServiceRegistrar, srv AudioServiceServer)
- func RegisterSystemServiceServer(s grpc.ServiceRegistrar, srv SystemServiceServer)
- func RegisterTalkgroupServiceServer(s grpc.ServiceRegistrar, srv TalkgroupServiceServer)
- type ActiveCall
- func (*ActiveCall) Descriptor() ([]byte, []int)deprecated
- func (x *ActiveCall) GetDeviceSerial() string
- func (x *ActiveCall) GetGrant() *Grant
- func (x *ActiveCall) GetLastHeardAt() string
- func (x *ActiveCall) GetStartedAt() string
- func (x *ActiveCall) GetTalkgroup() *TalkGroup
- func (*ActiveCall) ProtoMessage()
- func (x *ActiveCall) ProtoReflect() protoreflect.Message
- func (x *ActiveCall) Reset()
- func (x *ActiveCall) String() string
- type AudioFrame
- func (*AudioFrame) Descriptor() ([]byte, []int)deprecated
- func (x *AudioFrame) GetBody() isAudioFrame_Body
- func (x *AudioFrame) GetDeviceSerial() string
- func (x *AudioFrame) GetGrant() *Grant
- func (x *AudioFrame) GetPcm() *PCMSamples
- func (x *AudioFrame) GetRaw() *RawVocoderFrame
- func (x *AudioFrame) GetTimestamp() string
- func (*AudioFrame) ProtoMessage()
- func (x *AudioFrame) ProtoReflect() protoreflect.Message
- func (x *AudioFrame) Reset()
- func (x *AudioFrame) String() string
- type AudioFrame_Pcm
- type AudioFrame_Raw
- type AudioServiceClient
- type AudioServiceServer
- type AudioService_StreamAudioClient
- type AudioService_StreamAudioServer
- type CCLocked
- type CCLost
- type CallEnd
- func (*CallEnd) Descriptor() ([]byte, []int)deprecated
- func (x *CallEnd) GetDeviceSerial() string
- func (x *CallEnd) GetEndedAt() string
- func (x *CallEnd) GetGrant() *Grant
- func (x *CallEnd) GetReason() string
- func (x *CallEnd) GetStartedAt() string
- func (x *CallEnd) GetTalkgroup() *TalkGroup
- func (*CallEnd) ProtoMessage()
- func (x *CallEnd) ProtoReflect() protoreflect.Message
- func (x *CallEnd) Reset()
- func (x *CallEnd) String() string
- type CallStart
- func (*CallStart) Descriptor() ([]byte, []int)deprecated
- func (x *CallStart) GetDeviceSerial() string
- func (x *CallStart) GetGrant() *Grant
- func (x *CallStart) GetTalkgroup() *TalkGroup
- func (*CallStart) ProtoMessage()
- func (x *CallStart) ProtoReflect() protoreflect.Message
- func (x *CallStart) Reset()
- func (x *CallStart) String() string
- type ErrorEvent
- type Event
- func (*Event) Descriptor() ([]byte, []int)deprecated
- func (x *Event) GetCallEnd() *CallEnd
- func (x *Event) GetCallStart() *CallStart
- func (x *Event) GetCcLocked() *CCLocked
- func (x *Event) GetCcLost() *CCLost
- func (x *Event) GetError() *ErrorEvent
- func (x *Event) GetGrant() *Grant
- func (x *Event) GetKind() string
- func (x *Event) GetPayload() isEvent_Payload
- func (x *Event) GetSdrStatus() *SDRStatus
- func (x *Event) GetTimestamp() string
- func (*Event) ProtoMessage()
- func (x *Event) ProtoReflect() protoreflect.Message
- func (x *Event) Reset()
- func (x *Event) String() string
- type Event_CallEnd
- type Event_CallStart
- type Event_CcLocked
- type Event_CcLost
- type Event_Error
- type Event_Grant
- type Event_SdrStatus
- type GetSystemRequest
- type GetSystemResponse
- type GetTalkgroupRequest
- func (*GetTalkgroupRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetTalkgroupRequest) GetId() uint32
- func (*GetTalkgroupRequest) ProtoMessage()
- func (x *GetTalkgroupRequest) ProtoReflect() protoreflect.Message
- func (x *GetTalkgroupRequest) Reset()
- func (x *GetTalkgroupRequest) String() string
- type GetTalkgroupResponse
- func (*GetTalkgroupResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetTalkgroupResponse) GetTalkgroup() *TalkGroup
- func (*GetTalkgroupResponse) ProtoMessage()
- func (x *GetTalkgroupResponse) ProtoReflect() protoreflect.Message
- func (x *GetTalkgroupResponse) Reset()
- func (x *GetTalkgroupResponse) String() string
- type Grant
- func (*Grant) Descriptor() ([]byte, []int)deprecated
- func (x *Grant) GetChannelId() uint32
- func (x *Grant) GetChannelNumber() uint32
- func (x *Grant) GetDataCall() bool
- func (x *Grant) GetEmergency() bool
- func (x *Grant) GetEncrypted() bool
- func (x *Grant) GetFrequencyHz() uint32
- func (x *Grant) GetGroupId() uint32
- func (x *Grant) GetProtocol() string
- func (x *Grant) GetSourceId() uint32
- func (x *Grant) GetSystem() string
- func (*Grant) ProtoMessage()
- func (x *Grant) ProtoReflect() protoreflect.Message
- func (x *Grant) Reset()
- func (x *Grant) String() string
- type ListActiveCallsRequest
- type ListActiveCallsResponse
- func (*ListActiveCallsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListActiveCallsResponse) GetCalls() []*ActiveCall
- func (*ListActiveCallsResponse) ProtoMessage()
- func (x *ListActiveCallsResponse) ProtoReflect() protoreflect.Message
- func (x *ListActiveCallsResponse) Reset()
- func (x *ListActiveCallsResponse) String() string
- type ListSystemsRequest
- type ListSystemsResponse
- func (*ListSystemsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListSystemsResponse) GetSystems() []*System
- func (*ListSystemsResponse) ProtoMessage()
- func (x *ListSystemsResponse) ProtoReflect() protoreflect.Message
- func (x *ListSystemsResponse) Reset()
- func (x *ListSystemsResponse) String() string
- type ListTalkgroupsRequest
- func (*ListTalkgroupsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListTalkgroupsRequest) GetSystem() string
- func (*ListTalkgroupsRequest) ProtoMessage()
- func (x *ListTalkgroupsRequest) ProtoReflect() protoreflect.Message
- func (x *ListTalkgroupsRequest) Reset()
- func (x *ListTalkgroupsRequest) String() string
- type ListTalkgroupsResponse
- func (*ListTalkgroupsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListTalkgroupsResponse) GetTalkgroups() []*TalkGroup
- func (*ListTalkgroupsResponse) ProtoMessage()
- func (x *ListTalkgroupsResponse) ProtoReflect() protoreflect.Message
- func (x *ListTalkgroupsResponse) Reset()
- func (x *ListTalkgroupsResponse) String() string
- type PCMSamples
- type RawVocoderFrame
- func (*RawVocoderFrame) Descriptor() ([]byte, []int)deprecated
- func (x *RawVocoderFrame) GetFrame() []byte
- func (x *RawVocoderFrame) GetVocoder() string
- func (*RawVocoderFrame) ProtoMessage()
- func (x *RawVocoderFrame) ProtoReflect() protoreflect.Message
- func (x *RawVocoderFrame) Reset()
- func (x *RawVocoderFrame) String() string
- type SDRStatus
- func (*SDRStatus) Descriptor() ([]byte, []int)deprecated
- func (x *SDRStatus) GetAttached() bool
- func (x *SDRStatus) GetDriver() string
- func (x *SDRStatus) GetRole() string
- func (x *SDRStatus) GetSerial() string
- func (*SDRStatus) ProtoMessage()
- func (x *SDRStatus) ProtoReflect() protoreflect.Message
- func (x *SDRStatus) Reset()
- func (x *SDRStatus) String() string
- type StreamAudioRequest
- func (*StreamAudioRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamAudioRequest) GetDeviceSerials() []string
- func (x *StreamAudioRequest) GetIncludeRaw() bool
- func (x *StreamAudioRequest) GetTalkgroupIds() []uint32
- func (*StreamAudioRequest) ProtoMessage()
- func (x *StreamAudioRequest) ProtoReflect() protoreflect.Message
- func (x *StreamAudioRequest) Reset()
- func (x *StreamAudioRequest) String() string
- type System
- func (*System) Descriptor() ([]byte, []int)deprecated
- func (x *System) GetControlChannels() []uint32
- func (x *System) GetName() string
- func (x *System) GetProtocol() string
- func (x *System) GetRfss() uint32
- func (x *System) GetSite() uint32
- func (x *System) GetSystemId() uint32
- func (x *System) GetWacn() uint32
- func (*System) ProtoMessage()
- func (x *System) ProtoReflect() protoreflect.Message
- func (x *System) Reset()
- func (x *System) String() string
- type SystemServiceClient
- type SystemServiceServer
- type TalkGroup
- func (*TalkGroup) Descriptor() ([]byte, []int)deprecated
- func (x *TalkGroup) GetAlphaTag() string
- func (x *TalkGroup) GetDescription() string
- func (x *TalkGroup) GetGroup() string
- func (x *TalkGroup) GetId() uint32
- func (x *TalkGroup) GetLockout() bool
- func (x *TalkGroup) GetMode() string
- func (x *TalkGroup) GetPriority() int32
- func (x *TalkGroup) GetTag() string
- func (*TalkGroup) ProtoMessage()
- func (x *TalkGroup) ProtoReflect() protoreflect.Message
- func (x *TalkGroup) Reset()
- func (x *TalkGroup) String() string
- type TalkgroupServiceClient
- type TalkgroupServiceServer
- type UnimplementedAudioServiceServer
- type UnimplementedSystemServiceServer
- type UnimplementedTalkgroupServiceServer
- func (UnimplementedTalkgroupServiceServer) GetTalkgroup(context.Context, *GetTalkgroupRequest) (*GetTalkgroupResponse, error)
- func (UnimplementedTalkgroupServiceServer) ListActiveCalls(context.Context, *ListActiveCallsRequest) (*ListActiveCallsResponse, error)
- func (UnimplementedTalkgroupServiceServer) ListTalkgroups(context.Context, *ListTalkgroupsRequest) (*ListTalkgroupsResponse, error)
- type UnsafeAudioServiceServer
- type UnsafeSystemServiceServer
- type UnsafeTalkgroupServiceServer
Constants ¶
const ( SystemService_ListSystems_FullMethodName = "/gophertrunk.v1.SystemService/ListSystems" SystemService_GetSystem_FullMethodName = "/gophertrunk.v1.SystemService/GetSystem" )
const ( TalkgroupService_ListTalkgroups_FullMethodName = "/gophertrunk.v1.TalkgroupService/ListTalkgroups" TalkgroupService_GetTalkgroup_FullMethodName = "/gophertrunk.v1.TalkgroupService/GetTalkgroup" TalkgroupService_ListActiveCalls_FullMethodName = "/gophertrunk.v1.TalkgroupService/ListActiveCalls" )
const (
AudioService_StreamAudio_FullMethodName = "/gophertrunk.v1.AudioService/StreamAudio"
)
Variables ¶
var AudioService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "gophertrunk.v1.AudioService", HandlerType: (*AudioServiceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "StreamAudio", Handler: _AudioService_StreamAudio_Handler, ServerStreams: true, }, }, Metadata: "audio.proto", }
AudioService_ServiceDesc is the grpc.ServiceDesc for AudioService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_audio_proto protoreflect.FileDescriptor
var File_events_proto protoreflect.FileDescriptor
var File_system_proto protoreflect.FileDescriptor
var File_talkgroup_proto protoreflect.FileDescriptor
var SystemService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "gophertrunk.v1.SystemService", HandlerType: (*SystemServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ListSystems", Handler: _SystemService_ListSystems_Handler, }, { MethodName: "GetSystem", Handler: _SystemService_GetSystem_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "system.proto", }
SystemService_ServiceDesc is the grpc.ServiceDesc for SystemService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var TalkgroupService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "gophertrunk.v1.TalkgroupService", HandlerType: (*TalkgroupServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ListTalkgroups", Handler: _TalkgroupService_ListTalkgroups_Handler, }, { MethodName: "GetTalkgroup", Handler: _TalkgroupService_GetTalkgroup_Handler, }, { MethodName: "ListActiveCalls", Handler: _TalkgroupService_ListActiveCalls_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "talkgroup.proto", }
TalkgroupService_ServiceDesc is the grpc.ServiceDesc for TalkgroupService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterAudioServiceServer ¶
func RegisterAudioServiceServer(s grpc.ServiceRegistrar, srv AudioServiceServer)
func RegisterSystemServiceServer ¶
func RegisterSystemServiceServer(s grpc.ServiceRegistrar, srv SystemServiceServer)
func RegisterTalkgroupServiceServer ¶
func RegisterTalkgroupServiceServer(s grpc.ServiceRegistrar, srv TalkgroupServiceServer)
Types ¶
type ActiveCall ¶
type ActiveCall struct {
Grant *Grant `protobuf:"bytes,1,opt,name=grant,proto3" json:"grant,omitempty"`
Talkgroup *TalkGroup `protobuf:"bytes,2,opt,name=talkgroup,proto3" json:"talkgroup,omitempty"`
DeviceSerial string `protobuf:"bytes,3,opt,name=device_serial,json=deviceSerial,proto3" json:"device_serial,omitempty"`
StartedAt string `protobuf:"bytes,4,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
LastHeardAt string `protobuf:"bytes,5,opt,name=last_heard_at,json=lastHeardAt,proto3" json:"last_heard_at,omitempty"`
// contains filtered or unexported fields
}
func (*ActiveCall) Descriptor
deprecated
func (*ActiveCall) Descriptor() ([]byte, []int)
Deprecated: Use ActiveCall.ProtoReflect.Descriptor instead.
func (*ActiveCall) GetDeviceSerial ¶
func (x *ActiveCall) GetDeviceSerial() string
func (*ActiveCall) GetGrant ¶
func (x *ActiveCall) GetGrant() *Grant
func (*ActiveCall) GetLastHeardAt ¶
func (x *ActiveCall) GetLastHeardAt() string
func (*ActiveCall) GetStartedAt ¶
func (x *ActiveCall) GetStartedAt() string
func (*ActiveCall) GetTalkgroup ¶
func (x *ActiveCall) GetTalkgroup() *TalkGroup
func (*ActiveCall) ProtoMessage ¶
func (*ActiveCall) ProtoMessage()
func (*ActiveCall) ProtoReflect ¶
func (x *ActiveCall) ProtoReflect() protoreflect.Message
func (*ActiveCall) Reset ¶
func (x *ActiveCall) Reset()
func (*ActiveCall) String ¶
func (x *ActiveCall) String() string
type AudioFrame ¶
type AudioFrame struct {
// Server-stamped time the frame was emitted (RFC 3339 UTC).
Timestamp string `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
// The call this frame belongs to. Source ID + group ID + start time
// disambiguate concurrent calls on different Voice devices.
Grant *Grant `protobuf:"bytes,2,opt,name=grant,proto3" json:"grant,omitempty"`
DeviceSerial string `protobuf:"bytes,3,opt,name=device_serial,json=deviceSerial,proto3" json:"device_serial,omitempty"`
// Types that are valid to be assigned to Body:
//
// *AudioFrame_Pcm
// *AudioFrame_Raw
Body isAudioFrame_Body `protobuf_oneof:"body"`
// contains filtered or unexported fields
}
AudioFrame is one chunk of decoded PCM (or raw vocoder bytes) for an active call. Streamed from the daemon to subscribers.
func (*AudioFrame) Descriptor
deprecated
func (*AudioFrame) Descriptor() ([]byte, []int)
Deprecated: Use AudioFrame.ProtoReflect.Descriptor instead.
func (*AudioFrame) GetBody ¶
func (x *AudioFrame) GetBody() isAudioFrame_Body
func (*AudioFrame) GetDeviceSerial ¶
func (x *AudioFrame) GetDeviceSerial() string
func (*AudioFrame) GetGrant ¶
func (x *AudioFrame) GetGrant() *Grant
func (*AudioFrame) GetPcm ¶
func (x *AudioFrame) GetPcm() *PCMSamples
func (*AudioFrame) GetRaw ¶
func (x *AudioFrame) GetRaw() *RawVocoderFrame
func (*AudioFrame) GetTimestamp ¶
func (x *AudioFrame) GetTimestamp() string
func (*AudioFrame) ProtoMessage ¶
func (*AudioFrame) ProtoMessage()
func (*AudioFrame) ProtoReflect ¶
func (x *AudioFrame) ProtoReflect() protoreflect.Message
func (*AudioFrame) Reset ¶
func (x *AudioFrame) Reset()
func (*AudioFrame) String ¶
func (x *AudioFrame) String() string
type AudioFrame_Pcm ¶
type AudioFrame_Pcm struct {
Pcm *PCMSamples `protobuf:"bytes,10,opt,name=pcm,proto3,oneof"` // decoded 16-bit mono PCM
}
type AudioFrame_Raw ¶
type AudioFrame_Raw struct {
Raw *RawVocoderFrame `protobuf:"bytes,11,opt,name=raw,proto3,oneof"` // un-decoded vocoder bytes (IMBE / AMBE+2)
}
type AudioServiceClient ¶
type AudioServiceClient interface {
// Server-streaming RPC. The daemon emits one AudioFrame per arriving
// PCM chunk for matching active calls.
StreamAudio(ctx context.Context, in *StreamAudioRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[AudioFrame], error)
}
AudioServiceClient is the client API for AudioService 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 NewAudioServiceClient ¶
func NewAudioServiceClient(cc grpc.ClientConnInterface) AudioServiceClient
type AudioServiceServer ¶
type AudioServiceServer interface {
// Server-streaming RPC. The daemon emits one AudioFrame per arriving
// PCM chunk for matching active calls.
StreamAudio(*StreamAudioRequest, grpc.ServerStreamingServer[AudioFrame]) error
// contains filtered or unexported methods
}
AudioServiceServer is the server API for AudioService service. All implementations must embed UnimplementedAudioServiceServer for forward compatibility.
type AudioService_StreamAudioClient ¶
type AudioService_StreamAudioClient = grpc.ServerStreamingClient[AudioFrame]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type AudioService_StreamAudioServer ¶
type AudioService_StreamAudioServer = grpc.ServerStreamingServer[AudioFrame]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type CCLocked ¶
type CCLocked struct {
FrequencyHz uint32 `protobuf:"varint,1,opt,name=frequency_hz,json=frequencyHz,proto3" json:"frequency_hz,omitempty"`
// Protocol-specific identifier: P25 NAC, DMR Color Code, NXDN
// BaudRate, etc. Carried as a key/value bag for extensibility.
Attrs map[string]string `` /* 137-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*CCLocked) Descriptor
deprecated
func (*CCLocked) GetFrequencyHz ¶
func (*CCLocked) ProtoMessage ¶
func (*CCLocked) ProtoMessage()
func (*CCLocked) ProtoReflect ¶
func (x *CCLocked) ProtoReflect() protoreflect.Message
type CCLost ¶
type CCLost struct {
FrequencyHz uint32 `protobuf:"varint,1,opt,name=frequency_hz,json=frequencyHz,proto3" json:"frequency_hz,omitempty"`
Attrs map[string]string `` /* 137-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*CCLost) Descriptor
deprecated
func (*CCLost) GetFrequencyHz ¶
func (*CCLost) ProtoMessage ¶
func (*CCLost) ProtoMessage()
func (*CCLost) ProtoReflect ¶
func (x *CCLost) ProtoReflect() protoreflect.Message
type CallEnd ¶
type CallEnd struct {
Grant *Grant `protobuf:"bytes,1,opt,name=grant,proto3" json:"grant,omitempty"`
Talkgroup *TalkGroup `protobuf:"bytes,2,opt,name=talkgroup,proto3" json:"talkgroup,omitempty"`
DeviceSerial string `protobuf:"bytes,3,opt,name=device_serial,json=deviceSerial,proto3" json:"device_serial,omitempty"`
StartedAt string `protobuf:"bytes,4,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"` // RFC 3339
EndedAt string `protobuf:"bytes,5,opt,name=ended_at,json=endedAt,proto3" json:"ended_at,omitempty"`
Reason string `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"` // EndReason.String()
// contains filtered or unexported fields
}
func (*CallEnd) Descriptor
deprecated
func (*CallEnd) GetDeviceSerial ¶
func (*CallEnd) GetEndedAt ¶
func (*CallEnd) GetStartedAt ¶
func (*CallEnd) GetTalkgroup ¶
func (*CallEnd) ProtoMessage ¶
func (*CallEnd) ProtoMessage()
func (*CallEnd) ProtoReflect ¶
func (x *CallEnd) ProtoReflect() protoreflect.Message
type CallStart ¶
type CallStart struct {
Grant *Grant `protobuf:"bytes,1,opt,name=grant,proto3" json:"grant,omitempty"`
Talkgroup *TalkGroup `protobuf:"bytes,2,opt,name=talkgroup,proto3" json:"talkgroup,omitempty"` // optional; null if unknown
DeviceSerial string `protobuf:"bytes,3,opt,name=device_serial,json=deviceSerial,proto3" json:"device_serial,omitempty"`
// contains filtered or unexported fields
}
func (*CallStart) Descriptor
deprecated
func (*CallStart) GetDeviceSerial ¶
func (*CallStart) GetTalkgroup ¶
func (*CallStart) ProtoMessage ¶
func (*CallStart) ProtoMessage()
func (*CallStart) ProtoReflect ¶
func (x *CallStart) ProtoReflect() protoreflect.Message
type ErrorEvent ¶
type ErrorEvent struct {
Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` // subsystem ("sdr", "p25", "trunking", ...)
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*ErrorEvent) Descriptor
deprecated
func (*ErrorEvent) Descriptor() ([]byte, []int)
Deprecated: Use ErrorEvent.ProtoReflect.Descriptor instead.
func (*ErrorEvent) GetMessage ¶
func (x *ErrorEvent) GetMessage() string
func (*ErrorEvent) GetSource ¶
func (x *ErrorEvent) GetSource() string
func (*ErrorEvent) ProtoMessage ¶
func (*ErrorEvent) ProtoMessage()
func (*ErrorEvent) ProtoReflect ¶
func (x *ErrorEvent) ProtoReflect() protoreflect.Message
func (*ErrorEvent) Reset ¶
func (x *ErrorEvent) Reset()
func (*ErrorEvent) String ¶
func (x *ErrorEvent) String() string
type Event ¶
type Event struct {
// Event kind. Values match internal/events.Kind constants
// ("cc.locked", "cc.lost", "grant", "call.start", "call.end",
// "sdr.attached", "sdr.detached", "error").
Kind string `protobuf:"bytes,1,opt,name=kind,proto3" json:"kind,omitempty"`
// Server-stamped timestamp in RFC 3339 (UTC).
Timestamp string `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
// Discriminated payload. Exactly one of these is set per event.
//
// Types that are valid to be assigned to Payload:
//
// *Event_CcLocked
// *Event_CcLost
// *Event_Grant
// *Event_CallStart
// *Event_CallEnd
// *Event_SdrStatus
// *Event_Error
Payload isEvent_Payload `protobuf_oneof:"payload"`
// contains filtered or unexported fields
}
Event is the canonical envelope for everything published on the internal events bus and bridged out over the streaming API.
func (*Event) Descriptor
deprecated
func (*Event) GetCallEnd ¶
func (*Event) GetCallStart ¶
func (*Event) GetCcLocked ¶
func (*Event) GetError ¶
func (x *Event) GetError() *ErrorEvent
func (*Event) GetPayload ¶
func (x *Event) GetPayload() isEvent_Payload
func (*Event) GetSdrStatus ¶
func (*Event) GetTimestamp ¶
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) ProtoReflect ¶
func (x *Event) ProtoReflect() protoreflect.Message
type Event_CallEnd ¶
type Event_CallEnd struct {
CallEnd *CallEnd `protobuf:"bytes,14,opt,name=call_end,json=callEnd,proto3,oneof"`
}
type Event_CallStart ¶
type Event_CallStart struct {
CallStart *CallStart `protobuf:"bytes,13,opt,name=call_start,json=callStart,proto3,oneof"`
}
type Event_CcLocked ¶
type Event_CcLocked struct {
CcLocked *CCLocked `protobuf:"bytes,10,opt,name=cc_locked,json=ccLocked,proto3,oneof"`
}
type Event_CcLost ¶
type Event_CcLost struct {
CcLost *CCLost `protobuf:"bytes,11,opt,name=cc_lost,json=ccLost,proto3,oneof"`
}
type Event_Error ¶
type Event_Error struct {
Error *ErrorEvent `protobuf:"bytes,16,opt,name=error,proto3,oneof"`
}
type Event_Grant ¶
type Event_Grant struct {
Grant *Grant `protobuf:"bytes,12,opt,name=grant,proto3,oneof"`
}
type Event_SdrStatus ¶
type Event_SdrStatus struct {
SdrStatus *SDRStatus `protobuf:"bytes,15,opt,name=sdr_status,json=sdrStatus,proto3,oneof"`
}
type GetSystemRequest ¶
type GetSystemRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*GetSystemRequest) Descriptor
deprecated
func (*GetSystemRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSystemRequest.ProtoReflect.Descriptor instead.
func (*GetSystemRequest) GetName ¶
func (x *GetSystemRequest) GetName() string
func (*GetSystemRequest) ProtoMessage ¶
func (*GetSystemRequest) ProtoMessage()
func (*GetSystemRequest) ProtoReflect ¶
func (x *GetSystemRequest) ProtoReflect() protoreflect.Message
func (*GetSystemRequest) Reset ¶
func (x *GetSystemRequest) Reset()
func (*GetSystemRequest) String ¶
func (x *GetSystemRequest) String() string
type GetSystemResponse ¶
type GetSystemResponse struct {
System *System `protobuf:"bytes,1,opt,name=system,proto3" json:"system,omitempty"`
// contains filtered or unexported fields
}
func (*GetSystemResponse) Descriptor
deprecated
func (*GetSystemResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetSystemResponse.ProtoReflect.Descriptor instead.
func (*GetSystemResponse) GetSystem ¶
func (x *GetSystemResponse) GetSystem() *System
func (*GetSystemResponse) ProtoMessage ¶
func (*GetSystemResponse) ProtoMessage()
func (*GetSystemResponse) ProtoReflect ¶
func (x *GetSystemResponse) ProtoReflect() protoreflect.Message
func (*GetSystemResponse) Reset ¶
func (x *GetSystemResponse) Reset()
func (*GetSystemResponse) String ¶
func (x *GetSystemResponse) String() string
type GetTalkgroupRequest ¶
type GetTalkgroupRequest struct {
Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
// contains filtered or unexported fields
}
func (*GetTalkgroupRequest) Descriptor
deprecated
func (*GetTalkgroupRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTalkgroupRequest.ProtoReflect.Descriptor instead.
func (*GetTalkgroupRequest) GetId ¶
func (x *GetTalkgroupRequest) GetId() uint32
func (*GetTalkgroupRequest) ProtoMessage ¶
func (*GetTalkgroupRequest) ProtoMessage()
func (*GetTalkgroupRequest) ProtoReflect ¶
func (x *GetTalkgroupRequest) ProtoReflect() protoreflect.Message
func (*GetTalkgroupRequest) Reset ¶
func (x *GetTalkgroupRequest) Reset()
func (*GetTalkgroupRequest) String ¶
func (x *GetTalkgroupRequest) String() string
type GetTalkgroupResponse ¶
type GetTalkgroupResponse struct {
Talkgroup *TalkGroup `protobuf:"bytes,1,opt,name=talkgroup,proto3" json:"talkgroup,omitempty"`
// contains filtered or unexported fields
}
func (*GetTalkgroupResponse) Descriptor
deprecated
func (*GetTalkgroupResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetTalkgroupResponse.ProtoReflect.Descriptor instead.
func (*GetTalkgroupResponse) GetTalkgroup ¶
func (x *GetTalkgroupResponse) GetTalkgroup() *TalkGroup
func (*GetTalkgroupResponse) ProtoMessage ¶
func (*GetTalkgroupResponse) ProtoMessage()
func (*GetTalkgroupResponse) ProtoReflect ¶
func (x *GetTalkgroupResponse) ProtoReflect() protoreflect.Message
func (*GetTalkgroupResponse) Reset ¶
func (x *GetTalkgroupResponse) Reset()
func (*GetTalkgroupResponse) String ¶
func (x *GetTalkgroupResponse) String() string
type Grant ¶
type Grant struct {
System string `protobuf:"bytes,1,opt,name=system,proto3" json:"system,omitempty"`
Protocol string `protobuf:"bytes,2,opt,name=protocol,proto3" json:"protocol,omitempty"` // "p25" / "dmr" / "nxdn"
GroupId uint32 `protobuf:"varint,3,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
SourceId uint32 `protobuf:"varint,4,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"`
FrequencyHz uint32 `protobuf:"varint,5,opt,name=frequency_hz,json=frequencyHz,proto3" json:"frequency_hz,omitempty"`
ChannelId uint32 `protobuf:"varint,6,opt,name=channel_id,json=channelId,proto3" json:"channel_id,omitempty"`
ChannelNumber uint32 `protobuf:"varint,7,opt,name=channel_number,json=channelNumber,proto3" json:"channel_number,omitempty"`
Encrypted bool `protobuf:"varint,8,opt,name=encrypted,proto3" json:"encrypted,omitempty"`
Emergency bool `protobuf:"varint,9,opt,name=emergency,proto3" json:"emergency,omitempty"`
DataCall bool `protobuf:"varint,10,opt,name=data_call,json=dataCall,proto3" json:"data_call,omitempty"`
// contains filtered or unexported fields
}
func (*Grant) Descriptor
deprecated
func (*Grant) GetChannelId ¶
func (*Grant) GetChannelNumber ¶
func (*Grant) GetDataCall ¶
func (*Grant) GetEmergency ¶
func (*Grant) GetEncrypted ¶
func (*Grant) GetFrequencyHz ¶
func (*Grant) GetGroupId ¶
func (*Grant) GetProtocol ¶
func (*Grant) GetSourceId ¶
func (*Grant) ProtoMessage ¶
func (*Grant) ProtoMessage()
func (*Grant) ProtoReflect ¶
func (x *Grant) ProtoReflect() protoreflect.Message
type ListActiveCallsRequest ¶
type ListActiveCallsRequest struct {
// contains filtered or unexported fields
}
func (*ListActiveCallsRequest) Descriptor
deprecated
func (*ListActiveCallsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListActiveCallsRequest.ProtoReflect.Descriptor instead.
func (*ListActiveCallsRequest) ProtoMessage ¶
func (*ListActiveCallsRequest) ProtoMessage()
func (*ListActiveCallsRequest) ProtoReflect ¶
func (x *ListActiveCallsRequest) ProtoReflect() protoreflect.Message
func (*ListActiveCallsRequest) Reset ¶
func (x *ListActiveCallsRequest) Reset()
func (*ListActiveCallsRequest) String ¶
func (x *ListActiveCallsRequest) String() string
type ListActiveCallsResponse ¶
type ListActiveCallsResponse struct {
Calls []*ActiveCall `protobuf:"bytes,1,rep,name=calls,proto3" json:"calls,omitempty"`
// contains filtered or unexported fields
}
func (*ListActiveCallsResponse) Descriptor
deprecated
func (*ListActiveCallsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListActiveCallsResponse.ProtoReflect.Descriptor instead.
func (*ListActiveCallsResponse) GetCalls ¶
func (x *ListActiveCallsResponse) GetCalls() []*ActiveCall
func (*ListActiveCallsResponse) ProtoMessage ¶
func (*ListActiveCallsResponse) ProtoMessage()
func (*ListActiveCallsResponse) ProtoReflect ¶
func (x *ListActiveCallsResponse) ProtoReflect() protoreflect.Message
func (*ListActiveCallsResponse) Reset ¶
func (x *ListActiveCallsResponse) Reset()
func (*ListActiveCallsResponse) String ¶
func (x *ListActiveCallsResponse) String() string
type ListSystemsRequest ¶
type ListSystemsRequest struct {
// contains filtered or unexported fields
}
func (*ListSystemsRequest) Descriptor
deprecated
func (*ListSystemsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListSystemsRequest.ProtoReflect.Descriptor instead.
func (*ListSystemsRequest) ProtoMessage ¶
func (*ListSystemsRequest) ProtoMessage()
func (*ListSystemsRequest) ProtoReflect ¶
func (x *ListSystemsRequest) ProtoReflect() protoreflect.Message
func (*ListSystemsRequest) Reset ¶
func (x *ListSystemsRequest) Reset()
func (*ListSystemsRequest) String ¶
func (x *ListSystemsRequest) String() string
type ListSystemsResponse ¶
type ListSystemsResponse struct {
Systems []*System `protobuf:"bytes,1,rep,name=systems,proto3" json:"systems,omitempty"`
// contains filtered or unexported fields
}
func (*ListSystemsResponse) Descriptor
deprecated
func (*ListSystemsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListSystemsResponse.ProtoReflect.Descriptor instead.
func (*ListSystemsResponse) GetSystems ¶
func (x *ListSystemsResponse) GetSystems() []*System
func (*ListSystemsResponse) ProtoMessage ¶
func (*ListSystemsResponse) ProtoMessage()
func (*ListSystemsResponse) ProtoReflect ¶
func (x *ListSystemsResponse) ProtoReflect() protoreflect.Message
func (*ListSystemsResponse) Reset ¶
func (x *ListSystemsResponse) Reset()
func (*ListSystemsResponse) String ¶
func (x *ListSystemsResponse) String() string
type ListTalkgroupsRequest ¶
type ListTalkgroupsRequest struct {
// Optional system filter; empty = all systems.
System string `protobuf:"bytes,1,opt,name=system,proto3" json:"system,omitempty"`
// contains filtered or unexported fields
}
func (*ListTalkgroupsRequest) Descriptor
deprecated
func (*ListTalkgroupsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListTalkgroupsRequest.ProtoReflect.Descriptor instead.
func (*ListTalkgroupsRequest) GetSystem ¶
func (x *ListTalkgroupsRequest) GetSystem() string
func (*ListTalkgroupsRequest) ProtoMessage ¶
func (*ListTalkgroupsRequest) ProtoMessage()
func (*ListTalkgroupsRequest) ProtoReflect ¶
func (x *ListTalkgroupsRequest) ProtoReflect() protoreflect.Message
func (*ListTalkgroupsRequest) Reset ¶
func (x *ListTalkgroupsRequest) Reset()
func (*ListTalkgroupsRequest) String ¶
func (x *ListTalkgroupsRequest) String() string
type ListTalkgroupsResponse ¶
type ListTalkgroupsResponse struct {
Talkgroups []*TalkGroup `protobuf:"bytes,1,rep,name=talkgroups,proto3" json:"talkgroups,omitempty"`
// contains filtered or unexported fields
}
func (*ListTalkgroupsResponse) Descriptor
deprecated
func (*ListTalkgroupsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListTalkgroupsResponse.ProtoReflect.Descriptor instead.
func (*ListTalkgroupsResponse) GetTalkgroups ¶
func (x *ListTalkgroupsResponse) GetTalkgroups() []*TalkGroup
func (*ListTalkgroupsResponse) ProtoMessage ¶
func (*ListTalkgroupsResponse) ProtoMessage()
func (*ListTalkgroupsResponse) ProtoReflect ¶
func (x *ListTalkgroupsResponse) ProtoReflect() protoreflect.Message
func (*ListTalkgroupsResponse) Reset ¶
func (x *ListTalkgroupsResponse) Reset()
func (*ListTalkgroupsResponse) String ¶
func (x *ListTalkgroupsResponse) String() string
type PCMSamples ¶
type PCMSamples struct {
SampleRate uint32 `protobuf:"varint,1,opt,name=sample_rate,json=sampleRate,proto3" json:"sample_rate,omitempty"` // typically 8000
// Little-endian 16-bit signed samples.
Samples []byte `protobuf:"bytes,2,opt,name=samples,proto3" json:"samples,omitempty"`
// contains filtered or unexported fields
}
func (*PCMSamples) Descriptor
deprecated
func (*PCMSamples) Descriptor() ([]byte, []int)
Deprecated: Use PCMSamples.ProtoReflect.Descriptor instead.
func (*PCMSamples) GetSampleRate ¶
func (x *PCMSamples) GetSampleRate() uint32
func (*PCMSamples) GetSamples ¶
func (x *PCMSamples) GetSamples() []byte
func (*PCMSamples) ProtoMessage ¶
func (*PCMSamples) ProtoMessage()
func (*PCMSamples) ProtoReflect ¶
func (x *PCMSamples) ProtoReflect() protoreflect.Message
func (*PCMSamples) Reset ¶
func (x *PCMSamples) Reset()
func (*PCMSamples) String ¶
func (x *PCMSamples) String() string
type RawVocoderFrame ¶
type RawVocoderFrame struct {
// Vocoder name as registered in the voice/Registry ("imbe", "ambe",
// ...). "" means unknown / passthrough.
Vocoder string `protobuf:"bytes,1,opt,name=vocoder,proto3" json:"vocoder,omitempty"`
Frame []byte `protobuf:"bytes,2,opt,name=frame,proto3" json:"frame,omitempty"`
// contains filtered or unexported fields
}
func (*RawVocoderFrame) Descriptor
deprecated
func (*RawVocoderFrame) Descriptor() ([]byte, []int)
Deprecated: Use RawVocoderFrame.ProtoReflect.Descriptor instead.
func (*RawVocoderFrame) GetFrame ¶
func (x *RawVocoderFrame) GetFrame() []byte
func (*RawVocoderFrame) GetVocoder ¶
func (x *RawVocoderFrame) GetVocoder() string
func (*RawVocoderFrame) ProtoMessage ¶
func (*RawVocoderFrame) ProtoMessage()
func (*RawVocoderFrame) ProtoReflect ¶
func (x *RawVocoderFrame) ProtoReflect() protoreflect.Message
func (*RawVocoderFrame) Reset ¶
func (x *RawVocoderFrame) Reset()
func (*RawVocoderFrame) String ¶
func (x *RawVocoderFrame) String() string
type SDRStatus ¶
type SDRStatus struct {
Driver string `protobuf:"bytes,1,opt,name=driver,proto3" json:"driver,omitempty"`
Serial string `protobuf:"bytes,2,opt,name=serial,proto3" json:"serial,omitempty"`
Role string `protobuf:"bytes,3,opt,name=role,proto3" json:"role,omitempty"` // "control" / "voice" / "auto"
Attached bool `protobuf:"varint,4,opt,name=attached,proto3" json:"attached,omitempty"`
// contains filtered or unexported fields
}
func (*SDRStatus) Descriptor
deprecated
func (*SDRStatus) GetAttached ¶
func (*SDRStatus) ProtoMessage ¶
func (*SDRStatus) ProtoMessage()
func (*SDRStatus) ProtoReflect ¶
func (x *SDRStatus) ProtoReflect() protoreflect.Message
type StreamAudioRequest ¶
type StreamAudioRequest struct {
// Optional filter: only emit frames for these device serials. Empty
// matches all.
DeviceSerials []string `protobuf:"bytes,1,rep,name=device_serials,json=deviceSerials,proto3" json:"device_serials,omitempty"`
// Optional filter: only emit frames for these talkgroup IDs.
TalkgroupIds []uint32 `protobuf:"varint,2,rep,packed,name=talkgroup_ids,json=talkgroupIds,proto3" json:"talkgroup_ids,omitempty"`
// If true, also stream raw vocoder bytes (defaults false; PCM only).
IncludeRaw bool `protobuf:"varint,3,opt,name=include_raw,json=includeRaw,proto3" json:"include_raw,omitempty"`
// contains filtered or unexported fields
}
func (*StreamAudioRequest) Descriptor
deprecated
func (*StreamAudioRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamAudioRequest.ProtoReflect.Descriptor instead.
func (*StreamAudioRequest) GetDeviceSerials ¶
func (x *StreamAudioRequest) GetDeviceSerials() []string
func (*StreamAudioRequest) GetIncludeRaw ¶
func (x *StreamAudioRequest) GetIncludeRaw() bool
func (*StreamAudioRequest) GetTalkgroupIds ¶
func (x *StreamAudioRequest) GetTalkgroupIds() []uint32
func (*StreamAudioRequest) ProtoMessage ¶
func (*StreamAudioRequest) ProtoMessage()
func (*StreamAudioRequest) ProtoReflect ¶
func (x *StreamAudioRequest) ProtoReflect() protoreflect.Message
func (*StreamAudioRequest) Reset ¶
func (x *StreamAudioRequest) Reset()
func (*StreamAudioRequest) String ¶
func (x *StreamAudioRequest) String() string
type System ¶
type System struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Protocol string `protobuf:"bytes,2,opt,name=protocol,proto3" json:"protocol,omitempty"` // "p25" / "dmr" / "nxdn"
ControlChannels []uint32 `protobuf:"varint,3,rep,packed,name=control_channels,json=controlChannels,proto3" json:"control_channels,omitempty"` // candidate frequencies in Hz
Wacn uint32 `protobuf:"varint,4,opt,name=wacn,proto3" json:"wacn,omitempty"` // 20-bit (P25)
SystemId uint32 `protobuf:"varint,5,opt,name=system_id,json=systemId,proto3" json:"system_id,omitempty"` // 12-bit
Rfss uint32 `protobuf:"varint,6,opt,name=rfss,proto3" json:"rfss,omitempty"`
Site uint32 `protobuf:"varint,7,opt,name=site,proto3" json:"site,omitempty"`
// contains filtered or unexported fields
}
System mirrors trunking.System.
func (*System) Descriptor
deprecated
func (*System) GetControlChannels ¶
func (*System) GetProtocol ¶
func (*System) GetSystemId ¶
func (*System) ProtoMessage ¶
func (*System) ProtoMessage()
func (*System) ProtoReflect ¶
func (x *System) ProtoReflect() protoreflect.Message
type SystemServiceClient ¶
type SystemServiceClient interface {
ListSystems(ctx context.Context, in *ListSystemsRequest, opts ...grpc.CallOption) (*ListSystemsResponse, error)
GetSystem(ctx context.Context, in *GetSystemRequest, opts ...grpc.CallOption) (*GetSystemResponse, error)
}
SystemServiceClient is the client API for SystemService 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.
SystemService exposes read-only access to the configured systems.
func NewSystemServiceClient ¶
func NewSystemServiceClient(cc grpc.ClientConnInterface) SystemServiceClient
type SystemServiceServer ¶
type SystemServiceServer interface {
ListSystems(context.Context, *ListSystemsRequest) (*ListSystemsResponse, error)
GetSystem(context.Context, *GetSystemRequest) (*GetSystemResponse, error)
// contains filtered or unexported methods
}
SystemServiceServer is the server API for SystemService service. All implementations must embed UnimplementedSystemServiceServer for forward compatibility.
SystemService exposes read-only access to the configured systems.
type TalkGroup ¶
type TalkGroup struct {
Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
AlphaTag string `protobuf:"bytes,2,opt,name=alpha_tag,json=alphaTag,proto3" json:"alpha_tag,omitempty"`
Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
Tag string `protobuf:"bytes,4,opt,name=tag,proto3" json:"tag,omitempty"`
Group string `protobuf:"bytes,5,opt,name=group,proto3" json:"group,omitempty"`
Mode string `protobuf:"bytes,6,opt,name=mode,proto3" json:"mode,omitempty"`
Priority int32 `protobuf:"varint,7,opt,name=priority,proto3" json:"priority,omitempty"`
Lockout bool `protobuf:"varint,8,opt,name=lockout,proto3" json:"lockout,omitempty"`
// contains filtered or unexported fields
}
TalkGroup mirrors trunking.TalkGroup. Used in CallStart/CallEnd envelopes and as the row type for ListTalkgroups responses.
func (*TalkGroup) Descriptor
deprecated
func (*TalkGroup) GetAlphaTag ¶
func (*TalkGroup) GetDescription ¶
func (*TalkGroup) GetLockout ¶
func (*TalkGroup) GetPriority ¶
func (*TalkGroup) ProtoMessage ¶
func (*TalkGroup) ProtoMessage()
func (*TalkGroup) ProtoReflect ¶
func (x *TalkGroup) ProtoReflect() protoreflect.Message
type TalkgroupServiceClient ¶
type TalkgroupServiceClient interface {
ListTalkgroups(ctx context.Context, in *ListTalkgroupsRequest, opts ...grpc.CallOption) (*ListTalkgroupsResponse, error)
GetTalkgroup(ctx context.Context, in *GetTalkgroupRequest, opts ...grpc.CallOption) (*GetTalkgroupResponse, error)
ListActiveCalls(ctx context.Context, in *ListActiveCallsRequest, opts ...grpc.CallOption) (*ListActiveCallsResponse, error)
}
TalkgroupServiceClient is the client API for TalkgroupService 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 NewTalkgroupServiceClient ¶
func NewTalkgroupServiceClient(cc grpc.ClientConnInterface) TalkgroupServiceClient
type TalkgroupServiceServer ¶
type TalkgroupServiceServer interface {
ListTalkgroups(context.Context, *ListTalkgroupsRequest) (*ListTalkgroupsResponse, error)
GetTalkgroup(context.Context, *GetTalkgroupRequest) (*GetTalkgroupResponse, error)
ListActiveCalls(context.Context, *ListActiveCallsRequest) (*ListActiveCallsResponse, error)
// contains filtered or unexported methods
}
TalkgroupServiceServer is the server API for TalkgroupService service. All implementations must embed UnimplementedTalkgroupServiceServer for forward compatibility.
type UnimplementedAudioServiceServer ¶
type UnimplementedAudioServiceServer struct{}
UnimplementedAudioServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedAudioServiceServer) StreamAudio ¶
func (UnimplementedAudioServiceServer) StreamAudio(*StreamAudioRequest, grpc.ServerStreamingServer[AudioFrame]) error
type UnimplementedSystemServiceServer ¶
type UnimplementedSystemServiceServer struct{}
UnimplementedSystemServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedSystemServiceServer) GetSystem ¶
func (UnimplementedSystemServiceServer) GetSystem(context.Context, *GetSystemRequest) (*GetSystemResponse, error)
func (UnimplementedSystemServiceServer) ListSystems ¶
func (UnimplementedSystemServiceServer) ListSystems(context.Context, *ListSystemsRequest) (*ListSystemsResponse, error)
type UnimplementedTalkgroupServiceServer ¶
type UnimplementedTalkgroupServiceServer struct{}
UnimplementedTalkgroupServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedTalkgroupServiceServer) GetTalkgroup ¶
func (UnimplementedTalkgroupServiceServer) GetTalkgroup(context.Context, *GetTalkgroupRequest) (*GetTalkgroupResponse, error)
func (UnimplementedTalkgroupServiceServer) ListActiveCalls ¶
func (UnimplementedTalkgroupServiceServer) ListActiveCalls(context.Context, *ListActiveCallsRequest) (*ListActiveCallsResponse, error)
func (UnimplementedTalkgroupServiceServer) ListTalkgroups ¶
func (UnimplementedTalkgroupServiceServer) ListTalkgroups(context.Context, *ListTalkgroupsRequest) (*ListTalkgroupsResponse, error)
type UnsafeAudioServiceServer ¶
type UnsafeAudioServiceServer interface {
// contains filtered or unexported methods
}
UnsafeAudioServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AudioServiceServer will result in compilation errors.
type UnsafeSystemServiceServer ¶
type UnsafeSystemServiceServer interface {
// contains filtered or unexported methods
}
UnsafeSystemServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SystemServiceServer will result in compilation errors.
type UnsafeTalkgroupServiceServer ¶
type UnsafeTalkgroupServiceServer interface {
// contains filtered or unexported methods
}
UnsafeTalkgroupServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TalkgroupServiceServer will result in compilation errors.