Documentation ¶
Index ¶
- Variables
- func RegisterAudioServiceServer(s *grpc.Server, srv AudioServiceServer)
- type Audio
- func (*Audio) Descriptor() ([]byte, []int)
- func (this *Audio) Equal(that interface{}) bool
- func (m *Audio) GetContent() []byte
- func (m *Audio) GetSource() string
- func (this *Audio) GoString() string
- func (m *Audio) Marshal() (dAtA []byte, err error)
- func (m *Audio) MarshalTo(dAtA []byte) (int, error)
- func (*Audio) ProtoMessage()
- func (m *Audio) Reset()
- func (m *Audio) Size() (n int)
- func (this *Audio) String() string
- func (m *Audio) Unmarshal(dAtA []byte) error
- func (m *Audio) XXX_DiscardUnknown()
- func (m *Audio) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Audio) XXX_Merge(src proto.Message)
- func (m *Audio) XXX_Size() int
- func (m *Audio) XXX_Unmarshal(b []byte) error
- type AudioServiceClient
- type AudioServiceServer
- type AudioService_StreamClient
- type AudioService_StreamServer
- type StreamRequest
- func (*StreamRequest) Descriptor() ([]byte, []int)
- func (this *StreamRequest) Equal(that interface{}) bool
- func (m *StreamRequest) GetAudio() *Audio
- func (this *StreamRequest) GoString() string
- func (m *StreamRequest) Marshal() (dAtA []byte, err error)
- func (m *StreamRequest) MarshalTo(dAtA []byte) (int, error)
- func (*StreamRequest) ProtoMessage()
- func (m *StreamRequest) Reset()
- func (m *StreamRequest) Size() (n int)
- func (this *StreamRequest) String() string
- func (m *StreamRequest) Unmarshal(dAtA []byte) error
- func (m *StreamRequest) XXX_DiscardUnknown()
- func (m *StreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamRequest) XXX_Merge(src proto.Message)
- func (m *StreamRequest) XXX_Size() int
- func (m *StreamRequest) XXX_Unmarshal(b []byte) error
- type StreamResponse
- func (*StreamResponse) Descriptor() ([]byte, []int)
- func (this *StreamResponse) Equal(that interface{}) bool
- func (m *StreamResponse) GetAudio() *Audio
- func (this *StreamResponse) GoString() string
- func (m *StreamResponse) Marshal() (dAtA []byte, err error)
- func (m *StreamResponse) MarshalTo(dAtA []byte) (int, error)
- func (*StreamResponse) ProtoMessage()
- func (m *StreamResponse) Reset()
- func (m *StreamResponse) Size() (n int)
- func (this *StreamResponse) String() string
- func (m *StreamResponse) Unmarshal(dAtA []byte) error
- func (m *StreamResponse) XXX_DiscardUnknown()
- func (m *StreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamResponse) XXX_Merge(src proto.Message)
- func (m *StreamResponse) XXX_Size() int
- func (m *StreamResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthAudio = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowAudio = fmt.Errorf("proto: integer overflow") )
Functions ¶
func RegisterAudioServiceServer ¶
func RegisterAudioServiceServer(s *grpc.Server, srv AudioServiceServer)
Types ¶
type Audio ¶
type Audio struct { // The source of the audio data, should be unique per client Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` // The chunk of audio data Content []byte `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"` }
Audio is the message containing audio data for reading/writing to/from the server
func (*Audio) Descriptor ¶
func (*Audio) GetContent ¶
func (*Audio) ProtoMessage ¶
func (*Audio) ProtoMessage()
func (*Audio) XXX_DiscardUnknown ¶
func (m *Audio) XXX_DiscardUnknown()
func (*Audio) XXX_Marshal ¶
func (*Audio) XXX_Unmarshal ¶
type AudioServiceClient ¶
type AudioServiceClient interface {
Stream(ctx context.Context, opts ...grpc.CallOption) (AudioService_StreamClient, error)
}
AudioServiceClient is the client API for AudioService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewAudioServiceClient ¶
func NewAudioServiceClient(cc *grpc.ClientConn) AudioServiceClient
type AudioServiceServer ¶
type AudioServiceServer interface {
Stream(AudioService_StreamServer) error
}
AudioServiceServer is the server API for AudioService service.
type AudioService_StreamClient ¶
type AudioService_StreamClient interface { Send(*StreamRequest) error Recv() (*StreamResponse, error) grpc.ClientStream }
type AudioService_StreamServer ¶
type AudioService_StreamServer interface { Send(*StreamResponse) error Recv() (*StreamRequest, error) grpc.ServerStream }
type StreamRequest ¶
type StreamRequest struct {
Audio *Audio `protobuf:"bytes,1,opt,name=audio,proto3" json:"audio,omitempty"`
}
func (*StreamRequest) Descriptor ¶
func (*StreamRequest) Descriptor() ([]byte, []int)
func (*StreamRequest) Equal ¶
func (this *StreamRequest) Equal(that interface{}) bool
func (*StreamRequest) GetAudio ¶
func (m *StreamRequest) GetAudio() *Audio
func (*StreamRequest) GoString ¶
func (this *StreamRequest) GoString() string
func (*StreamRequest) Marshal ¶
func (m *StreamRequest) Marshal() (dAtA []byte, err error)
func (*StreamRequest) ProtoMessage ¶
func (*StreamRequest) ProtoMessage()
func (*StreamRequest) Reset ¶
func (m *StreamRequest) Reset()
func (*StreamRequest) Size ¶
func (m *StreamRequest) Size() (n int)
func (*StreamRequest) String ¶
func (this *StreamRequest) String() string
func (*StreamRequest) Unmarshal ¶
func (m *StreamRequest) Unmarshal(dAtA []byte) error
func (*StreamRequest) XXX_DiscardUnknown ¶
func (m *StreamRequest) XXX_DiscardUnknown()
func (*StreamRequest) XXX_Marshal ¶
func (m *StreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamRequest) XXX_Merge ¶
func (m *StreamRequest) XXX_Merge(src proto.Message)
func (*StreamRequest) XXX_Size ¶
func (m *StreamRequest) XXX_Size() int
func (*StreamRequest) XXX_Unmarshal ¶
func (m *StreamRequest) XXX_Unmarshal(b []byte) error
type StreamResponse ¶
type StreamResponse struct {
Audio *Audio `protobuf:"bytes,1,opt,name=audio,proto3" json:"audio,omitempty"`
}
func (*StreamResponse) Descriptor ¶
func (*StreamResponse) Descriptor() ([]byte, []int)
func (*StreamResponse) Equal ¶
func (this *StreamResponse) Equal(that interface{}) bool
func (*StreamResponse) GetAudio ¶
func (m *StreamResponse) GetAudio() *Audio
func (*StreamResponse) GoString ¶
func (this *StreamResponse) GoString() string
func (*StreamResponse) Marshal ¶
func (m *StreamResponse) Marshal() (dAtA []byte, err error)
func (*StreamResponse) ProtoMessage ¶
func (*StreamResponse) ProtoMessage()
func (*StreamResponse) Reset ¶
func (m *StreamResponse) Reset()
func (*StreamResponse) Size ¶
func (m *StreamResponse) Size() (n int)
func (*StreamResponse) String ¶
func (this *StreamResponse) String() string
func (*StreamResponse) Unmarshal ¶
func (m *StreamResponse) Unmarshal(dAtA []byte) error
func (*StreamResponse) XXX_DiscardUnknown ¶
func (m *StreamResponse) XXX_DiscardUnknown()
func (*StreamResponse) XXX_Marshal ¶
func (m *StreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamResponse) XXX_Merge ¶
func (m *StreamResponse) XXX_Merge(src proto.Message)
func (*StreamResponse) XXX_Size ¶
func (m *StreamResponse) XXX_Size() int
func (*StreamResponse) XXX_Unmarshal ¶
func (m *StreamResponse) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.