Documentation ¶
Index ¶
- func RegisterDigitVideoRecorderServiceServer(s *grpc.Server, srv DigitVideoRecorderServiceServer)
- type DigitVideoRecorderServiceClient
- type DigitVideoRecorderServiceServer
- type GetRecordRequest
- func (*GetRecordRequest) Descriptor() ([]byte, []int)
- func (m *GetRecordRequest) GetRecord() *OpRecord
- func (*GetRecordRequest) ProtoMessage()
- func (m *GetRecordRequest) Reset()
- func (m *GetRecordRequest) String() string
- func (this *GetRecordRequest) Validate() error
- func (m *GetRecordRequest) XXX_DiscardUnknown()
- func (m *GetRecordRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetRecordRequest) XXX_Merge(src proto.Message)
- func (m *GetRecordRequest) XXX_Size() int
- func (m *GetRecordRequest) XXX_Unmarshal(b []byte) error
- type GetRecordResponse
- func (*GetRecordResponse) Descriptor() ([]byte, []int)
- func (m *GetRecordResponse) GetRecord() *Record
- func (*GetRecordResponse) ProtoMessage()
- func (m *GetRecordResponse) Reset()
- func (m *GetRecordResponse) String() string
- func (this *GetRecordResponse) Validate() error
- func (m *GetRecordResponse) XXX_DiscardUnknown()
- func (m *GetRecordResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetRecordResponse) XXX_Merge(src proto.Message)
- func (m *GetRecordResponse) XXX_Size() int
- func (m *GetRecordResponse) XXX_Unmarshal(b []byte) error
- type ListRecordsRequest
- func (*ListRecordsRequest) Descriptor() ([]byte, []int)
- func (m *ListRecordsRequest) GetFilter() isListRecordsRequest_Filter
- func (m *ListRecordsRequest) GetRange() *ListRecordsRequestRange_
- func (*ListRecordsRequest) ProtoMessage()
- func (m *ListRecordsRequest) Reset()
- func (m *ListRecordsRequest) String() string
- func (this *ListRecordsRequest) Validate() error
- func (m *ListRecordsRequest) XXX_DiscardUnknown()
- func (m *ListRecordsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListRecordsRequest) XXX_Merge(src proto.Message)
- func (*ListRecordsRequest) XXX_OneofWrappers() []interface{}
- func (m *ListRecordsRequest) XXX_Size() int
- func (m *ListRecordsRequest) XXX_Unmarshal(b []byte) error
- type ListRecordsRequestRange_
- func (*ListRecordsRequestRange_) Descriptor() ([]byte, []int)
- func (m *ListRecordsRequestRange_) GetEndAt() *timestamp.Timestamp
- func (m *ListRecordsRequestRange_) GetStartAt() *timestamp.Timestamp
- func (*ListRecordsRequestRange_) ProtoMessage()
- func (m *ListRecordsRequestRange_) Reset()
- func (m *ListRecordsRequestRange_) String() string
- func (this *ListRecordsRequestRange_) Validate() error
- func (m *ListRecordsRequestRange_) XXX_DiscardUnknown()
- func (m *ListRecordsRequestRange_) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListRecordsRequestRange_) XXX_Merge(src proto.Message)
- func (m *ListRecordsRequestRange_) XXX_Size() int
- func (m *ListRecordsRequestRange_) XXX_Unmarshal(b []byte) error
- type ListRecordsRequest_Range
- type ListRecordsResponse
- func (*ListRecordsResponse) Descriptor() ([]byte, []int)
- func (m *ListRecordsResponse) GetRecords() []*Record
- func (*ListRecordsResponse) ProtoMessage()
- func (m *ListRecordsResponse) Reset()
- func (m *ListRecordsResponse) String() string
- func (this *ListRecordsResponse) Validate() error
- func (m *ListRecordsResponse) XXX_DiscardUnknown()
- func (m *ListRecordsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListRecordsResponse) XXX_Merge(src proto.Message)
- func (m *ListRecordsResponse) XXX_Size() int
- func (m *ListRecordsResponse) XXX_Unmarshal(b []byte) error
- type OpRecord
- func (*OpRecord) Descriptor() ([]byte, []int)
- func (m *OpRecord) GetEndAt() *timestamp.Timestamp
- func (m *OpRecord) GetId() *wrappers.StringValue
- func (m *OpRecord) GetStartAt() *timestamp.Timestamp
- func (*OpRecord) ProtoMessage()
- func (m *OpRecord) Reset()
- func (m *OpRecord) String() string
- func (this *OpRecord) Validate() error
- func (m *OpRecord) XXX_DiscardUnknown()
- func (m *OpRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OpRecord) XXX_Merge(src proto.Message)
- func (m *OpRecord) XXX_Size() int
- func (m *OpRecord) XXX_Unmarshal(b []byte) error
- type Record
- func (*Record) Descriptor() ([]byte, []int)
- func (m *Record) GetEndAt() *timestamp.Timestamp
- func (m *Record) GetId() string
- func (m *Record) GetStartAt() *timestamp.Timestamp
- func (*Record) ProtoMessage()
- func (m *Record) Reset()
- func (m *Record) String() string
- func (this *Record) Validate() error
- func (m *Record) XXX_DiscardUnknown()
- func (m *Record) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Record) XXX_Merge(src proto.Message)
- func (m *Record) XXX_Size() int
- func (m *Record) XXX_Unmarshal(b []byte) error
- type UnimplementedDigitVideoRecorderServiceServer
- func (*UnimplementedDigitVideoRecorderServiceServer) GetRecord(ctx context.Context, req *GetRecordRequest) (*GetRecordResponse, error)
- func (*UnimplementedDigitVideoRecorderServiceServer) ListRecords(ctx context.Context, req *ListRecordsRequest) (*ListRecordsResponse, error)
- func (*UnimplementedDigitVideoRecorderServiceServer) Start(ctx context.Context, req *empty.Empty) (*empty.Empty, error)
- func (*UnimplementedDigitVideoRecorderServiceServer) Stop(ctx context.Context, req *empty.Empty) (*empty.Empty, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterDigitVideoRecorderServiceServer ¶
func RegisterDigitVideoRecorderServiceServer(s *grpc.Server, srv DigitVideoRecorderServiceServer)
Types ¶
type DigitVideoRecorderServiceClient ¶
type DigitVideoRecorderServiceClient interface { Start(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error) Stop(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error) GetRecord(ctx context.Context, in *GetRecordRequest, opts ...grpc.CallOption) (*GetRecordResponse, error) ListRecords(ctx context.Context, in *ListRecordsRequest, opts ...grpc.CallOption) (*ListRecordsResponse, error) }
DigitVideoRecorderServiceClient is the client API for DigitVideoRecorderService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewDigitVideoRecorderServiceClient ¶
func NewDigitVideoRecorderServiceClient(cc *grpc.ClientConn) DigitVideoRecorderServiceClient
type DigitVideoRecorderServiceServer ¶
type DigitVideoRecorderServiceServer interface { Start(context.Context, *empty.Empty) (*empty.Empty, error) Stop(context.Context, *empty.Empty) (*empty.Empty, error) GetRecord(context.Context, *GetRecordRequest) (*GetRecordResponse, error) ListRecords(context.Context, *ListRecordsRequest) (*ListRecordsResponse, error) }
DigitVideoRecorderServiceServer is the server API for DigitVideoRecorderService service.
type GetRecordRequest ¶
type GetRecordRequest struct { Record *OpRecord `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetRecordRequest) Descriptor ¶
func (*GetRecordRequest) Descriptor() ([]byte, []int)
func (*GetRecordRequest) GetRecord ¶
func (m *GetRecordRequest) GetRecord() *OpRecord
func (*GetRecordRequest) ProtoMessage ¶
func (*GetRecordRequest) ProtoMessage()
func (*GetRecordRequest) Reset ¶
func (m *GetRecordRequest) Reset()
func (*GetRecordRequest) String ¶
func (m *GetRecordRequest) String() string
func (*GetRecordRequest) Validate ¶
func (this *GetRecordRequest) Validate() error
func (*GetRecordRequest) XXX_DiscardUnknown ¶
func (m *GetRecordRequest) XXX_DiscardUnknown()
func (*GetRecordRequest) XXX_Marshal ¶
func (m *GetRecordRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetRecordRequest) XXX_Merge ¶
func (m *GetRecordRequest) XXX_Merge(src proto.Message)
func (*GetRecordRequest) XXX_Size ¶
func (m *GetRecordRequest) XXX_Size() int
func (*GetRecordRequest) XXX_Unmarshal ¶
func (m *GetRecordRequest) XXX_Unmarshal(b []byte) error
type GetRecordResponse ¶
type GetRecordResponse struct { Record *Record `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetRecordResponse) Descriptor ¶
func (*GetRecordResponse) Descriptor() ([]byte, []int)
func (*GetRecordResponse) GetRecord ¶
func (m *GetRecordResponse) GetRecord() *Record
func (*GetRecordResponse) ProtoMessage ¶
func (*GetRecordResponse) ProtoMessage()
func (*GetRecordResponse) Reset ¶
func (m *GetRecordResponse) Reset()
func (*GetRecordResponse) String ¶
func (m *GetRecordResponse) String() string
func (*GetRecordResponse) Validate ¶
func (this *GetRecordResponse) Validate() error
func (*GetRecordResponse) XXX_DiscardUnknown ¶
func (m *GetRecordResponse) XXX_DiscardUnknown()
func (*GetRecordResponse) XXX_Marshal ¶
func (m *GetRecordResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetRecordResponse) XXX_Merge ¶
func (m *GetRecordResponse) XXX_Merge(src proto.Message)
func (*GetRecordResponse) XXX_Size ¶
func (m *GetRecordResponse) XXX_Size() int
func (*GetRecordResponse) XXX_Unmarshal ¶
func (m *GetRecordResponse) XXX_Unmarshal(b []byte) error
type ListRecordsRequest ¶
type ListRecordsRequest struct { // Types that are valid to be assigned to Filter: // *ListRecordsRequest_Range Filter isListRecordsRequest_Filter `protobuf_oneof:"filter"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListRecordsRequest) Descriptor ¶
func (*ListRecordsRequest) Descriptor() ([]byte, []int)
func (*ListRecordsRequest) GetFilter ¶
func (m *ListRecordsRequest) GetFilter() isListRecordsRequest_Filter
func (*ListRecordsRequest) GetRange ¶
func (m *ListRecordsRequest) GetRange() *ListRecordsRequestRange_
func (*ListRecordsRequest) ProtoMessage ¶
func (*ListRecordsRequest) ProtoMessage()
func (*ListRecordsRequest) Reset ¶
func (m *ListRecordsRequest) Reset()
func (*ListRecordsRequest) String ¶
func (m *ListRecordsRequest) String() string
func (*ListRecordsRequest) Validate ¶
func (this *ListRecordsRequest) Validate() error
func (*ListRecordsRequest) XXX_DiscardUnknown ¶
func (m *ListRecordsRequest) XXX_DiscardUnknown()
func (*ListRecordsRequest) XXX_Marshal ¶
func (m *ListRecordsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListRecordsRequest) XXX_Merge ¶
func (m *ListRecordsRequest) XXX_Merge(src proto.Message)
func (*ListRecordsRequest) XXX_OneofWrappers ¶
func (*ListRecordsRequest) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*ListRecordsRequest) XXX_Size ¶
func (m *ListRecordsRequest) XXX_Size() int
func (*ListRecordsRequest) XXX_Unmarshal ¶
func (m *ListRecordsRequest) XXX_Unmarshal(b []byte) error
type ListRecordsRequestRange_ ¶
type ListRecordsRequestRange_ struct { StartAt *timestamp.Timestamp `protobuf:"bytes,1,opt,name=start_at,json=startAt,proto3" json:"start_at,omitempty"` EndAt *timestamp.Timestamp `protobuf:"bytes,2,opt,name=end_at,json=endAt,proto3" json:"end_at,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListRecordsRequestRange_) Descriptor ¶
func (*ListRecordsRequestRange_) Descriptor() ([]byte, []int)
func (*ListRecordsRequestRange_) GetEndAt ¶
func (m *ListRecordsRequestRange_) GetEndAt() *timestamp.Timestamp
func (*ListRecordsRequestRange_) GetStartAt ¶
func (m *ListRecordsRequestRange_) GetStartAt() *timestamp.Timestamp
func (*ListRecordsRequestRange_) ProtoMessage ¶
func (*ListRecordsRequestRange_) ProtoMessage()
func (*ListRecordsRequestRange_) Reset ¶
func (m *ListRecordsRequestRange_) Reset()
func (*ListRecordsRequestRange_) String ¶
func (m *ListRecordsRequestRange_) String() string
func (*ListRecordsRequestRange_) Validate ¶
func (this *ListRecordsRequestRange_) Validate() error
func (*ListRecordsRequestRange_) XXX_DiscardUnknown ¶
func (m *ListRecordsRequestRange_) XXX_DiscardUnknown()
func (*ListRecordsRequestRange_) XXX_Marshal ¶
func (m *ListRecordsRequestRange_) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListRecordsRequestRange_) XXX_Merge ¶
func (m *ListRecordsRequestRange_) XXX_Merge(src proto.Message)
func (*ListRecordsRequestRange_) XXX_Size ¶
func (m *ListRecordsRequestRange_) XXX_Size() int
func (*ListRecordsRequestRange_) XXX_Unmarshal ¶
func (m *ListRecordsRequestRange_) XXX_Unmarshal(b []byte) error
type ListRecordsRequest_Range ¶
type ListRecordsRequest_Range struct {
Range *ListRecordsRequestRange_ `protobuf:"bytes,1,opt,name=range,proto3,oneof"`
}
type ListRecordsResponse ¶
type ListRecordsResponse struct { Records []*Record `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListRecordsResponse) Descriptor ¶
func (*ListRecordsResponse) Descriptor() ([]byte, []int)
func (*ListRecordsResponse) GetRecords ¶
func (m *ListRecordsResponse) GetRecords() []*Record
func (*ListRecordsResponse) ProtoMessage ¶
func (*ListRecordsResponse) ProtoMessage()
func (*ListRecordsResponse) Reset ¶
func (m *ListRecordsResponse) Reset()
func (*ListRecordsResponse) String ¶
func (m *ListRecordsResponse) String() string
func (*ListRecordsResponse) Validate ¶
func (this *ListRecordsResponse) Validate() error
func (*ListRecordsResponse) XXX_DiscardUnknown ¶
func (m *ListRecordsResponse) XXX_DiscardUnknown()
func (*ListRecordsResponse) XXX_Marshal ¶
func (m *ListRecordsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListRecordsResponse) XXX_Merge ¶
func (m *ListRecordsResponse) XXX_Merge(src proto.Message)
func (*ListRecordsResponse) XXX_Size ¶
func (m *ListRecordsResponse) XXX_Size() int
func (*ListRecordsResponse) XXX_Unmarshal ¶
func (m *ListRecordsResponse) XXX_Unmarshal(b []byte) error
type OpRecord ¶
type OpRecord struct { Id *wrappers.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` StartAt *timestamp.Timestamp `protobuf:"bytes,2,opt,name=start_at,json=startAt,proto3" json:"start_at,omitempty"` EndAt *timestamp.Timestamp `protobuf:"bytes,3,opt,name=end_at,json=endAt,proto3" json:"end_at,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*OpRecord) Descriptor ¶
func (*OpRecord) GetId ¶
func (m *OpRecord) GetId() *wrappers.StringValue
func (*OpRecord) GetStartAt ¶
func (*OpRecord) ProtoMessage ¶
func (*OpRecord) ProtoMessage()
func (*OpRecord) XXX_DiscardUnknown ¶
func (m *OpRecord) XXX_DiscardUnknown()
func (*OpRecord) XXX_Marshal ¶
func (*OpRecord) XXX_Unmarshal ¶
type Record ¶
type Record struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` StartAt *timestamp.Timestamp `protobuf:"bytes,2,opt,name=start_at,json=startAt,proto3" json:"start_at,omitempty"` EndAt *timestamp.Timestamp `protobuf:"bytes,3,opt,name=end_at,json=endAt,proto3" json:"end_at,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Record) Descriptor ¶
func (*Record) GetStartAt ¶
func (*Record) ProtoMessage ¶
func (*Record) ProtoMessage()
func (*Record) XXX_DiscardUnknown ¶
func (m *Record) XXX_DiscardUnknown()
func (*Record) XXX_Marshal ¶
func (*Record) XXX_Unmarshal ¶
type UnimplementedDigitVideoRecorderServiceServer ¶
type UnimplementedDigitVideoRecorderServiceServer struct { }
UnimplementedDigitVideoRecorderServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedDigitVideoRecorderServiceServer) GetRecord ¶
func (*UnimplementedDigitVideoRecorderServiceServer) GetRecord(ctx context.Context, req *GetRecordRequest) (*GetRecordResponse, error)
func (*UnimplementedDigitVideoRecorderServiceServer) ListRecords ¶
func (*UnimplementedDigitVideoRecorderServiceServer) ListRecords(ctx context.Context, req *ListRecordsRequest) (*ListRecordsResponse, error)
Click to show internal directories.
Click to hide internal directories.