Documentation
¶
Overview ¶
Package net is a generated GoMock package.
Index ¶
- Variables
- func RegisterOrchestratorServer(s *grpc.Server, srv OrchestratorServer)
- func RegisterTicketRedeemerServer(s *grpc.Server, srv TicketRedeemerServer)
- func RegisterTranscoderServer(s *grpc.Server, srv TranscoderServer)
- type AuthToken
- func (*AuthToken) Descriptor() ([]byte, []int)
- func (m *AuthToken) GetExpiration() int64
- func (m *AuthToken) GetSessionId() string
- func (m *AuthToken) GetToken() []byte
- func (*AuthToken) ProtoMessage()
- func (m *AuthToken) Reset()
- func (m *AuthToken) String() string
- func (m *AuthToken) XXX_DiscardUnknown()
- func (m *AuthToken) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AuthToken) XXX_Merge(src proto.Message)
- func (m *AuthToken) XXX_Size() int
- func (m *AuthToken) XXX_Unmarshal(b []byte) error
- type Capabilities
- func (*Capabilities) Descriptor() ([]byte, []int)
- func (m *Capabilities) GetBitstring() []uint64
- func (m *Capabilities) GetMandatories() []uint64
- func (*Capabilities) ProtoMessage()
- func (m *Capabilities) Reset()
- func (m *Capabilities) String() string
- func (m *Capabilities) XXX_DiscardUnknown()
- func (m *Capabilities) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Capabilities) XXX_Merge(src proto.Message)
- func (m *Capabilities) XXX_Size() int
- func (m *Capabilities) XXX_Unmarshal(b []byte) error
- type Capabilities_Constraints
- func (*Capabilities_Constraints) Descriptor() ([]byte, []int)
- func (*Capabilities_Constraints) ProtoMessage()
- func (m *Capabilities_Constraints) Reset()
- func (m *Capabilities_Constraints) String() string
- func (m *Capabilities_Constraints) XXX_DiscardUnknown()
- func (m *Capabilities_Constraints) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Capabilities_Constraints) XXX_Merge(src proto.Message)
- func (m *Capabilities_Constraints) XXX_Size() int
- func (m *Capabilities_Constraints) XXX_Unmarshal(b []byte) error
- type DetectData
- func (*DetectData) Descriptor() ([]byte, []int)
- func (m *DetectData) GetSceneClassification() *SceneClassificationData
- func (m *DetectData) GetValue() isDetectData_Value
- func (*DetectData) ProtoMessage()
- func (m *DetectData) Reset()
- func (m *DetectData) String() string
- func (m *DetectData) XXX_DiscardUnknown()
- func (m *DetectData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DetectData) XXX_Merge(src proto.Message)
- func (*DetectData) XXX_OneofWrappers() []interface{}
- func (m *DetectData) XXX_Size() int
- func (m *DetectData) XXX_Unmarshal(b []byte) error
- type DetectData_SceneClassification
- type DetectorClass
- func (*DetectorClass) Descriptor() ([]byte, []int)
- func (m *DetectorClass) GetClassId() uint32
- func (m *DetectorClass) GetClassName() string
- func (*DetectorClass) ProtoMessage()
- func (m *DetectorClass) Reset()
- func (m *DetectorClass) String() string
- func (m *DetectorClass) XXX_DiscardUnknown()
- func (m *DetectorClass) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DetectorClass) XXX_Merge(src proto.Message)
- func (m *DetectorClass) XXX_Size() int
- func (m *DetectorClass) XXX_Unmarshal(b []byte) error
- type DetectorProfile
- func (*DetectorProfile) Descriptor() ([]byte, []int)
- func (m *DetectorProfile) GetSceneClassification() *SceneClassificationProfile
- func (m *DetectorProfile) GetValue() isDetectorProfile_Value
- func (*DetectorProfile) ProtoMessage()
- func (m *DetectorProfile) Reset()
- func (m *DetectorProfile) String() string
- func (m *DetectorProfile) XXX_DiscardUnknown()
- func (m *DetectorProfile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DetectorProfile) XXX_Merge(src proto.Message)
- func (*DetectorProfile) XXX_OneofWrappers() []interface{}
- func (m *DetectorProfile) XXX_Size() int
- func (m *DetectorProfile) XXX_Unmarshal(b []byte) error
- type DetectorProfile_SceneClassification
- type MaxFloatReq
- func (*MaxFloatReq) Descriptor() ([]byte, []int)
- func (m *MaxFloatReq) GetSender() []byte
- func (*MaxFloatReq) ProtoMessage()
- func (m *MaxFloatReq) Reset()
- func (m *MaxFloatReq) String() string
- func (m *MaxFloatReq) XXX_DiscardUnknown()
- func (m *MaxFloatReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MaxFloatReq) XXX_Merge(src proto.Message)
- func (m *MaxFloatReq) XXX_Size() int
- func (m *MaxFloatReq) XXX_Unmarshal(b []byte) error
- type MaxFloatUpdate
- func (*MaxFloatUpdate) Descriptor() ([]byte, []int)
- func (m *MaxFloatUpdate) GetMaxFloat() []byte
- func (*MaxFloatUpdate) ProtoMessage()
- func (m *MaxFloatUpdate) Reset()
- func (m *MaxFloatUpdate) String() string
- func (m *MaxFloatUpdate) XXX_DiscardUnknown()
- func (m *MaxFloatUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MaxFloatUpdate) XXX_Merge(src proto.Message)
- func (m *MaxFloatUpdate) XXX_Size() int
- func (m *MaxFloatUpdate) XXX_Unmarshal(b []byte) error
- type MockTicketRedeemerClient
- func (m *MockTicketRedeemerClient) EXPECT() *MockTicketRedeemerClientMockRecorder
- func (m *MockTicketRedeemerClient) MaxFloat(ctx context.Context, in *MaxFloatReq, opts ...grpc.CallOption) (*MaxFloatUpdate, error)
- func (m *MockTicketRedeemerClient) MonitorMaxFloat(ctx context.Context, in *MaxFloatReq, opts ...grpc.CallOption) (TicketRedeemer_MonitorMaxFloatClient, error)
- func (m *MockTicketRedeemerClient) QueueTicket(ctx context.Context, in *Ticket, opts ...grpc.CallOption) (*QueueTicketRes, error)
- type MockTicketRedeemerClientMockRecorder
- func (mr *MockTicketRedeemerClientMockRecorder) MaxFloat(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockTicketRedeemerClientMockRecorder) MonitorMaxFloat(ctx, in interface{}, opts ...interface{}) *gomock.Call
- func (mr *MockTicketRedeemerClientMockRecorder) QueueTicket(ctx, in interface{}, opts ...interface{}) *gomock.Call
- type MockTicketRedeemerServer
- func (m *MockTicketRedeemerServer) EXPECT() *MockTicketRedeemerServerMockRecorder
- func (m *MockTicketRedeemerServer) MaxFloat(arg0 context.Context, arg1 *MaxFloatReq) (*MaxFloatUpdate, error)
- func (m *MockTicketRedeemerServer) MonitorMaxFloat(arg0 *MaxFloatReq, arg1 TicketRedeemer_MonitorMaxFloatServer) error
- func (m *MockTicketRedeemerServer) QueueTicket(arg0 context.Context, arg1 *Ticket) (*QueueTicketRes, error)
- type MockTicketRedeemerServerMockRecorder
- type MockTicketRedeemer_MonitorMaxFloatClient
- func (m *MockTicketRedeemer_MonitorMaxFloatClient) CloseSend() error
- func (m *MockTicketRedeemer_MonitorMaxFloatClient) Context() context.Context
- func (m *MockTicketRedeemer_MonitorMaxFloatClient) EXPECT() *MockTicketRedeemer_MonitorMaxFloatClientMockRecorder
- func (m *MockTicketRedeemer_MonitorMaxFloatClient) Header() (metadata.MD, error)
- func (m *MockTicketRedeemer_MonitorMaxFloatClient) Recv() (*MaxFloatUpdate, error)
- func (m_2 *MockTicketRedeemer_MonitorMaxFloatClient) RecvMsg(m interface{}) error
- func (m_2 *MockTicketRedeemer_MonitorMaxFloatClient) SendMsg(m interface{}) error
- func (m *MockTicketRedeemer_MonitorMaxFloatClient) Trailer() metadata.MD
- type MockTicketRedeemer_MonitorMaxFloatClientMockRecorder
- func (mr *MockTicketRedeemer_MonitorMaxFloatClientMockRecorder) CloseSend() *gomock.Call
- func (mr *MockTicketRedeemer_MonitorMaxFloatClientMockRecorder) Context() *gomock.Call
- func (mr *MockTicketRedeemer_MonitorMaxFloatClientMockRecorder) Header() *gomock.Call
- func (mr *MockTicketRedeemer_MonitorMaxFloatClientMockRecorder) Recv() *gomock.Call
- func (mr *MockTicketRedeemer_MonitorMaxFloatClientMockRecorder) RecvMsg(m interface{}) *gomock.Call
- func (mr *MockTicketRedeemer_MonitorMaxFloatClientMockRecorder) SendMsg(m interface{}) *gomock.Call
- func (mr *MockTicketRedeemer_MonitorMaxFloatClientMockRecorder) Trailer() *gomock.Call
- type MockTicketRedeemer_MonitorMaxFloatServer
- func (m *MockTicketRedeemer_MonitorMaxFloatServer) Context() context.Context
- func (m *MockTicketRedeemer_MonitorMaxFloatServer) EXPECT() *MockTicketRedeemer_MonitorMaxFloatServerMockRecorder
- func (m_2 *MockTicketRedeemer_MonitorMaxFloatServer) RecvMsg(m interface{}) error
- func (m *MockTicketRedeemer_MonitorMaxFloatServer) Send(arg0 *MaxFloatUpdate) error
- func (m *MockTicketRedeemer_MonitorMaxFloatServer) SendHeader(arg0 metadata.MD) error
- func (m_2 *MockTicketRedeemer_MonitorMaxFloatServer) SendMsg(m interface{}) error
- func (m *MockTicketRedeemer_MonitorMaxFloatServer) SetHeader(arg0 metadata.MD) error
- func (m *MockTicketRedeemer_MonitorMaxFloatServer) SetTrailer(arg0 metadata.MD)
- type MockTicketRedeemer_MonitorMaxFloatServerMockRecorder
- func (mr *MockTicketRedeemer_MonitorMaxFloatServerMockRecorder) Context() *gomock.Call
- func (mr *MockTicketRedeemer_MonitorMaxFloatServerMockRecorder) RecvMsg(m interface{}) *gomock.Call
- func (mr *MockTicketRedeemer_MonitorMaxFloatServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockTicketRedeemer_MonitorMaxFloatServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockTicketRedeemer_MonitorMaxFloatServerMockRecorder) SendMsg(m interface{}) *gomock.Call
- func (mr *MockTicketRedeemer_MonitorMaxFloatServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockTicketRedeemer_MonitorMaxFloatServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type NodeStatus
- type NotifySegment
- func (*NotifySegment) Descriptor() ([]byte, []int)
- func (m *NotifySegment) GetProfiles() []byte
- func (m *NotifySegment) GetSegData() *SegData
- func (m *NotifySegment) GetTaskId() int64
- func (m *NotifySegment) GetUrl() string
- func (*NotifySegment) ProtoMessage()
- func (m *NotifySegment) Reset()
- func (m *NotifySegment) String() string
- func (m *NotifySegment) XXX_DiscardUnknown()
- func (m *NotifySegment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NotifySegment) XXX_Merge(src proto.Message)
- func (m *NotifySegment) XXX_Size() int
- func (m *NotifySegment) XXX_Unmarshal(b []byte) error
- type OSInfo
- func (*OSInfo) Descriptor() ([]byte, []int)
- func (m *OSInfo) GetS3Info() *S3OSInfo
- func (m *OSInfo) GetStorageType() OSInfo_StorageType
- func (*OSInfo) ProtoMessage()
- func (m *OSInfo) Reset()
- func (m *OSInfo) String() string
- func (m *OSInfo) XXX_DiscardUnknown()
- func (m *OSInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OSInfo) XXX_Merge(src proto.Message)
- func (m *OSInfo) XXX_Size() int
- func (m *OSInfo) XXX_Unmarshal(b []byte) error
- type OSInfo_StorageType
- type OrchestratorClient
- type OrchestratorInfo
- func (*OrchestratorInfo) Descriptor() ([]byte, []int)
- func (m *OrchestratorInfo) GetAddress() []byte
- func (m *OrchestratorInfo) GetAuthToken() *AuthToken
- func (m *OrchestratorInfo) GetCapabilities() *Capabilities
- func (m *OrchestratorInfo) GetPriceInfo() *PriceInfo
- func (m *OrchestratorInfo) GetStorage() []*OSInfo
- func (m *OrchestratorInfo) GetTicketParams() *TicketParams
- func (m *OrchestratorInfo) GetTranscoder() string
- func (*OrchestratorInfo) ProtoMessage()
- func (m *OrchestratorInfo) Reset()
- func (m *OrchestratorInfo) String() string
- func (m *OrchestratorInfo) XXX_DiscardUnknown()
- func (m *OrchestratorInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OrchestratorInfo) XXX_Merge(src proto.Message)
- func (m *OrchestratorInfo) XXX_Size() int
- func (m *OrchestratorInfo) XXX_Unmarshal(b []byte) error
- type OrchestratorRequest
- func (*OrchestratorRequest) Descriptor() ([]byte, []int)
- func (m *OrchestratorRequest) GetAddress() []byte
- func (m *OrchestratorRequest) GetSig() []byte
- func (*OrchestratorRequest) ProtoMessage()
- func (m *OrchestratorRequest) Reset()
- func (m *OrchestratorRequest) String() string
- func (m *OrchestratorRequest) XXX_DiscardUnknown()
- func (m *OrchestratorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OrchestratorRequest) XXX_Merge(src proto.Message)
- func (m *OrchestratorRequest) XXX_Size() int
- func (m *OrchestratorRequest) XXX_Unmarshal(b []byte) error
- type OrchestratorServer
- type Payment
- func (*Payment) Descriptor() ([]byte, []int)
- func (m *Payment) GetExpectedPrice() *PriceInfo
- func (m *Payment) GetExpirationParams() *TicketExpirationParams
- func (m *Payment) GetSender() []byte
- func (m *Payment) GetTicketParams() *TicketParams
- func (m *Payment) GetTicketSenderParams() []*TicketSenderParams
- func (*Payment) ProtoMessage()
- func (m *Payment) Reset()
- func (m *Payment) String() string
- func (m *Payment) XXX_DiscardUnknown()
- func (m *Payment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Payment) XXX_Merge(src proto.Message)
- func (m *Payment) XXX_Size() int
- func (m *Payment) XXX_Unmarshal(b []byte) error
- type PingPong
- func (*PingPong) Descriptor() ([]byte, []int)
- func (m *PingPong) GetValue() []byte
- func (*PingPong) ProtoMessage()
- func (m *PingPong) Reset()
- func (m *PingPong) String() string
- func (m *PingPong) XXX_DiscardUnknown()
- func (m *PingPong) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PingPong) XXX_Merge(src proto.Message)
- func (m *PingPong) XXX_Size() int
- func (m *PingPong) XXX_Unmarshal(b []byte) error
- type PriceInfo
- func (*PriceInfo) Descriptor() ([]byte, []int)
- func (m *PriceInfo) GetPixelsPerUnit() int64
- func (m *PriceInfo) GetPricePerUnit() int64
- func (*PriceInfo) ProtoMessage()
- func (m *PriceInfo) Reset()
- func (m *PriceInfo) String() string
- func (m *PriceInfo) XXX_DiscardUnknown()
- func (m *PriceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PriceInfo) XXX_Merge(src proto.Message)
- func (m *PriceInfo) XXX_Size() int
- func (m *PriceInfo) XXX_Unmarshal(b []byte) error
- type QueueTicketRes
- func (*QueueTicketRes) Descriptor() ([]byte, []int)
- func (*QueueTicketRes) ProtoMessage()
- func (m *QueueTicketRes) Reset()
- func (m *QueueTicketRes) String() string
- func (m *QueueTicketRes) XXX_DiscardUnknown()
- func (m *QueueTicketRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueueTicketRes) XXX_Merge(src proto.Message)
- func (m *QueueTicketRes) XXX_Size() int
- func (m *QueueTicketRes) XXX_Unmarshal(b []byte) error
- type RegisterRequest
- func (*RegisterRequest) Descriptor() ([]byte, []int)
- func (m *RegisterRequest) GetCapacity() int64
- func (m *RegisterRequest) GetSecret() string
- func (*RegisterRequest) ProtoMessage()
- func (m *RegisterRequest) Reset()
- func (m *RegisterRequest) String() string
- func (m *RegisterRequest) XXX_DiscardUnknown()
- func (m *RegisterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RegisterRequest) XXX_Merge(src proto.Message)
- func (m *RegisterRequest) XXX_Size() int
- func (m *RegisterRequest) XXX_Unmarshal(b []byte) error
- type RemoteTranscoderInfo
- type S3OSInfo
- func (*S3OSInfo) Descriptor() ([]byte, []int)
- func (m *S3OSInfo) GetCredential() string
- func (m *S3OSInfo) GetHost() string
- func (m *S3OSInfo) GetKey() string
- func (m *S3OSInfo) GetPolicy() string
- func (m *S3OSInfo) GetSignature() string
- func (m *S3OSInfo) GetXAmzDate() string
- func (*S3OSInfo) ProtoMessage()
- func (m *S3OSInfo) Reset()
- func (m *S3OSInfo) String() string
- func (m *S3OSInfo) XXX_DiscardUnknown()
- func (m *S3OSInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *S3OSInfo) XXX_Merge(src proto.Message)
- func (m *S3OSInfo) XXX_Size() int
- func (m *S3OSInfo) XXX_Unmarshal(b []byte) error
- type SceneClassificationData
- func (*SceneClassificationData) Descriptor() ([]byte, []int)
- func (m *SceneClassificationData) GetClassProbs() map[uint32]float64
- func (*SceneClassificationData) ProtoMessage()
- func (m *SceneClassificationData) Reset()
- func (m *SceneClassificationData) String() string
- func (m *SceneClassificationData) XXX_DiscardUnknown()
- func (m *SceneClassificationData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SceneClassificationData) XXX_Merge(src proto.Message)
- func (m *SceneClassificationData) XXX_Size() int
- func (m *SceneClassificationData) XXX_Unmarshal(b []byte) error
- type SceneClassificationProfile
- func (*SceneClassificationProfile) Descriptor() ([]byte, []int)
- func (m *SceneClassificationProfile) GetClasses() []*DetectorClass
- func (m *SceneClassificationProfile) GetSampleRate() uint32
- func (*SceneClassificationProfile) ProtoMessage()
- func (m *SceneClassificationProfile) Reset()
- func (m *SceneClassificationProfile) String() string
- func (m *SceneClassificationProfile) XXX_DiscardUnknown()
- func (m *SceneClassificationProfile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SceneClassificationProfile) XXX_Merge(src proto.Message)
- func (m *SceneClassificationProfile) XXX_Size() int
- func (m *SceneClassificationProfile) XXX_Unmarshal(b []byte) error
- type SegData
- func (*SegData) Descriptor() ([]byte, []int)
- func (m *SegData) GetAuthToken() *AuthToken
- func (m *SegData) GetCapabilities() *Capabilities
- func (m *SegData) GetDetectorEnabled() bool
- func (m *SegData) GetDetectorProfiles() []*DetectorProfile
- func (m *SegData) GetDuration() int32
- func (m *SegData) GetFullProfiles() []*VideoProfile
- func (m *SegData) GetFullProfiles2() []*VideoProfile
- func (m *SegData) GetFullProfiles3() []*VideoProfile
- func (m *SegData) GetHash() []byte
- func (m *SegData) GetManifestId() []byte
- func (m *SegData) GetProfiles() []byte
- func (m *SegData) GetSeq() int64
- func (m *SegData) GetSig() []byte
- func (m *SegData) GetStorage() []*OSInfo
- func (*SegData) ProtoMessage()
- func (m *SegData) Reset()
- func (m *SegData) String() string
- func (m *SegData) XXX_DiscardUnknown()
- func (m *SegData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SegData) XXX_Merge(src proto.Message)
- func (m *SegData) XXX_Size() int
- func (m *SegData) XXX_Unmarshal(b []byte) error
- type StreamInfo
- type Ticket
- func (*Ticket) Descriptor() ([]byte, []int)
- func (m *Ticket) GetExpirationParams() *TicketExpirationParams
- func (m *Ticket) GetRecipientRand() []byte
- func (m *Ticket) GetSender() []byte
- func (m *Ticket) GetSenderParams() *TicketSenderParams
- func (m *Ticket) GetTicketParams() *TicketParams
- func (*Ticket) ProtoMessage()
- func (m *Ticket) Reset()
- func (m *Ticket) String() string
- func (m *Ticket) XXX_DiscardUnknown()
- func (m *Ticket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Ticket) XXX_Merge(src proto.Message)
- func (m *Ticket) XXX_Size() int
- func (m *Ticket) XXX_Unmarshal(b []byte) error
- type TicketExpirationParams
- func (*TicketExpirationParams) Descriptor() ([]byte, []int)
- func (m *TicketExpirationParams) GetCreationRound() int64
- func (m *TicketExpirationParams) GetCreationRoundBlockHash() []byte
- func (*TicketExpirationParams) ProtoMessage()
- func (m *TicketExpirationParams) Reset()
- func (m *TicketExpirationParams) String() string
- func (m *TicketExpirationParams) XXX_DiscardUnknown()
- func (m *TicketExpirationParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TicketExpirationParams) XXX_Merge(src proto.Message)
- func (m *TicketExpirationParams) XXX_Size() int
- func (m *TicketExpirationParams) XXX_Unmarshal(b []byte) error
- type TicketParams
- func (*TicketParams) Descriptor() ([]byte, []int)
- func (m *TicketParams) GetExpirationBlock() []byte
- func (m *TicketParams) GetExpirationParams() *TicketExpirationParams
- func (m *TicketParams) GetFaceValue() []byte
- func (m *TicketParams) GetRecipient() []byte
- func (m *TicketParams) GetRecipientRandHash() []byte
- func (m *TicketParams) GetSeed() []byte
- func (m *TicketParams) GetWinProb() []byte
- func (*TicketParams) ProtoMessage()
- func (m *TicketParams) Reset()
- func (m *TicketParams) String() string
- func (m *TicketParams) XXX_DiscardUnknown()
- func (m *TicketParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TicketParams) XXX_Merge(src proto.Message)
- func (m *TicketParams) XXX_Size() int
- func (m *TicketParams) XXX_Unmarshal(b []byte) error
- type TicketRedeemerClient
- type TicketRedeemerServer
- type TicketRedeemer_MonitorMaxFloatClient
- type TicketRedeemer_MonitorMaxFloatServer
- type TicketSenderParams
- func (*TicketSenderParams) Descriptor() ([]byte, []int)
- func (m *TicketSenderParams) GetSenderNonce() uint32
- func (m *TicketSenderParams) GetSig() []byte
- func (*TicketSenderParams) ProtoMessage()
- func (m *TicketSenderParams) Reset()
- func (m *TicketSenderParams) String() string
- func (m *TicketSenderParams) XXX_DiscardUnknown()
- func (m *TicketSenderParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TicketSenderParams) XXX_Merge(src proto.Message)
- func (m *TicketSenderParams) XXX_Size() int
- func (m *TicketSenderParams) XXX_Unmarshal(b []byte) error
- type TranscodeData
- func (*TranscodeData) Descriptor() ([]byte, []int)
- func (m *TranscodeData) GetDetections() []*DetectData
- func (m *TranscodeData) GetSegments() []*TranscodedSegmentData
- func (m *TranscodeData) GetSig() []byte
- func (*TranscodeData) ProtoMessage()
- func (m *TranscodeData) Reset()
- func (m *TranscodeData) String() string
- func (m *TranscodeData) XXX_DiscardUnknown()
- func (m *TranscodeData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TranscodeData) XXX_Merge(src proto.Message)
- func (m *TranscodeData) XXX_Size() int
- func (m *TranscodeData) XXX_Unmarshal(b []byte) error
- type TranscodeResult
- func (*TranscodeResult) Descriptor() ([]byte, []int)
- func (m *TranscodeResult) GetData() *TranscodeData
- func (m *TranscodeResult) GetError() string
- func (m *TranscodeResult) GetInfo() *OrchestratorInfo
- func (m *TranscodeResult) GetResult() isTranscodeResult_Result
- func (m *TranscodeResult) GetSeq() int64
- func (*TranscodeResult) ProtoMessage()
- func (m *TranscodeResult) Reset()
- func (m *TranscodeResult) String() string
- func (m *TranscodeResult) XXX_DiscardUnknown()
- func (m *TranscodeResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TranscodeResult) XXX_Merge(src proto.Message)
- func (*TranscodeResult) XXX_OneofWrappers() []interface{}
- func (m *TranscodeResult) XXX_Size() int
- func (m *TranscodeResult) XXX_Unmarshal(b []byte) error
- type TranscodeResult_Data
- type TranscodeResult_Error
- type TranscodedSegmentData
- func (*TranscodedSegmentData) Descriptor() ([]byte, []int)
- func (m *TranscodedSegmentData) GetPixels() int64
- func (m *TranscodedSegmentData) GetUrl() string
- func (*TranscodedSegmentData) ProtoMessage()
- func (m *TranscodedSegmentData) Reset()
- func (m *TranscodedSegmentData) String() string
- func (m *TranscodedSegmentData) XXX_DiscardUnknown()
- func (m *TranscodedSegmentData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TranscodedSegmentData) XXX_Merge(src proto.Message)
- func (m *TranscodedSegmentData) XXX_Size() int
- func (m *TranscodedSegmentData) XXX_Unmarshal(b []byte) error
- type TranscoderClient
- type TranscoderServer
- type Transcoder_RegisterTranscoderClient
- type Transcoder_RegisterTranscoderServer
- type UnimplementedOrchestratorServer
- type UnimplementedTicketRedeemerServer
- func (*UnimplementedTicketRedeemerServer) MaxFloat(ctx context.Context, req *MaxFloatReq) (*MaxFloatUpdate, error)
- func (*UnimplementedTicketRedeemerServer) MonitorMaxFloat(req *MaxFloatReq, srv TicketRedeemer_MonitorMaxFloatServer) error
- func (*UnimplementedTicketRedeemerServer) QueueTicket(ctx context.Context, req *Ticket) (*QueueTicketRes, error)
- type UnimplementedTranscoderServer
- type VideoProfile
- func (*VideoProfile) Descriptor() ([]byte, []int)
- func (m *VideoProfile) GetBitrate() int32
- func (m *VideoProfile) GetFormat() VideoProfile_Format
- func (m *VideoProfile) GetFps() uint32
- func (m *VideoProfile) GetFpsDen() uint32
- func (m *VideoProfile) GetGop() int32
- func (m *VideoProfile) GetHeight() int32
- func (m *VideoProfile) GetName() string
- func (m *VideoProfile) GetProfile() VideoProfile_Profile
- func (m *VideoProfile) GetWidth() int32
- func (*VideoProfile) ProtoMessage()
- func (m *VideoProfile) Reset()
- func (m *VideoProfile) String() string
- func (m *VideoProfile) XXX_DiscardUnknown()
- func (m *VideoProfile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *VideoProfile) XXX_Merge(src proto.Message)
- func (m *VideoProfile) XXX_Size() int
- func (m *VideoProfile) XXX_Unmarshal(b []byte) error
- type VideoProfile_Format
- type VideoProfile_Profile
Constants ¶
This section is empty.
Variables ¶
var OSInfo_StorageType_name = map[int32]string{
0: "DIRECT",
1: "S3",
2: "GOOGLE",
}
var OSInfo_StorageType_value = map[string]int32{
"DIRECT": 0,
"S3": 1,
"GOOGLE": 2,
}
var VideoProfile_Format_name = map[int32]string{
0: "MPEGTS",
1: "MP4",
}
var VideoProfile_Format_value = map[string]int32{
"MPEGTS": 0,
"MP4": 1,
}
var VideoProfile_Profile_name = map[int32]string{
0: "ENCODER_DEFAULT",
1: "H264_BASELINE",
2: "H264_MAIN",
3: "H264_HIGH",
4: "H264_CONSTRAINED_HIGH",
}
var VideoProfile_Profile_value = map[string]int32{
"ENCODER_DEFAULT": 0,
"H264_BASELINE": 1,
"H264_MAIN": 2,
"H264_HIGH": 3,
"H264_CONSTRAINED_HIGH": 4,
}
Functions ¶
func RegisterOrchestratorServer ¶ added in v0.3.3
func RegisterOrchestratorServer(s *grpc.Server, srv OrchestratorServer)
func RegisterTicketRedeemerServer ¶ added in v0.5.9
func RegisterTicketRedeemerServer(s *grpc.Server, srv TicketRedeemerServer)
func RegisterTranscoderServer ¶ added in v0.5.0
func RegisterTranscoderServer(s *grpc.Server, srv TranscoderServer)
Types ¶
type AuthToken ¶ added in v0.3.3
type AuthToken struct { // Record used to authenticate for a transcode session // Opaque to the receiver Token []byte `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` // ID of the transcode session that the token is authenticating for SessionId string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // Timestamp when the token expires Expiration int64 `protobuf:"varint,3,opt,name=expiration,proto3" json:"expiration,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Data for transcoding authentication that is included in the OrchestratorInfo message during discovery
func (*AuthToken) Descriptor ¶ added in v0.3.3
func (*AuthToken) GetExpiration ¶ added in v0.5.11
func (*AuthToken) GetSessionId ¶ added in v0.5.11
func (*AuthToken) ProtoMessage ¶ added in v0.3.3
func (*AuthToken) ProtoMessage()
func (*AuthToken) XXX_DiscardUnknown ¶ added in v0.3.3
func (m *AuthToken) XXX_DiscardUnknown()
func (*AuthToken) XXX_Marshal ¶ added in v0.3.3
func (*AuthToken) XXX_Unmarshal ¶ added in v0.3.3
type Capabilities ¶ added in v0.5.10
type Capabilities struct { // Bit string of supported features - one bit per feature Bitstring []uint64 `protobuf:"varint,1,rep,packed,name=bitstring,proto3" json:"bitstring,omitempty"` // Bit string of features that are required to be supported Mandatories []uint64 `protobuf:"varint,2,rep,packed,name=mandatories,proto3" json:"mandatories,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Capabilities) Descriptor ¶ added in v0.5.10
func (*Capabilities) Descriptor() ([]byte, []int)
func (*Capabilities) GetBitstring ¶ added in v0.5.10
func (m *Capabilities) GetBitstring() []uint64
func (*Capabilities) GetMandatories ¶ added in v0.5.10
func (m *Capabilities) GetMandatories() []uint64
func (*Capabilities) ProtoMessage ¶ added in v0.5.10
func (*Capabilities) ProtoMessage()
func (*Capabilities) Reset ¶ added in v0.5.10
func (m *Capabilities) Reset()
func (*Capabilities) String ¶ added in v0.5.10
func (m *Capabilities) String() string
func (*Capabilities) XXX_DiscardUnknown ¶ added in v0.5.10
func (m *Capabilities) XXX_DiscardUnknown()
func (*Capabilities) XXX_Marshal ¶ added in v0.5.10
func (m *Capabilities) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Capabilities) XXX_Merge ¶ added in v0.5.10
func (m *Capabilities) XXX_Merge(src proto.Message)
func (*Capabilities) XXX_Size ¶ added in v0.5.10
func (m *Capabilities) XXX_Size() int
func (*Capabilities) XXX_Unmarshal ¶ added in v0.5.10
func (m *Capabilities) XXX_Unmarshal(b []byte) error
type Capabilities_Constraints ¶ added in v0.5.10
type Capabilities_Constraints struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Non-binary capability constraints, such as supported ranges.
func (*Capabilities_Constraints) Descriptor ¶ added in v0.5.10
func (*Capabilities_Constraints) Descriptor() ([]byte, []int)
func (*Capabilities_Constraints) ProtoMessage ¶ added in v0.5.10
func (*Capabilities_Constraints) ProtoMessage()
func (*Capabilities_Constraints) Reset ¶ added in v0.5.10
func (m *Capabilities_Constraints) Reset()
func (*Capabilities_Constraints) String ¶ added in v0.5.10
func (m *Capabilities_Constraints) String() string
func (*Capabilities_Constraints) XXX_DiscardUnknown ¶ added in v0.5.10
func (m *Capabilities_Constraints) XXX_DiscardUnknown()
func (*Capabilities_Constraints) XXX_Marshal ¶ added in v0.5.10
func (m *Capabilities_Constraints) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Capabilities_Constraints) XXX_Merge ¶ added in v0.5.10
func (m *Capabilities_Constraints) XXX_Merge(src proto.Message)
func (*Capabilities_Constraints) XXX_Size ¶ added in v0.5.10
func (m *Capabilities_Constraints) XXX_Size() int
func (*Capabilities_Constraints) XXX_Unmarshal ¶ added in v0.5.10
func (m *Capabilities_Constraints) XXX_Unmarshal(b []byte) error
type DetectData ¶ added in v0.5.19
type DetectData struct { // Types that are valid to be assigned to Value: // *DetectData_SceneClassification Value isDetectData_Value `protobuf_oneof:"value"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
[EXPERIMENTAL] Describes detection results
func (*DetectData) Descriptor ¶ added in v0.5.19
func (*DetectData) Descriptor() ([]byte, []int)
func (*DetectData) GetSceneClassification ¶ added in v0.5.19
func (m *DetectData) GetSceneClassification() *SceneClassificationData
func (*DetectData) GetValue ¶ added in v0.5.19
func (m *DetectData) GetValue() isDetectData_Value
func (*DetectData) ProtoMessage ¶ added in v0.5.19
func (*DetectData) ProtoMessage()
func (*DetectData) Reset ¶ added in v0.5.19
func (m *DetectData) Reset()
func (*DetectData) String ¶ added in v0.5.19
func (m *DetectData) String() string
func (*DetectData) XXX_DiscardUnknown ¶ added in v0.5.19
func (m *DetectData) XXX_DiscardUnknown()
func (*DetectData) XXX_Marshal ¶ added in v0.5.19
func (m *DetectData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DetectData) XXX_Merge ¶ added in v0.5.19
func (m *DetectData) XXX_Merge(src proto.Message)
func (*DetectData) XXX_OneofWrappers ¶ added in v0.5.19
func (*DetectData) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*DetectData) XXX_Size ¶ added in v0.5.19
func (m *DetectData) XXX_Size() int
func (*DetectData) XXX_Unmarshal ¶ added in v0.5.19
func (m *DetectData) XXX_Unmarshal(b []byte) error
type DetectData_SceneClassification ¶ added in v0.5.19
type DetectData_SceneClassification struct {
SceneClassification *SceneClassificationData `protobuf:"bytes,1,opt,name=scene_classification,json=sceneClassification,proto3,oneof"`
}
type DetectorClass ¶ added in v0.5.19
type DetectorClass struct { // ID of the class to detect ClassId uint32 `protobuf:"varint,1,opt,name=class_id,json=classId,proto3" json:"class_id,omitempty"` // Name of the class to detect ClassName string `protobuf:"bytes,2,opt,name=class_name,json=className,proto3" json:"class_name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
[EXPERIMENTAL] Describes a class that a model is trained to detect
func (*DetectorClass) Descriptor ¶ added in v0.5.19
func (*DetectorClass) Descriptor() ([]byte, []int)
func (*DetectorClass) GetClassId ¶ added in v0.5.19
func (m *DetectorClass) GetClassId() uint32
func (*DetectorClass) GetClassName ¶ added in v0.5.19
func (m *DetectorClass) GetClassName() string
func (*DetectorClass) ProtoMessage ¶ added in v0.5.19
func (*DetectorClass) ProtoMessage()
func (*DetectorClass) Reset ¶ added in v0.5.19
func (m *DetectorClass) Reset()
func (*DetectorClass) String ¶ added in v0.5.19
func (m *DetectorClass) String() string
func (*DetectorClass) XXX_DiscardUnknown ¶ added in v0.5.19
func (m *DetectorClass) XXX_DiscardUnknown()
func (*DetectorClass) XXX_Marshal ¶ added in v0.5.19
func (m *DetectorClass) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DetectorClass) XXX_Merge ¶ added in v0.5.19
func (m *DetectorClass) XXX_Merge(src proto.Message)
func (*DetectorClass) XXX_Size ¶ added in v0.5.19
func (m *DetectorClass) XXX_Size() int
func (*DetectorClass) XXX_Unmarshal ¶ added in v0.5.19
func (m *DetectorClass) XXX_Unmarshal(b []byte) error
type DetectorProfile ¶ added in v0.5.19
type DetectorProfile struct { // Types that are valid to be assigned to Value: // *DetectorProfile_SceneClassification Value isDetectorProfile_Value `protobuf_oneof:"value"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
[EXPERIMENTAL] Describes the content detection configuration
func (*DetectorProfile) Descriptor ¶ added in v0.5.19
func (*DetectorProfile) Descriptor() ([]byte, []int)
func (*DetectorProfile) GetSceneClassification ¶ added in v0.5.19
func (m *DetectorProfile) GetSceneClassification() *SceneClassificationProfile
func (*DetectorProfile) GetValue ¶ added in v0.5.19
func (m *DetectorProfile) GetValue() isDetectorProfile_Value
func (*DetectorProfile) ProtoMessage ¶ added in v0.5.19
func (*DetectorProfile) ProtoMessage()
func (*DetectorProfile) Reset ¶ added in v0.5.19
func (m *DetectorProfile) Reset()
func (*DetectorProfile) String ¶ added in v0.5.19
func (m *DetectorProfile) String() string
func (*DetectorProfile) XXX_DiscardUnknown ¶ added in v0.5.19
func (m *DetectorProfile) XXX_DiscardUnknown()
func (*DetectorProfile) XXX_Marshal ¶ added in v0.5.19
func (m *DetectorProfile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DetectorProfile) XXX_Merge ¶ added in v0.5.19
func (m *DetectorProfile) XXX_Merge(src proto.Message)
func (*DetectorProfile) XXX_OneofWrappers ¶ added in v0.5.19
func (*DetectorProfile) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*DetectorProfile) XXX_Size ¶ added in v0.5.19
func (m *DetectorProfile) XXX_Size() int
func (*DetectorProfile) XXX_Unmarshal ¶ added in v0.5.19
func (m *DetectorProfile) XXX_Unmarshal(b []byte) error
type DetectorProfile_SceneClassification ¶ added in v0.5.19
type DetectorProfile_SceneClassification struct {
SceneClassification *SceneClassificationProfile `protobuf:"bytes,1,opt,name=scene_classification,json=sceneClassification,proto3,oneof"`
}
type MaxFloatReq ¶ added in v0.5.9
type MaxFloatReq struct { Sender []byte `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MaxFloatReq) Descriptor ¶ added in v0.5.9
func (*MaxFloatReq) Descriptor() ([]byte, []int)
func (*MaxFloatReq) GetSender ¶ added in v0.5.9
func (m *MaxFloatReq) GetSender() []byte
func (*MaxFloatReq) ProtoMessage ¶ added in v0.5.9
func (*MaxFloatReq) ProtoMessage()
func (*MaxFloatReq) Reset ¶ added in v0.5.9
func (m *MaxFloatReq) Reset()
func (*MaxFloatReq) String ¶ added in v0.5.9
func (m *MaxFloatReq) String() string
func (*MaxFloatReq) XXX_DiscardUnknown ¶ added in v0.5.9
func (m *MaxFloatReq) XXX_DiscardUnknown()
func (*MaxFloatReq) XXX_Marshal ¶ added in v0.5.9
func (m *MaxFloatReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MaxFloatReq) XXX_Merge ¶ added in v0.5.9
func (m *MaxFloatReq) XXX_Merge(src proto.Message)
func (*MaxFloatReq) XXX_Size ¶ added in v0.5.9
func (m *MaxFloatReq) XXX_Size() int
func (*MaxFloatReq) XXX_Unmarshal ¶ added in v0.5.9
func (m *MaxFloatReq) XXX_Unmarshal(b []byte) error
type MaxFloatUpdate ¶ added in v0.5.9
type MaxFloatUpdate struct { MaxFloat []byte `protobuf:"bytes,1,opt,name=max_float,json=maxFloat,proto3" json:"max_float,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MaxFloatUpdate) Descriptor ¶ added in v0.5.9
func (*MaxFloatUpdate) Descriptor() ([]byte, []int)
func (*MaxFloatUpdate) GetMaxFloat ¶ added in v0.5.9
func (m *MaxFloatUpdate) GetMaxFloat() []byte
func (*MaxFloatUpdate) ProtoMessage ¶ added in v0.5.9
func (*MaxFloatUpdate) ProtoMessage()
func (*MaxFloatUpdate) Reset ¶ added in v0.5.9
func (m *MaxFloatUpdate) Reset()
func (*MaxFloatUpdate) String ¶ added in v0.5.9
func (m *MaxFloatUpdate) String() string
func (*MaxFloatUpdate) XXX_DiscardUnknown ¶ added in v0.5.9
func (m *MaxFloatUpdate) XXX_DiscardUnknown()
func (*MaxFloatUpdate) XXX_Marshal ¶ added in v0.5.9
func (m *MaxFloatUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MaxFloatUpdate) XXX_Merge ¶ added in v0.5.9
func (m *MaxFloatUpdate) XXX_Merge(src proto.Message)
func (*MaxFloatUpdate) XXX_Size ¶ added in v0.5.9
func (m *MaxFloatUpdate) XXX_Size() int
func (*MaxFloatUpdate) XXX_Unmarshal ¶ added in v0.5.9
func (m *MaxFloatUpdate) XXX_Unmarshal(b []byte) error
type MockTicketRedeemerClient ¶ added in v0.5.9
type MockTicketRedeemerClient struct {
// contains filtered or unexported fields
}
MockTicketRedeemerClient is a mock of TicketRedeemerClient interface.
func NewMockTicketRedeemerClient ¶ added in v0.5.9
func NewMockTicketRedeemerClient(ctrl *gomock.Controller) *MockTicketRedeemerClient
NewMockTicketRedeemerClient creates a new mock instance.
func (*MockTicketRedeemerClient) EXPECT ¶ added in v0.5.9
func (m *MockTicketRedeemerClient) EXPECT() *MockTicketRedeemerClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockTicketRedeemerClient) MaxFloat ¶ added in v0.5.9
func (m *MockTicketRedeemerClient) MaxFloat(ctx context.Context, in *MaxFloatReq, opts ...grpc.CallOption) (*MaxFloatUpdate, error)
MaxFloat mocks base method.
func (*MockTicketRedeemerClient) MonitorMaxFloat ¶ added in v0.5.9
func (m *MockTicketRedeemerClient) MonitorMaxFloat(ctx context.Context, in *MaxFloatReq, opts ...grpc.CallOption) (TicketRedeemer_MonitorMaxFloatClient, error)
MonitorMaxFloat mocks base method.
func (*MockTicketRedeemerClient) QueueTicket ¶ added in v0.5.9
func (m *MockTicketRedeemerClient) QueueTicket(ctx context.Context, in *Ticket, opts ...grpc.CallOption) (*QueueTicketRes, error)
QueueTicket mocks base method.
type MockTicketRedeemerClientMockRecorder ¶ added in v0.5.9
type MockTicketRedeemerClientMockRecorder struct {
// contains filtered or unexported fields
}
MockTicketRedeemerClientMockRecorder is the mock recorder for MockTicketRedeemerClient.
func (*MockTicketRedeemerClientMockRecorder) MaxFloat ¶ added in v0.5.9
func (mr *MockTicketRedeemerClientMockRecorder) MaxFloat(ctx, in interface{}, opts ...interface{}) *gomock.Call
MaxFloat indicates an expected call of MaxFloat.
func (*MockTicketRedeemerClientMockRecorder) MonitorMaxFloat ¶ added in v0.5.9
func (mr *MockTicketRedeemerClientMockRecorder) MonitorMaxFloat(ctx, in interface{}, opts ...interface{}) *gomock.Call
MonitorMaxFloat indicates an expected call of MonitorMaxFloat.
func (*MockTicketRedeemerClientMockRecorder) QueueTicket ¶ added in v0.5.9
func (mr *MockTicketRedeemerClientMockRecorder) QueueTicket(ctx, in interface{}, opts ...interface{}) *gomock.Call
QueueTicket indicates an expected call of QueueTicket.
type MockTicketRedeemerServer ¶ added in v0.5.9
type MockTicketRedeemerServer struct {
// contains filtered or unexported fields
}
MockTicketRedeemerServer is a mock of TicketRedeemerServer interface.
func NewMockTicketRedeemerServer ¶ added in v0.5.9
func NewMockTicketRedeemerServer(ctrl *gomock.Controller) *MockTicketRedeemerServer
NewMockTicketRedeemerServer creates a new mock instance.
func (*MockTicketRedeemerServer) EXPECT ¶ added in v0.5.9
func (m *MockTicketRedeemerServer) EXPECT() *MockTicketRedeemerServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockTicketRedeemerServer) MaxFloat ¶ added in v0.5.9
func (m *MockTicketRedeemerServer) MaxFloat(arg0 context.Context, arg1 *MaxFloatReq) (*MaxFloatUpdate, error)
MaxFloat mocks base method.
func (*MockTicketRedeemerServer) MonitorMaxFloat ¶ added in v0.5.9
func (m *MockTicketRedeemerServer) MonitorMaxFloat(arg0 *MaxFloatReq, arg1 TicketRedeemer_MonitorMaxFloatServer) error
MonitorMaxFloat mocks base method.
func (*MockTicketRedeemerServer) QueueTicket ¶ added in v0.5.9
func (m *MockTicketRedeemerServer) QueueTicket(arg0 context.Context, arg1 *Ticket) (*QueueTicketRes, error)
QueueTicket mocks base method.
type MockTicketRedeemerServerMockRecorder ¶ added in v0.5.9
type MockTicketRedeemerServerMockRecorder struct {
// contains filtered or unexported fields
}
MockTicketRedeemerServerMockRecorder is the mock recorder for MockTicketRedeemerServer.
func (*MockTicketRedeemerServerMockRecorder) MaxFloat ¶ added in v0.5.9
func (mr *MockTicketRedeemerServerMockRecorder) MaxFloat(arg0, arg1 interface{}) *gomock.Call
MaxFloat indicates an expected call of MaxFloat.
func (*MockTicketRedeemerServerMockRecorder) MonitorMaxFloat ¶ added in v0.5.9
func (mr *MockTicketRedeemerServerMockRecorder) MonitorMaxFloat(arg0, arg1 interface{}) *gomock.Call
MonitorMaxFloat indicates an expected call of MonitorMaxFloat.
func (*MockTicketRedeemerServerMockRecorder) QueueTicket ¶ added in v0.5.9
func (mr *MockTicketRedeemerServerMockRecorder) QueueTicket(arg0, arg1 interface{}) *gomock.Call
QueueTicket indicates an expected call of QueueTicket.
type MockTicketRedeemer_MonitorMaxFloatClient ¶ added in v0.5.9
type MockTicketRedeemer_MonitorMaxFloatClient struct {
// contains filtered or unexported fields
}
MockTicketRedeemer_MonitorMaxFloatClient is a mock of TicketRedeemer_MonitorMaxFloatClient interface.
func NewMockTicketRedeemer_MonitorMaxFloatClient ¶ added in v0.5.9
func NewMockTicketRedeemer_MonitorMaxFloatClient(ctrl *gomock.Controller) *MockTicketRedeemer_MonitorMaxFloatClient
NewMockTicketRedeemer_MonitorMaxFloatClient creates a new mock instance.
func (*MockTicketRedeemer_MonitorMaxFloatClient) CloseSend ¶ added in v0.5.9
func (m *MockTicketRedeemer_MonitorMaxFloatClient) CloseSend() error
CloseSend mocks base method.
func (*MockTicketRedeemer_MonitorMaxFloatClient) Context ¶ added in v0.5.9
func (m *MockTicketRedeemer_MonitorMaxFloatClient) Context() context.Context
Context mocks base method.
func (*MockTicketRedeemer_MonitorMaxFloatClient) EXPECT ¶ added in v0.5.9
func (m *MockTicketRedeemer_MonitorMaxFloatClient) EXPECT() *MockTicketRedeemer_MonitorMaxFloatClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockTicketRedeemer_MonitorMaxFloatClient) Header ¶ added in v0.5.9
func (m *MockTicketRedeemer_MonitorMaxFloatClient) Header() (metadata.MD, error)
Header mocks base method.
func (*MockTicketRedeemer_MonitorMaxFloatClient) Recv ¶ added in v0.5.9
func (m *MockTicketRedeemer_MonitorMaxFloatClient) Recv() (*MaxFloatUpdate, error)
Recv mocks base method.
func (*MockTicketRedeemer_MonitorMaxFloatClient) RecvMsg ¶ added in v0.5.9
func (m_2 *MockTicketRedeemer_MonitorMaxFloatClient) RecvMsg(m interface{}) error
RecvMsg mocks base method.
func (*MockTicketRedeemer_MonitorMaxFloatClient) SendMsg ¶ added in v0.5.9
func (m_2 *MockTicketRedeemer_MonitorMaxFloatClient) SendMsg(m interface{}) error
SendMsg mocks base method.
func (*MockTicketRedeemer_MonitorMaxFloatClient) Trailer ¶ added in v0.5.9
func (m *MockTicketRedeemer_MonitorMaxFloatClient) Trailer() metadata.MD
Trailer mocks base method.
type MockTicketRedeemer_MonitorMaxFloatClientMockRecorder ¶ added in v0.5.9
type MockTicketRedeemer_MonitorMaxFloatClientMockRecorder struct {
// contains filtered or unexported fields
}
MockTicketRedeemer_MonitorMaxFloatClientMockRecorder is the mock recorder for MockTicketRedeemer_MonitorMaxFloatClient.
func (*MockTicketRedeemer_MonitorMaxFloatClientMockRecorder) CloseSend ¶ added in v0.5.9
func (mr *MockTicketRedeemer_MonitorMaxFloatClientMockRecorder) CloseSend() *gomock.Call
CloseSend indicates an expected call of CloseSend.
func (*MockTicketRedeemer_MonitorMaxFloatClientMockRecorder) Context ¶ added in v0.5.9
func (mr *MockTicketRedeemer_MonitorMaxFloatClientMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockTicketRedeemer_MonitorMaxFloatClientMockRecorder) Header ¶ added in v0.5.9
func (mr *MockTicketRedeemer_MonitorMaxFloatClientMockRecorder) Header() *gomock.Call
Header indicates an expected call of Header.
func (*MockTicketRedeemer_MonitorMaxFloatClientMockRecorder) Recv ¶ added in v0.5.9
func (mr *MockTicketRedeemer_MonitorMaxFloatClientMockRecorder) Recv() *gomock.Call
Recv indicates an expected call of Recv.
func (*MockTicketRedeemer_MonitorMaxFloatClientMockRecorder) RecvMsg ¶ added in v0.5.9
func (mr *MockTicketRedeemer_MonitorMaxFloatClientMockRecorder) RecvMsg(m interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockTicketRedeemer_MonitorMaxFloatClientMockRecorder) SendMsg ¶ added in v0.5.9
func (mr *MockTicketRedeemer_MonitorMaxFloatClientMockRecorder) SendMsg(m interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockTicketRedeemer_MonitorMaxFloatClientMockRecorder) Trailer ¶ added in v0.5.9
func (mr *MockTicketRedeemer_MonitorMaxFloatClientMockRecorder) Trailer() *gomock.Call
Trailer indicates an expected call of Trailer.
type MockTicketRedeemer_MonitorMaxFloatServer ¶ added in v0.5.9
type MockTicketRedeemer_MonitorMaxFloatServer struct {
// contains filtered or unexported fields
}
MockTicketRedeemer_MonitorMaxFloatServer is a mock of TicketRedeemer_MonitorMaxFloatServer interface.
func NewMockTicketRedeemer_MonitorMaxFloatServer ¶ added in v0.5.9
func NewMockTicketRedeemer_MonitorMaxFloatServer(ctrl *gomock.Controller) *MockTicketRedeemer_MonitorMaxFloatServer
NewMockTicketRedeemer_MonitorMaxFloatServer creates a new mock instance.
func (*MockTicketRedeemer_MonitorMaxFloatServer) Context ¶ added in v0.5.9
func (m *MockTicketRedeemer_MonitorMaxFloatServer) Context() context.Context
Context mocks base method.
func (*MockTicketRedeemer_MonitorMaxFloatServer) EXPECT ¶ added in v0.5.9
func (m *MockTicketRedeemer_MonitorMaxFloatServer) EXPECT() *MockTicketRedeemer_MonitorMaxFloatServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockTicketRedeemer_MonitorMaxFloatServer) RecvMsg ¶ added in v0.5.9
func (m_2 *MockTicketRedeemer_MonitorMaxFloatServer) RecvMsg(m interface{}) error
RecvMsg mocks base method.
func (*MockTicketRedeemer_MonitorMaxFloatServer) Send ¶ added in v0.5.9
func (m *MockTicketRedeemer_MonitorMaxFloatServer) Send(arg0 *MaxFloatUpdate) error
Send mocks base method.
func (*MockTicketRedeemer_MonitorMaxFloatServer) SendHeader ¶ added in v0.5.9
func (m *MockTicketRedeemer_MonitorMaxFloatServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockTicketRedeemer_MonitorMaxFloatServer) SendMsg ¶ added in v0.5.9
func (m_2 *MockTicketRedeemer_MonitorMaxFloatServer) SendMsg(m interface{}) error
SendMsg mocks base method.
func (*MockTicketRedeemer_MonitorMaxFloatServer) SetHeader ¶ added in v0.5.9
func (m *MockTicketRedeemer_MonitorMaxFloatServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockTicketRedeemer_MonitorMaxFloatServer) SetTrailer ¶ added in v0.5.9
func (m *MockTicketRedeemer_MonitorMaxFloatServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockTicketRedeemer_MonitorMaxFloatServerMockRecorder ¶ added in v0.5.9
type MockTicketRedeemer_MonitorMaxFloatServerMockRecorder struct {
// contains filtered or unexported fields
}
MockTicketRedeemer_MonitorMaxFloatServerMockRecorder is the mock recorder for MockTicketRedeemer_MonitorMaxFloatServer.
func (*MockTicketRedeemer_MonitorMaxFloatServerMockRecorder) Context ¶ added in v0.5.9
func (mr *MockTicketRedeemer_MonitorMaxFloatServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockTicketRedeemer_MonitorMaxFloatServerMockRecorder) RecvMsg ¶ added in v0.5.9
func (mr *MockTicketRedeemer_MonitorMaxFloatServerMockRecorder) RecvMsg(m interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockTicketRedeemer_MonitorMaxFloatServerMockRecorder) Send ¶ added in v0.5.9
func (mr *MockTicketRedeemer_MonitorMaxFloatServerMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockTicketRedeemer_MonitorMaxFloatServerMockRecorder) SendHeader ¶ added in v0.5.9
func (mr *MockTicketRedeemer_MonitorMaxFloatServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockTicketRedeemer_MonitorMaxFloatServerMockRecorder) SendMsg ¶ added in v0.5.9
func (mr *MockTicketRedeemer_MonitorMaxFloatServerMockRecorder) SendMsg(m interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockTicketRedeemer_MonitorMaxFloatServerMockRecorder) SetHeader ¶ added in v0.5.9
func (mr *MockTicketRedeemer_MonitorMaxFloatServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockTicketRedeemer_MonitorMaxFloatServerMockRecorder) SetTrailer ¶ added in v0.5.9
func (mr *MockTicketRedeemer_MonitorMaxFloatServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type NodeStatus ¶
type NodeStatus struct { Manifests map[string]*m3u8.MasterPlaylist // maps external manifest (provided in HTTP push URL to the internal one // (returned from webhook)) InternalManifests map[string]string StreamInfo map[string]StreamInfo OrchestratorPool []string Version string GolangRuntimeVersion string GOArch string GOOS string RegisteredTranscodersNumber int RegisteredTranscoders []RemoteTranscoderInfo LocalTranscoding bool // Indicates orchestrator that is also transcoder }
type NotifySegment ¶ added in v0.5.0
type NotifySegment struct { // URL of the segment to transcode. Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"` // Configuration for the transcoding job SegData *SegData `protobuf:"bytes,3,opt,name=segData,proto3" json:"segData,omitempty"` // ID for this particular transcoding task. TaskId int64 `protobuf:"varint,16,opt,name=taskId,proto3" json:"taskId,omitempty"` // Deprecated by fullProfiles. Set of presets to transcode into. // Should be set to an invalid value to induce failures Profiles []byte `protobuf:"bytes,17,opt,name=profiles,proto3" json:"profiles,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Sent by the orchestrator to the transcoder
func (*NotifySegment) Descriptor ¶ added in v0.5.0
func (*NotifySegment) Descriptor() ([]byte, []int)
func (*NotifySegment) GetProfiles ¶ added in v0.5.0
func (m *NotifySegment) GetProfiles() []byte
func (*NotifySegment) GetSegData ¶ added in v0.5.9
func (m *NotifySegment) GetSegData() *SegData
func (*NotifySegment) GetTaskId ¶ added in v0.5.0
func (m *NotifySegment) GetTaskId() int64
func (*NotifySegment) GetUrl ¶ added in v0.5.0
func (m *NotifySegment) GetUrl() string
func (*NotifySegment) ProtoMessage ¶ added in v0.5.0
func (*NotifySegment) ProtoMessage()
func (*NotifySegment) Reset ¶ added in v0.5.0
func (m *NotifySegment) Reset()
func (*NotifySegment) String ¶ added in v0.5.0
func (m *NotifySegment) String() string
func (*NotifySegment) XXX_DiscardUnknown ¶ added in v0.5.0
func (m *NotifySegment) XXX_DiscardUnknown()
func (*NotifySegment) XXX_Marshal ¶ added in v0.5.0
func (m *NotifySegment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NotifySegment) XXX_Merge ¶ added in v0.5.0
func (m *NotifySegment) XXX_Merge(src proto.Message)
func (*NotifySegment) XXX_Size ¶ added in v0.5.0
func (m *NotifySegment) XXX_Size() int
func (*NotifySegment) XXX_Unmarshal ¶ added in v0.5.0
func (m *NotifySegment) XXX_Unmarshal(b []byte) error
type OSInfo ¶ added in v0.5.0
type OSInfo struct { // Storage type: direct, s3, ipfs. StorageType OSInfo_StorageType `protobuf:"varint,1,opt,name=storageType,proto3,enum=net.OSInfo_StorageType" json:"storageType,omitempty"` S3Info *S3OSInfo `protobuf:"bytes,16,opt,name=s3info,proto3" json:"s3info,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
OSInfo needed to negotiate storages that will be used. It carries info needed to write to the storage.
func (*OSInfo) Descriptor ¶ added in v0.5.0
func (*OSInfo) GetStorageType ¶ added in v0.5.0
func (m *OSInfo) GetStorageType() OSInfo_StorageType
func (*OSInfo) ProtoMessage ¶ added in v0.5.0
func (*OSInfo) ProtoMessage()
func (*OSInfo) XXX_DiscardUnknown ¶ added in v0.5.0
func (m *OSInfo) XXX_DiscardUnknown()
func (*OSInfo) XXX_Marshal ¶ added in v0.5.0
func (*OSInfo) XXX_Unmarshal ¶ added in v0.5.0
type OSInfo_StorageType ¶ added in v0.5.0
type OSInfo_StorageType int32
const ( OSInfo_DIRECT OSInfo_StorageType = 0 OSInfo_S3 OSInfo_StorageType = 1 OSInfo_GOOGLE OSInfo_StorageType = 2 )
func (OSInfo_StorageType) EnumDescriptor ¶ added in v0.5.0
func (OSInfo_StorageType) EnumDescriptor() ([]byte, []int)
func (OSInfo_StorageType) String ¶ added in v0.5.0
func (x OSInfo_StorageType) String() string
type OrchestratorClient ¶ added in v0.3.3
type OrchestratorClient interface { // Called by the broadcaster to request transcoder info from an orchestrator. GetOrchestrator(ctx context.Context, in *OrchestratorRequest, opts ...grpc.CallOption) (*OrchestratorInfo, error) Ping(ctx context.Context, in *PingPong, opts ...grpc.CallOption) (*PingPong, error) }
OrchestratorClient is the client API for Orchestrator service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewOrchestratorClient ¶ added in v0.3.3
func NewOrchestratorClient(cc *grpc.ClientConn) OrchestratorClient
type OrchestratorInfo ¶ added in v0.5.0
type OrchestratorInfo struct { // URI of the transcoder to use for submitting segments. Transcoder string `protobuf:"bytes,1,opt,name=transcoder,proto3" json:"transcoder,omitempty"` // Parameters for probabilistic micropayment tickets TicketParams *TicketParams `protobuf:"bytes,2,opt,name=ticket_params,json=ticketParams,proto3" json:"ticket_params,omitempty"` // Price Info containing the price per pixel to transcode PriceInfo *PriceInfo `protobuf:"bytes,3,opt,name=price_info,json=priceInfo,proto3" json:"price_info,omitempty"` // ETH address that should sign transcoded results Address []byte `protobuf:"bytes,4,opt,name=address,proto3" json:"address,omitempty"` // Features and constraints supported by the orchestrator Capabilities *Capabilities `protobuf:"bytes,5,opt,name=capabilities,proto3" json:"capabilities,omitempty"` // Data for transcoding authentication AuthToken *AuthToken `protobuf:"bytes,6,opt,name=auth_token,json=authToken,proto3" json:"auth_token,omitempty"` // Orchestrator returns info about own input object storage, if it wants it to be used. Storage []*OSInfo `protobuf:"bytes,32,rep,name=storage,proto3" json:"storage,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
The orchestrator sends this in response to `GetOrchestrator`, containing miscellaneous data related to the job.
func (*OrchestratorInfo) Descriptor ¶ added in v0.5.0
func (*OrchestratorInfo) Descriptor() ([]byte, []int)
func (*OrchestratorInfo) GetAddress ¶ added in v0.5.9
func (m *OrchestratorInfo) GetAddress() []byte
func (*OrchestratorInfo) GetAuthToken ¶ added in v0.5.11
func (m *OrchestratorInfo) GetAuthToken() *AuthToken
func (*OrchestratorInfo) GetCapabilities ¶ added in v0.5.10
func (m *OrchestratorInfo) GetCapabilities() *Capabilities
func (*OrchestratorInfo) GetPriceInfo ¶ added in v0.5.0
func (m *OrchestratorInfo) GetPriceInfo() *PriceInfo
func (*OrchestratorInfo) GetStorage ¶ added in v0.5.0
func (m *OrchestratorInfo) GetStorage() []*OSInfo
func (*OrchestratorInfo) GetTicketParams ¶ added in v0.5.0
func (m *OrchestratorInfo) GetTicketParams() *TicketParams
func (*OrchestratorInfo) GetTranscoder ¶ added in v0.5.0
func (m *OrchestratorInfo) GetTranscoder() string
func (*OrchestratorInfo) ProtoMessage ¶ added in v0.5.0
func (*OrchestratorInfo) ProtoMessage()
func (*OrchestratorInfo) Reset ¶ added in v0.5.0
func (m *OrchestratorInfo) Reset()
func (*OrchestratorInfo) String ¶ added in v0.5.0
func (m *OrchestratorInfo) String() string
func (*OrchestratorInfo) XXX_DiscardUnknown ¶ added in v0.5.0
func (m *OrchestratorInfo) XXX_DiscardUnknown()
func (*OrchestratorInfo) XXX_Marshal ¶ added in v0.5.0
func (m *OrchestratorInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OrchestratorInfo) XXX_Merge ¶ added in v0.5.0
func (m *OrchestratorInfo) XXX_Merge(src proto.Message)
func (*OrchestratorInfo) XXX_Size ¶ added in v0.5.0
func (m *OrchestratorInfo) XXX_Size() int
func (*OrchestratorInfo) XXX_Unmarshal ¶ added in v0.5.0
func (m *OrchestratorInfo) XXX_Unmarshal(b []byte) error
type OrchestratorRequest ¶ added in v0.5.0
type OrchestratorRequest struct { // Ethereum address of the broadcaster Address []byte `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` // Broadcaster's signature over its address Sig []byte `protobuf:"bytes,2,opt,name=sig,proto3" json:"sig,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
This request is sent by the broadcaster in `GetTranscoder` to request information on which transcoder to use.
func (*OrchestratorRequest) Descriptor ¶ added in v0.5.0
func (*OrchestratorRequest) Descriptor() ([]byte, []int)
func (*OrchestratorRequest) GetAddress ¶ added in v0.5.0
func (m *OrchestratorRequest) GetAddress() []byte
func (*OrchestratorRequest) GetSig ¶ added in v0.5.0
func (m *OrchestratorRequest) GetSig() []byte
func (*OrchestratorRequest) ProtoMessage ¶ added in v0.5.0
func (*OrchestratorRequest) ProtoMessage()
func (*OrchestratorRequest) Reset ¶ added in v0.5.0
func (m *OrchestratorRequest) Reset()
func (*OrchestratorRequest) String ¶ added in v0.5.0
func (m *OrchestratorRequest) String() string
func (*OrchestratorRequest) XXX_DiscardUnknown ¶ added in v0.5.0
func (m *OrchestratorRequest) XXX_DiscardUnknown()
func (*OrchestratorRequest) XXX_Marshal ¶ added in v0.5.0
func (m *OrchestratorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OrchestratorRequest) XXX_Merge ¶ added in v0.5.0
func (m *OrchestratorRequest) XXX_Merge(src proto.Message)
func (*OrchestratorRequest) XXX_Size ¶ added in v0.5.0
func (m *OrchestratorRequest) XXX_Size() int
func (*OrchestratorRequest) XXX_Unmarshal ¶ added in v0.5.0
func (m *OrchestratorRequest) XXX_Unmarshal(b []byte) error
type OrchestratorServer ¶ added in v0.3.3
type OrchestratorServer interface { // Called by the broadcaster to request transcoder info from an orchestrator. GetOrchestrator(context.Context, *OrchestratorRequest) (*OrchestratorInfo, error) Ping(context.Context, *PingPong) (*PingPong, error) }
OrchestratorServer is the server API for Orchestrator service.
type Payment ¶ added in v0.5.0
type Payment struct { // Probabilistic micropayment ticket parameters // These remain the same even when sending multiple tickets TicketParams *TicketParams `protobuf:"bytes,1,opt,name=ticket_params,json=ticketParams,proto3" json:"ticket_params,omitempty"` // ETH address of the sender Sender []byte `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"` // Ticket params for expiration related validation ExpirationParams *TicketExpirationParams `protobuf:"bytes,3,opt,name=expiration_params,json=expirationParams,proto3" json:"expiration_params,omitempty"` TicketSenderParams []*TicketSenderParams `protobuf:"bytes,4,rep,name=ticket_sender_params,json=ticketSenderParams,proto3" json:"ticket_sender_params,omitempty"` // O's last known price ExpectedPrice *PriceInfo `protobuf:"bytes,5,opt,name=expected_price,json=expectedPrice,proto3" json:"expected_price,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Payment for transcoding video segments A payment can constitute of multiple tickets A broadcaster might need to send multiple tickets to top up his credit with an Orchestrator
func (*Payment) Descriptor ¶ added in v0.5.0
func (*Payment) GetExpectedPrice ¶ added in v0.5.0
func (*Payment) GetExpirationParams ¶ added in v0.5.0
func (m *Payment) GetExpirationParams() *TicketExpirationParams
func (*Payment) GetTicketParams ¶ added in v0.5.0
func (m *Payment) GetTicketParams() *TicketParams
func (*Payment) GetTicketSenderParams ¶ added in v0.5.0
func (m *Payment) GetTicketSenderParams() []*TicketSenderParams
func (*Payment) ProtoMessage ¶ added in v0.5.0
func (*Payment) ProtoMessage()
func (*Payment) XXX_DiscardUnknown ¶ added in v0.5.0
func (m *Payment) XXX_DiscardUnknown()
func (*Payment) XXX_Marshal ¶ added in v0.5.0
func (*Payment) XXX_Unmarshal ¶ added in v0.5.0
type PingPong ¶ added in v0.5.0
type PingPong struct { // Implementation defined Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PingPong) Descriptor ¶ added in v0.5.0
func (*PingPong) ProtoMessage ¶ added in v0.5.0
func (*PingPong) ProtoMessage()
func (*PingPong) XXX_DiscardUnknown ¶ added in v0.5.0
func (m *PingPong) XXX_DiscardUnknown()
func (*PingPong) XXX_Marshal ¶ added in v0.5.0
func (*PingPong) XXX_Unmarshal ¶ added in v0.5.0
type PriceInfo ¶ added in v0.5.0
type PriceInfo struct { // price in wei PricePerUnit int64 `protobuf:"varint,1,opt,name=pricePerUnit,proto3" json:"pricePerUnit,omitempty"` // Pixels covered in the price // Set price to 1 wei and pixelsPerUnit > 1 to have a smaller price granularity per pixel than 1 wei PixelsPerUnit int64 `protobuf:"varint,2,opt,name=pixelsPerUnit,proto3" json:"pixelsPerUnit,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
PriceInfo conveys pricing info for transcoding services
func (*PriceInfo) Descriptor ¶ added in v0.5.0
func (*PriceInfo) GetPixelsPerUnit ¶ added in v0.5.0
func (*PriceInfo) GetPricePerUnit ¶ added in v0.5.0
func (*PriceInfo) ProtoMessage ¶ added in v0.5.0
func (*PriceInfo) ProtoMessage()
func (*PriceInfo) XXX_DiscardUnknown ¶ added in v0.5.0
func (m *PriceInfo) XXX_DiscardUnknown()
func (*PriceInfo) XXX_Marshal ¶ added in v0.5.0
func (*PriceInfo) XXX_Unmarshal ¶ added in v0.5.0
type QueueTicketRes ¶ added in v0.5.9
type QueueTicketRes struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*QueueTicketRes) Descriptor ¶ added in v0.5.9
func (*QueueTicketRes) Descriptor() ([]byte, []int)
func (*QueueTicketRes) ProtoMessage ¶ added in v0.5.9
func (*QueueTicketRes) ProtoMessage()
func (*QueueTicketRes) Reset ¶ added in v0.5.9
func (m *QueueTicketRes) Reset()
func (*QueueTicketRes) String ¶ added in v0.5.9
func (m *QueueTicketRes) String() string
func (*QueueTicketRes) XXX_DiscardUnknown ¶ added in v0.5.9
func (m *QueueTicketRes) XXX_DiscardUnknown()
func (*QueueTicketRes) XXX_Marshal ¶ added in v0.5.9
func (m *QueueTicketRes) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueueTicketRes) XXX_Merge ¶ added in v0.5.9
func (m *QueueTicketRes) XXX_Merge(src proto.Message)
func (*QueueTicketRes) XXX_Size ¶ added in v0.5.9
func (m *QueueTicketRes) XXX_Size() int
func (*QueueTicketRes) XXX_Unmarshal ¶ added in v0.5.9
func (m *QueueTicketRes) XXX_Unmarshal(b []byte) error
type RegisterRequest ¶ added in v0.5.0
type RegisterRequest struct { // Shared secret for auth Secret string `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"` // Transcoder capacity Capacity int64 `protobuf:"varint,2,opt,name=capacity,proto3" json:"capacity,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Sent by the transcoder to register itself to the orchestrator.
func (*RegisterRequest) Descriptor ¶ added in v0.5.0
func (*RegisterRequest) Descriptor() ([]byte, []int)
func (*RegisterRequest) GetCapacity ¶ added in v0.5.0
func (m *RegisterRequest) GetCapacity() int64
func (*RegisterRequest) GetSecret ¶ added in v0.5.0
func (m *RegisterRequest) GetSecret() string
func (*RegisterRequest) ProtoMessage ¶ added in v0.5.0
func (*RegisterRequest) ProtoMessage()
func (*RegisterRequest) Reset ¶ added in v0.5.0
func (m *RegisterRequest) Reset()
func (*RegisterRequest) String ¶ added in v0.5.0
func (m *RegisterRequest) String() string
func (*RegisterRequest) XXX_DiscardUnknown ¶ added in v0.5.0
func (m *RegisterRequest) XXX_DiscardUnknown()
func (*RegisterRequest) XXX_Marshal ¶ added in v0.5.0
func (m *RegisterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RegisterRequest) XXX_Merge ¶ added in v0.5.0
func (m *RegisterRequest) XXX_Merge(src proto.Message)
func (*RegisterRequest) XXX_Size ¶ added in v0.5.0
func (m *RegisterRequest) XXX_Size() int
func (*RegisterRequest) XXX_Unmarshal ¶ added in v0.5.0
func (m *RegisterRequest) XXX_Unmarshal(b []byte) error
type RemoteTranscoderInfo ¶ added in v0.5.0
type S3OSInfo ¶ added in v0.5.0
type S3OSInfo struct { // Host to use to connect to S3 Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` // Key (prefix) to use when uploading the object. Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` // POST policy that S3 owner node creates to give write access to other node. Policy string `protobuf:"bytes,3,opt,name=policy,proto3" json:"policy,omitempty"` // Signature for POST policy. Signature string `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"` // Needed for POST policy. Credential string `protobuf:"bytes,5,opt,name=credential,proto3" json:"credential,omitempty"` // Needed for POST policy. XAmzDate string `protobuf:"bytes,6,opt,name=xAmzDate,proto3" json:"xAmzDate,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*S3OSInfo) Descriptor ¶ added in v0.5.0
func (*S3OSInfo) GetCredential ¶ added in v0.5.0
func (*S3OSInfo) GetSignature ¶ added in v0.5.0
func (*S3OSInfo) GetXAmzDate ¶ added in v0.5.0
func (*S3OSInfo) ProtoMessage ¶ added in v0.5.0
func (*S3OSInfo) ProtoMessage()
func (*S3OSInfo) XXX_DiscardUnknown ¶ added in v0.5.0
func (m *S3OSInfo) XXX_DiscardUnknown()
func (*S3OSInfo) XXX_Marshal ¶ added in v0.5.0
func (*S3OSInfo) XXX_Unmarshal ¶ added in v0.5.0
type SceneClassificationData ¶ added in v0.5.19
type SceneClassificationData struct { // Probability that the segment is detected as a particular classID (uint32) ClassProbs map[uint32]float64 `` /* 182-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
[EXPERIMENTAL] Describes scene classification results
func (*SceneClassificationData) Descriptor ¶ added in v0.5.19
func (*SceneClassificationData) Descriptor() ([]byte, []int)
func (*SceneClassificationData) GetClassProbs ¶ added in v0.5.19
func (m *SceneClassificationData) GetClassProbs() map[uint32]float64
func (*SceneClassificationData) ProtoMessage ¶ added in v0.5.19
func (*SceneClassificationData) ProtoMessage()
func (*SceneClassificationData) Reset ¶ added in v0.5.19
func (m *SceneClassificationData) Reset()
func (*SceneClassificationData) String ¶ added in v0.5.19
func (m *SceneClassificationData) String() string
func (*SceneClassificationData) XXX_DiscardUnknown ¶ added in v0.5.19
func (m *SceneClassificationData) XXX_DiscardUnknown()
func (*SceneClassificationData) XXX_Marshal ¶ added in v0.5.19
func (m *SceneClassificationData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SceneClassificationData) XXX_Merge ¶ added in v0.5.19
func (m *SceneClassificationData) XXX_Merge(src proto.Message)
func (*SceneClassificationData) XXX_Size ¶ added in v0.5.19
func (m *SceneClassificationData) XXX_Size() int
func (*SceneClassificationData) XXX_Unmarshal ¶ added in v0.5.19
func (m *SceneClassificationData) XXX_Unmarshal(b []byte) error
type SceneClassificationProfile ¶ added in v0.5.19
type SceneClassificationProfile struct { // Sample rate of the frames picked by the O for scene detection SampleRate uint32 `protobuf:"varint,1,opt,name=sample_rate,json=sampleRate,proto3" json:"sample_rate,omitempty"` // List of output classes the model is trained to detect Classes []*DetectorClass `protobuf:"bytes,2,rep,name=classes,proto3" json:"classes,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
[EXPERIMENTAL] Describes the scene classification configuration
func (*SceneClassificationProfile) Descriptor ¶ added in v0.5.19
func (*SceneClassificationProfile) Descriptor() ([]byte, []int)
func (*SceneClassificationProfile) GetClasses ¶ added in v0.5.19
func (m *SceneClassificationProfile) GetClasses() []*DetectorClass
func (*SceneClassificationProfile) GetSampleRate ¶ added in v0.5.19
func (m *SceneClassificationProfile) GetSampleRate() uint32
func (*SceneClassificationProfile) ProtoMessage ¶ added in v0.5.19
func (*SceneClassificationProfile) ProtoMessage()
func (*SceneClassificationProfile) Reset ¶ added in v0.5.19
func (m *SceneClassificationProfile) Reset()
func (*SceneClassificationProfile) String ¶ added in v0.5.19
func (m *SceneClassificationProfile) String() string
func (*SceneClassificationProfile) XXX_DiscardUnknown ¶ added in v0.5.19
func (m *SceneClassificationProfile) XXX_DiscardUnknown()
func (*SceneClassificationProfile) XXX_Marshal ¶ added in v0.5.19
func (m *SceneClassificationProfile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SceneClassificationProfile) XXX_Merge ¶ added in v0.5.19
func (m *SceneClassificationProfile) XXX_Merge(src proto.Message)
func (*SceneClassificationProfile) XXX_Size ¶ added in v0.5.19
func (m *SceneClassificationProfile) XXX_Size() int
func (*SceneClassificationProfile) XXX_Unmarshal ¶ added in v0.5.19
func (m *SceneClassificationProfile) XXX_Unmarshal(b []byte) error
type SegData ¶ added in v0.3.3
type SegData struct { // Manifest ID this segment belongs to ManifestId []byte `protobuf:"bytes,1,opt,name=manifestId,proto3" json:"manifestId,omitempty"` // Sequence number of the segment to be transcoded Seq int64 `protobuf:"varint,2,opt,name=seq,proto3" json:"seq,omitempty"` // Hash of the segment data to be transcoded Hash []byte `protobuf:"bytes,3,opt,name=hash,proto3" json:"hash,omitempty"` // Transcoding profiles to use Profiles []byte `protobuf:"bytes,4,opt,name=profiles,proto3" json:"profiles,omitempty"` // Broadcaster signature for the segment. Corresponds to: // broadcaster.sign(manifestId | seqNo | dataHash | profiles) Sig []byte `protobuf:"bytes,5,opt,name=sig,proto3" json:"sig,omitempty"` // Duration of the segment to be transcoded, in milliseconds Duration int32 `protobuf:"varint,6,opt,name=duration,proto3" json:"duration,omitempty"` // Capabilities used by this segment. Capabilities *Capabilities `protobuf:"bytes,7,opt,name=capabilities,proto3" json:"capabilities,omitempty"` // Data for transcoding authentication AuthToken *AuthToken `protobuf:"bytes,8,opt,name=auth_token,json=authToken,proto3" json:"auth_token,omitempty"` // [EXPERIMENTAL] // Detector enabled for this segment DetectorEnabled bool `protobuf:"varint,9,opt,name=detector_enabled,json=detectorEnabled,proto3" json:"detector_enabled,omitempty"` // Broadcaster's preferred storage medium(s) // XXX should we include this in a sig somewhere until certs are authenticated? Storage []*OSInfo `protobuf:"bytes,32,rep,name=storage,proto3" json:"storage,omitempty"` // Transcoding profiles to use. Supersedes `profiles` field // Deprecated by `fullProfiles2` but may still be used for mpegts formats FullProfiles []*VideoProfile `protobuf:"bytes,33,rep,name=fullProfiles,proto3" json:"fullProfiles,omitempty"` // Transcoding profiles to use. Supersedes `fullProfiles` field // Deprecated by `fullProfiles3` but may still be used for integer FPS FullProfiles2 []*VideoProfile `protobuf:"bytes,34,rep,name=fullProfiles2,proto3" json:"fullProfiles2,omitempty"` // Transcoding profiles to use. Supersedes `fullProfiles2` field FullProfiles3 []*VideoProfile `protobuf:"bytes,35,rep,name=fullProfiles3,proto3" json:"fullProfiles3,omitempty"` // [EXPERIMENTAL] // Detector profiles to use DetectorProfiles []*DetectorProfile `protobuf:"bytes,36,rep,name=detector_profiles,json=detectorProfiles,proto3" json:"detector_profiles,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Data included by the broadcaster when submitting a segment for transcoding.
func (*SegData) Descriptor ¶ added in v0.3.3
func (*SegData) GetAuthToken ¶ added in v0.5.11
func (*SegData) GetCapabilities ¶ added in v0.5.10
func (m *SegData) GetCapabilities() *Capabilities
func (*SegData) GetDetectorEnabled ¶ added in v0.5.19
func (*SegData) GetDetectorProfiles ¶ added in v0.5.19
func (m *SegData) GetDetectorProfiles() []*DetectorProfile
func (*SegData) GetDuration ¶ added in v0.5.9
func (*SegData) GetFullProfiles ¶ added in v0.5.2
func (m *SegData) GetFullProfiles() []*VideoProfile
func (*SegData) GetFullProfiles2 ¶ added in v0.5.6
func (m *SegData) GetFullProfiles2() []*VideoProfile
func (*SegData) GetFullProfiles3 ¶ added in v0.5.9
func (m *SegData) GetFullProfiles3() []*VideoProfile
func (*SegData) GetManifestId ¶ added in v0.5.0
func (*SegData) GetProfiles ¶ added in v0.5.0
func (*SegData) GetStorage ¶ added in v0.5.0
func (*SegData) ProtoMessage ¶ added in v0.3.3
func (*SegData) ProtoMessage()
func (*SegData) XXX_DiscardUnknown ¶ added in v0.3.3
func (m *SegData) XXX_DiscardUnknown()
func (*SegData) XXX_Marshal ¶ added in v0.3.3
func (*SegData) XXX_Unmarshal ¶ added in v0.3.3
type StreamInfo ¶ added in v0.5.15
type Ticket ¶ added in v0.5.9
type Ticket struct { TicketParams *TicketParams `protobuf:"bytes,1,opt,name=ticket_params,json=ticketParams,proto3" json:"ticket_params,omitempty"` Sender []byte `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"` ExpirationParams *TicketExpirationParams `protobuf:"bytes,3,opt,name=expiration_params,json=expirationParams,proto3" json:"expiration_params,omitempty"` SenderParams *TicketSenderParams `protobuf:"bytes,4,opt,name=sender_params,json=senderParams,proto3" json:"sender_params,omitempty"` RecipientRand []byte `protobuf:"bytes,5,opt,name=recipient_rand,json=recipientRand,proto3" json:"recipient_rand,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Ticket) Descriptor ¶ added in v0.5.9
func (*Ticket) GetExpirationParams ¶ added in v0.5.9
func (m *Ticket) GetExpirationParams() *TicketExpirationParams
func (*Ticket) GetRecipientRand ¶ added in v0.5.9
func (*Ticket) GetSenderParams ¶ added in v0.5.9
func (m *Ticket) GetSenderParams() *TicketSenderParams
func (*Ticket) GetTicketParams ¶ added in v0.5.9
func (m *Ticket) GetTicketParams() *TicketParams
func (*Ticket) ProtoMessage ¶ added in v0.5.9
func (*Ticket) ProtoMessage()
func (*Ticket) XXX_DiscardUnknown ¶ added in v0.5.9
func (m *Ticket) XXX_DiscardUnknown()
func (*Ticket) XXX_Marshal ¶ added in v0.5.9
func (*Ticket) XXX_Unmarshal ¶ added in v0.5.9
type TicketExpirationParams ¶ added in v0.5.0
type TicketExpirationParams struct { // Round during which tickets are created CreationRound int64 `protobuf:"varint,1,opt,name=creation_round,json=creationRound,proto3" json:"creation_round,omitempty"` // Block hash associated with creation_round CreationRoundBlockHash []byte `` /* 131-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Ticket params for expiration related validation
func (*TicketExpirationParams) Descriptor ¶ added in v0.5.0
func (*TicketExpirationParams) Descriptor() ([]byte, []int)
func (*TicketExpirationParams) GetCreationRound ¶ added in v0.5.0
func (m *TicketExpirationParams) GetCreationRound() int64
func (*TicketExpirationParams) GetCreationRoundBlockHash ¶ added in v0.5.0
func (m *TicketExpirationParams) GetCreationRoundBlockHash() []byte
func (*TicketExpirationParams) ProtoMessage ¶ added in v0.5.0
func (*TicketExpirationParams) ProtoMessage()
func (*TicketExpirationParams) Reset ¶ added in v0.5.0
func (m *TicketExpirationParams) Reset()
func (*TicketExpirationParams) String ¶ added in v0.5.0
func (m *TicketExpirationParams) String() string
func (*TicketExpirationParams) XXX_DiscardUnknown ¶ added in v0.5.0
func (m *TicketExpirationParams) XXX_DiscardUnknown()
func (*TicketExpirationParams) XXX_Marshal ¶ added in v0.5.0
func (m *TicketExpirationParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TicketExpirationParams) XXX_Merge ¶ added in v0.5.0
func (m *TicketExpirationParams) XXX_Merge(src proto.Message)
func (*TicketExpirationParams) XXX_Size ¶ added in v0.5.0
func (m *TicketExpirationParams) XXX_Size() int
func (*TicketExpirationParams) XXX_Unmarshal ¶ added in v0.5.0
func (m *TicketExpirationParams) XXX_Unmarshal(b []byte) error
type TicketParams ¶ added in v0.5.0
type TicketParams struct { // ETH address of the recipient Recipient []byte `protobuf:"bytes,1,opt,name=recipient,proto3" json:"recipient,omitempty"` // Pay out (in Wei) to the recipient if the ticket wins FaceValue []byte `protobuf:"bytes,2,opt,name=face_value,json=faceValue,proto3" json:"face_value,omitempty"` // Probability that the ticket wins WinProb []byte `protobuf:"bytes,3,opt,name=win_prob,json=winProb,proto3" json:"win_prob,omitempty"` // 32 byte keccak-256 hash commitment to a random number provided // by the recipient RecipientRandHash []byte `protobuf:"bytes,4,opt,name=recipient_rand_hash,json=recipientRandHash,proto3" json:"recipient_rand_hash,omitempty"` // Value generated by recipient that the recipient can use // to derive the random number corresponding to the recipient's hash commitment Seed []byte `protobuf:"bytes,5,opt,name=seed,proto3" json:"seed,omitempty"` // Block number at which the current set of advertised TicketParams is no longer valid ExpirationBlock []byte `protobuf:"bytes,6,opt,name=expiration_block,json=expirationBlock,proto3" json:"expiration_block,omitempty"` // Expected ticket expiration params ExpirationParams *TicketExpirationParams `protobuf:"bytes,7,opt,name=expiration_params,json=expirationParams,proto3" json:"expiration_params,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Required parameters for probabilistic micropayment tickets
func (*TicketParams) Descriptor ¶ added in v0.5.0
func (*TicketParams) Descriptor() ([]byte, []int)
func (*TicketParams) GetExpirationBlock ¶ added in v0.5.5
func (m *TicketParams) GetExpirationBlock() []byte
func (*TicketParams) GetExpirationParams ¶ added in v0.5.6
func (m *TicketParams) GetExpirationParams() *TicketExpirationParams
func (*TicketParams) GetFaceValue ¶ added in v0.5.0
func (m *TicketParams) GetFaceValue() []byte
func (*TicketParams) GetRecipient ¶ added in v0.5.0
func (m *TicketParams) GetRecipient() []byte
func (*TicketParams) GetRecipientRandHash ¶ added in v0.5.0
func (m *TicketParams) GetRecipientRandHash() []byte
func (*TicketParams) GetSeed ¶ added in v0.5.0
func (m *TicketParams) GetSeed() []byte
func (*TicketParams) GetWinProb ¶ added in v0.5.0
func (m *TicketParams) GetWinProb() []byte
func (*TicketParams) ProtoMessage ¶ added in v0.5.0
func (*TicketParams) ProtoMessage()
func (*TicketParams) Reset ¶ added in v0.5.0
func (m *TicketParams) Reset()
func (*TicketParams) String ¶ added in v0.5.0
func (m *TicketParams) String() string
func (*TicketParams) XXX_DiscardUnknown ¶ added in v0.5.0
func (m *TicketParams) XXX_DiscardUnknown()
func (*TicketParams) XXX_Marshal ¶ added in v0.5.0
func (m *TicketParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TicketParams) XXX_Merge ¶ added in v0.5.0
func (m *TicketParams) XXX_Merge(src proto.Message)
func (*TicketParams) XXX_Size ¶ added in v0.5.0
func (m *TicketParams) XXX_Size() int
func (*TicketParams) XXX_Unmarshal ¶ added in v0.5.0
func (m *TicketParams) XXX_Unmarshal(b []byte) error
type TicketRedeemerClient ¶ added in v0.5.9
type TicketRedeemerClient interface { QueueTicket(ctx context.Context, in *Ticket, opts ...grpc.CallOption) (*QueueTicketRes, error) MaxFloat(ctx context.Context, in *MaxFloatReq, opts ...grpc.CallOption) (*MaxFloatUpdate, error) MonitorMaxFloat(ctx context.Context, in *MaxFloatReq, opts ...grpc.CallOption) (TicketRedeemer_MonitorMaxFloatClient, error) }
TicketRedeemerClient is the client API for TicketRedeemer service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewTicketRedeemerClient ¶ added in v0.5.9
func NewTicketRedeemerClient(cc *grpc.ClientConn) TicketRedeemerClient
type TicketRedeemerServer ¶ added in v0.5.9
type TicketRedeemerServer interface { QueueTicket(context.Context, *Ticket) (*QueueTicketRes, error) MaxFloat(context.Context, *MaxFloatReq) (*MaxFloatUpdate, error) MonitorMaxFloat(*MaxFloatReq, TicketRedeemer_MonitorMaxFloatServer) error }
TicketRedeemerServer is the server API for TicketRedeemer service.
type TicketRedeemer_MonitorMaxFloatClient ¶ added in v0.5.9
type TicketRedeemer_MonitorMaxFloatClient interface { Recv() (*MaxFloatUpdate, error) grpc.ClientStream }
type TicketRedeemer_MonitorMaxFloatServer ¶ added in v0.5.9
type TicketRedeemer_MonitorMaxFloatServer interface { Send(*MaxFloatUpdate) error grpc.ServerStream }
type TicketSenderParams ¶ added in v0.5.0
type TicketSenderParams struct { // Monotonically increasing counter that makes the ticket // unique relative to a particular hash commitment to a recipient's random number SenderNonce uint32 `protobuf:"varint,1,opt,name=sender_nonce,json=senderNonce,proto3" json:"sender_nonce,omitempty"` // Sender signature over the ticket Sig []byte `protobuf:"bytes,2,opt,name=sig,proto3" json:"sig,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Sender Params (nonces and signatures)
func (*TicketSenderParams) Descriptor ¶ added in v0.5.0
func (*TicketSenderParams) Descriptor() ([]byte, []int)
func (*TicketSenderParams) GetSenderNonce ¶ added in v0.5.0
func (m *TicketSenderParams) GetSenderNonce() uint32
func (*TicketSenderParams) GetSig ¶ added in v0.5.0
func (m *TicketSenderParams) GetSig() []byte
func (*TicketSenderParams) ProtoMessage ¶ added in v0.5.0
func (*TicketSenderParams) ProtoMessage()
func (*TicketSenderParams) Reset ¶ added in v0.5.0
func (m *TicketSenderParams) Reset()
func (*TicketSenderParams) String ¶ added in v0.5.0
func (m *TicketSenderParams) String() string
func (*TicketSenderParams) XXX_DiscardUnknown ¶ added in v0.5.0
func (m *TicketSenderParams) XXX_DiscardUnknown()
func (*TicketSenderParams) XXX_Marshal ¶ added in v0.5.0
func (m *TicketSenderParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TicketSenderParams) XXX_Merge ¶ added in v0.5.0
func (m *TicketSenderParams) XXX_Merge(src proto.Message)
func (*TicketSenderParams) XXX_Size ¶ added in v0.5.0
func (m *TicketSenderParams) XXX_Size() int
func (*TicketSenderParams) XXX_Unmarshal ¶ added in v0.5.0
func (m *TicketSenderParams) XXX_Unmarshal(b []byte) error
type TranscodeData ¶ added in v0.3.3
type TranscodeData struct { // Transcoded data, in the order specified in the job options Segments []*TranscodedSegmentData `protobuf:"bytes,1,rep,name=segments,proto3" json:"segments,omitempty"` // Signature of the hash of the concatenated hashes Sig []byte `protobuf:"bytes,2,opt,name=sig,proto3" json:"sig,omitempty"` // [EXPERIMENTAL] // Detection result data in same order as SegData.detector_profiles Detections []*DetectData `protobuf:"bytes,3,rep,name=detections,proto3" json:"detections,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
A set of transcoded segments following the profiles specified in the job.
func (*TranscodeData) Descriptor ¶ added in v0.3.3
func (*TranscodeData) Descriptor() ([]byte, []int)
func (*TranscodeData) GetDetections ¶ added in v0.5.19
func (m *TranscodeData) GetDetections() []*DetectData
func (*TranscodeData) GetSegments ¶ added in v0.3.3
func (m *TranscodeData) GetSegments() []*TranscodedSegmentData
func (*TranscodeData) GetSig ¶ added in v0.3.3
func (m *TranscodeData) GetSig() []byte
func (*TranscodeData) ProtoMessage ¶ added in v0.3.3
func (*TranscodeData) ProtoMessage()
func (*TranscodeData) Reset ¶ added in v0.3.3
func (m *TranscodeData) Reset()
func (*TranscodeData) String ¶ added in v0.3.3
func (m *TranscodeData) String() string
func (*TranscodeData) XXX_DiscardUnknown ¶ added in v0.3.3
func (m *TranscodeData) XXX_DiscardUnknown()
func (*TranscodeData) XXX_Marshal ¶ added in v0.3.3
func (m *TranscodeData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TranscodeData) XXX_Merge ¶ added in v0.3.3
func (m *TranscodeData) XXX_Merge(src proto.Message)
func (*TranscodeData) XXX_Size ¶ added in v0.3.3
func (m *TranscodeData) XXX_Size() int
func (*TranscodeData) XXX_Unmarshal ¶ added in v0.3.3
func (m *TranscodeData) XXX_Unmarshal(b []byte) error
type TranscodeResult ¶ added in v0.3.3
type TranscodeResult struct { // Sequence number of the transcoded results. Seq int64 `protobuf:"varint,1,opt,name=seq,proto3" json:"seq,omitempty"` // Result of transcoding can be an error, or successful with more info // // Types that are valid to be assigned to Result: // *TranscodeResult_Error // *TranscodeResult_Data Result isTranscodeResult_Result `protobuf_oneof:"result"` // Used to notify a broadcaster of updated orchestrator information Info *OrchestratorInfo `protobuf:"bytes,16,opt,name=info,proto3" json:"info,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Response that a transcoder sends after transcoding a segment.
func (*TranscodeResult) Descriptor ¶ added in v0.3.3
func (*TranscodeResult) Descriptor() ([]byte, []int)
func (*TranscodeResult) GetData ¶ added in v0.3.3
func (m *TranscodeResult) GetData() *TranscodeData
func (*TranscodeResult) GetError ¶ added in v0.3.3
func (m *TranscodeResult) GetError() string
func (*TranscodeResult) GetInfo ¶ added in v0.5.0
func (m *TranscodeResult) GetInfo() *OrchestratorInfo
func (*TranscodeResult) GetResult ¶ added in v0.3.3
func (m *TranscodeResult) GetResult() isTranscodeResult_Result
func (*TranscodeResult) GetSeq ¶ added in v0.3.3
func (m *TranscodeResult) GetSeq() int64
func (*TranscodeResult) ProtoMessage ¶ added in v0.3.3
func (*TranscodeResult) ProtoMessage()
func (*TranscodeResult) Reset ¶ added in v0.3.3
func (m *TranscodeResult) Reset()
func (*TranscodeResult) String ¶ added in v0.3.3
func (m *TranscodeResult) String() string
func (*TranscodeResult) XXX_DiscardUnknown ¶ added in v0.3.3
func (m *TranscodeResult) XXX_DiscardUnknown()
func (*TranscodeResult) XXX_Marshal ¶ added in v0.3.3
func (m *TranscodeResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TranscodeResult) XXX_Merge ¶ added in v0.3.3
func (m *TranscodeResult) XXX_Merge(src proto.Message)
func (*TranscodeResult) XXX_OneofWrappers ¶ added in v0.5.0
func (*TranscodeResult) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*TranscodeResult) XXX_Size ¶ added in v0.3.3
func (m *TranscodeResult) XXX_Size() int
func (*TranscodeResult) XXX_Unmarshal ¶ added in v0.3.3
func (m *TranscodeResult) XXX_Unmarshal(b []byte) error
type TranscodeResult_Data ¶ added in v0.3.3
type TranscodeResult_Data struct {
Data *TranscodeData `protobuf:"bytes,3,opt,name=data,proto3,oneof"`
}
type TranscodeResult_Error ¶ added in v0.3.3
type TranscodeResult_Error struct {
Error string `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}
type TranscodedSegmentData ¶ added in v0.3.3
type TranscodedSegmentData struct { // URL where the transcoded data can be downloaded from. Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"` // Amount of pixels processed (output pixels) Pixels int64 `protobuf:"varint,2,opt,name=pixels,proto3" json:"pixels,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Individual transcoded segment data.
func (*TranscodedSegmentData) Descriptor ¶ added in v0.3.3
func (*TranscodedSegmentData) Descriptor() ([]byte, []int)
func (*TranscodedSegmentData) GetPixels ¶ added in v0.5.0
func (m *TranscodedSegmentData) GetPixels() int64
func (*TranscodedSegmentData) GetUrl ¶ added in v0.3.3
func (m *TranscodedSegmentData) GetUrl() string
func (*TranscodedSegmentData) ProtoMessage ¶ added in v0.3.3
func (*TranscodedSegmentData) ProtoMessage()
func (*TranscodedSegmentData) Reset ¶ added in v0.3.3
func (m *TranscodedSegmentData) Reset()
func (*TranscodedSegmentData) String ¶ added in v0.3.3
func (m *TranscodedSegmentData) String() string
func (*TranscodedSegmentData) XXX_DiscardUnknown ¶ added in v0.3.3
func (m *TranscodedSegmentData) XXX_DiscardUnknown()
func (*TranscodedSegmentData) XXX_Marshal ¶ added in v0.3.3
func (m *TranscodedSegmentData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TranscodedSegmentData) XXX_Merge ¶ added in v0.3.3
func (m *TranscodedSegmentData) XXX_Merge(src proto.Message)
func (*TranscodedSegmentData) XXX_Size ¶ added in v0.3.3
func (m *TranscodedSegmentData) XXX_Size() int
func (*TranscodedSegmentData) XXX_Unmarshal ¶ added in v0.3.3
func (m *TranscodedSegmentData) XXX_Unmarshal(b []byte) error
type TranscoderClient ¶ added in v0.5.0
type TranscoderClient interface { // Called by the transcoder to register to an orchestrator. The orchestrator // notifies registered transcoders of segments as they come in. RegisterTranscoder(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (Transcoder_RegisterTranscoderClient, error) }
TranscoderClient is the client API for Transcoder service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewTranscoderClient ¶ added in v0.5.0
func NewTranscoderClient(cc *grpc.ClientConn) TranscoderClient
type TranscoderServer ¶ added in v0.5.0
type TranscoderServer interface { // Called by the transcoder to register to an orchestrator. The orchestrator // notifies registered transcoders of segments as they come in. RegisterTranscoder(*RegisterRequest, Transcoder_RegisterTranscoderServer) error }
TranscoderServer is the server API for Transcoder service.
type Transcoder_RegisterTranscoderClient ¶ added in v0.5.0
type Transcoder_RegisterTranscoderClient interface { Recv() (*NotifySegment, error) grpc.ClientStream }
type Transcoder_RegisterTranscoderServer ¶ added in v0.5.0
type Transcoder_RegisterTranscoderServer interface { Send(*NotifySegment) error grpc.ServerStream }
type UnimplementedOrchestratorServer ¶ added in v0.5.0
type UnimplementedOrchestratorServer struct { }
UnimplementedOrchestratorServer can be embedded to have forward compatible implementations.
func (*UnimplementedOrchestratorServer) GetOrchestrator ¶ added in v0.5.0
func (*UnimplementedOrchestratorServer) GetOrchestrator(ctx context.Context, req *OrchestratorRequest) (*OrchestratorInfo, error)
type UnimplementedTicketRedeemerServer ¶ added in v0.5.9
type UnimplementedTicketRedeemerServer struct { }
UnimplementedTicketRedeemerServer can be embedded to have forward compatible implementations.
func (*UnimplementedTicketRedeemerServer) MaxFloat ¶ added in v0.5.9
func (*UnimplementedTicketRedeemerServer) MaxFloat(ctx context.Context, req *MaxFloatReq) (*MaxFloatUpdate, error)
func (*UnimplementedTicketRedeemerServer) MonitorMaxFloat ¶ added in v0.5.9
func (*UnimplementedTicketRedeemerServer) MonitorMaxFloat(req *MaxFloatReq, srv TicketRedeemer_MonitorMaxFloatServer) error
func (*UnimplementedTicketRedeemerServer) QueueTicket ¶ added in v0.5.9
func (*UnimplementedTicketRedeemerServer) QueueTicket(ctx context.Context, req *Ticket) (*QueueTicketRes, error)
type UnimplementedTranscoderServer ¶ added in v0.5.0
type UnimplementedTranscoderServer struct { }
UnimplementedTranscoderServer can be embedded to have forward compatible implementations.
func (*UnimplementedTranscoderServer) RegisterTranscoder ¶ added in v0.5.0
func (*UnimplementedTranscoderServer) RegisterTranscoder(req *RegisterRequest, srv Transcoder_RegisterTranscoderServer) error
type VideoProfile ¶ added in v0.5.2
type VideoProfile struct { // Name of VideoProfile Name string `protobuf:"bytes,16,opt,name=name,proto3" json:"name,omitempty"` // Width of VideoProfile Width int32 `protobuf:"varint,17,opt,name=width,proto3" json:"width,omitempty"` // Height of VideoProfile Height int32 `protobuf:"varint,18,opt,name=height,proto3" json:"height,omitempty"` // Bitrate of VideoProfile Bitrate int32 `protobuf:"varint,19,opt,name=bitrate,proto3" json:"bitrate,omitempty"` // FPS of VideoProfile Fps uint32 `protobuf:"varint,20,opt,name=fps,proto3" json:"fps,omitempty"` Format VideoProfile_Format `protobuf:"varint,21,opt,name=format,proto3,enum=net.VideoProfile_Format" json:"format,omitempty"` // FPS Denominator of VideoProfile FpsDen uint32 `protobuf:"varint,22,opt,name=fpsDen,proto3" json:"fpsDen,omitempty"` // Desired codec profile Profile VideoProfile_Profile `protobuf:"varint,23,opt,name=profile,proto3,enum=net.VideoProfile_Profile" json:"profile,omitempty"` // GOP interval Gop int32 `protobuf:"varint,24,opt,name=gop,proto3" json:"gop,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*VideoProfile) Descriptor ¶ added in v0.5.2
func (*VideoProfile) Descriptor() ([]byte, []int)
func (*VideoProfile) GetBitrate ¶ added in v0.5.2
func (m *VideoProfile) GetBitrate() int32
func (*VideoProfile) GetFormat ¶ added in v0.5.6
func (m *VideoProfile) GetFormat() VideoProfile_Format
func (*VideoProfile) GetFps ¶ added in v0.5.2
func (m *VideoProfile) GetFps() uint32
func (*VideoProfile) GetFpsDen ¶ added in v0.5.9
func (m *VideoProfile) GetFpsDen() uint32
func (*VideoProfile) GetGop ¶ added in v0.5.9
func (m *VideoProfile) GetGop() int32
func (*VideoProfile) GetHeight ¶ added in v0.5.2
func (m *VideoProfile) GetHeight() int32
func (*VideoProfile) GetName ¶ added in v0.5.2
func (m *VideoProfile) GetName() string
func (*VideoProfile) GetProfile ¶ added in v0.5.9
func (m *VideoProfile) GetProfile() VideoProfile_Profile
func (*VideoProfile) GetWidth ¶ added in v0.5.2
func (m *VideoProfile) GetWidth() int32
func (*VideoProfile) ProtoMessage ¶ added in v0.5.2
func (*VideoProfile) ProtoMessage()
func (*VideoProfile) Reset ¶ added in v0.5.2
func (m *VideoProfile) Reset()
func (*VideoProfile) String ¶ added in v0.5.2
func (m *VideoProfile) String() string
func (*VideoProfile) XXX_DiscardUnknown ¶ added in v0.5.2
func (m *VideoProfile) XXX_DiscardUnknown()
func (*VideoProfile) XXX_Marshal ¶ added in v0.5.2
func (m *VideoProfile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*VideoProfile) XXX_Merge ¶ added in v0.5.2
func (m *VideoProfile) XXX_Merge(src proto.Message)
func (*VideoProfile) XXX_Size ¶ added in v0.5.2
func (m *VideoProfile) XXX_Size() int
func (*VideoProfile) XXX_Unmarshal ¶ added in v0.5.2
func (m *VideoProfile) XXX_Unmarshal(b []byte) error
type VideoProfile_Format ¶ added in v0.5.6
type VideoProfile_Format int32
Desired output format
const ( VideoProfile_MPEGTS VideoProfile_Format = 0 VideoProfile_MP4 VideoProfile_Format = 1 )
func (VideoProfile_Format) EnumDescriptor ¶ added in v0.5.6
func (VideoProfile_Format) EnumDescriptor() ([]byte, []int)
func (VideoProfile_Format) String ¶ added in v0.5.6
func (x VideoProfile_Format) String() string
type VideoProfile_Profile ¶ added in v0.5.9
type VideoProfile_Profile int32
const ( VideoProfile_ENCODER_DEFAULT VideoProfile_Profile = 0 VideoProfile_H264_BASELINE VideoProfile_Profile = 1 VideoProfile_H264_MAIN VideoProfile_Profile = 2 VideoProfile_H264_HIGH VideoProfile_Profile = 3 VideoProfile_H264_CONSTRAINED_HIGH VideoProfile_Profile = 4 )
func (VideoProfile_Profile) EnumDescriptor ¶ added in v0.5.9
func (VideoProfile_Profile) EnumDescriptor() ([]byte, []int)
func (VideoProfile_Profile) String ¶ added in v0.5.9
func (x VideoProfile_Profile) String() string