net

Nov 7, 2024

Changes in this version

+ const AIWorker_RegisterAIWorker_FullMethodName

+ const Orchestrator_EndTranscodingSession_FullMethodName

+ const Orchestrator_GetOrchestrator_FullMethodName

+ const Orchestrator_Ping_FullMethodName

+ const Transcoder_RegisterTranscoder_FullMethodName

+ var AIWorker_ServiceDesc = grpc.ServiceDesc

+ func RegisterAIWorkerServer(s grpc.ServiceRegistrar, srv AIWorkerServer)

+ type AIJobData struct

+ Pipeline string

+ RequestData []byte

+ func (*AIJobData) Descriptor() ([]byte, []int)

+ func (*AIJobData) ProtoMessage()

+ func (x *AIJobData) GetPipeline() string

+ func (x *AIJobData) GetRequestData() []byte

+ func (x *AIJobData) ProtoReflect() protoreflect.Message

+ func (x *AIJobData) Reset()

+ func (x *AIJobData) String() string

+ type AIWorkerClient interface

+ RegisterAIWorker func(ctx context.Context, in *RegisterAIWorkerRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[NotifyAIJob], error)

+ func NewAIWorkerClient(cc grpc.ClientConnInterface) AIWorkerClient

+ type AIWorkerServer interface

+ RegisterAIWorker func(*RegisterAIWorkerRequest, grpc.ServerStreamingServer[NotifyAIJob]) error

+ type AIWorker_RegisterAIWorkerClient = grpc.ServerStreamingClient[NotifyAIJob]

+ type AIWorker_RegisterAIWorkerServer = grpc.ServerStreamingServer[NotifyAIJob]

+ type Capabilities_CapabilityConstraints struct

+ Models map[string]*Capabilities_CapabilityConstraints_ModelConstraint

+ func (*Capabilities_CapabilityConstraints) Descriptor() ([]byte, []int)

+ func (*Capabilities_CapabilityConstraints) ProtoMessage()

+ func (x *Capabilities_CapabilityConstraints) GetModels() map[string]*Capabilities_CapabilityConstraints_ModelConstraint

+ func (x *Capabilities_CapabilityConstraints) ProtoReflect() protoreflect.Message

+ func (x *Capabilities_CapabilityConstraints) Reset()

+ func (x *Capabilities_CapabilityConstraints) String() string

+ type Capabilities_CapabilityConstraints_ModelConstraint struct

+ Capacity uint32

+ Warm bool

+ func (*Capabilities_CapabilityConstraints_ModelConstraint) Descriptor() ([]byte, []int)

+ func (*Capabilities_CapabilityConstraints_ModelConstraint) ProtoMessage()

+ func (x *Capabilities_CapabilityConstraints_ModelConstraint) GetCapacity() uint32

+ func (x *Capabilities_CapabilityConstraints_ModelConstraint) GetWarm() bool

+ func (x *Capabilities_CapabilityConstraints_ModelConstraint) ProtoReflect() protoreflect.Message

+ func (x *Capabilities_CapabilityConstraints_ModelConstraint) Reset()

+ func (x *Capabilities_CapabilityConstraints_ModelConstraint) String() string

type Capabilities_Constraints

+ PerCapability map[uint32]*Capabilities_CapabilityConstraints

+ func (x *Capabilities_Constraints) GetPerCapability() map[uint32]*Capabilities_CapabilityConstraints

+ type NotifyAIJob struct

+ AIJobData *AIJobData

+ TaskId int64

+ func (*NotifyAIJob) Descriptor() ([]byte, []int)

+ func (*NotifyAIJob) ProtoMessage()

+ func (x *NotifyAIJob) GetAIJobData() *AIJobData

+ func (x *NotifyAIJob) GetTaskId() int64

+ func (x *NotifyAIJob) ProtoReflect() protoreflect.Message

+ func (x *NotifyAIJob) Reset()

+ func (x *NotifyAIJob) String() string

type OrchestratorRequest

+ Capabilities *Capabilities

+ func (x *OrchestratorRequest) GetCapabilities() *Capabilities

+ type PaymentResult struct

+ Info *OrchestratorInfo

+ func (*PaymentResult) Descriptor() ([]byte, []int)

+ func (*PaymentResult) ProtoMessage()

+ func (x *PaymentResult) GetInfo() *OrchestratorInfo

+ func (x *PaymentResult) ProtoReflect() protoreflect.Message

+ func (x *PaymentResult) Reset()

+ func (x *PaymentResult) String() string

+ type RegisterAIWorkerRequest struct

+ Capabilities *Capabilities

+ Secret string

+ func (*RegisterAIWorkerRequest) Descriptor() ([]byte, []int)

+ func (*RegisterAIWorkerRequest) ProtoMessage()

+ func (x *RegisterAIWorkerRequest) GetCapabilities() *Capabilities

+ func (x *RegisterAIWorkerRequest) GetSecret() string

+ func (x *RegisterAIWorkerRequest) ProtoReflect() protoreflect.Message

+ func (x *RegisterAIWorkerRequest) Reset()

+ func (x *RegisterAIWorkerRequest) String() string

+ type UnimplementedAIWorkerServer struct

+ func (UnimplementedAIWorkerServer) RegisterAIWorker(*RegisterAIWorkerRequest, grpc.ServerStreamingServer[NotifyAIJob]) error

+ type UnsafeAIWorkerServer interface

Sep 10, 2024

Changes in this version

type NotifySegment

+ OrchId string

+ func (x *NotifySegment) GetOrchId() string

May 14, 2024

Changes in this version

type Capabilities

+ Constraints *Capabilities_Constraints

+ Version string

+ func (m *Capabilities) GetConstraints() *Capabilities_Constraints

+ func (m *Capabilities) GetVersion() string

type Capabilities_Constraints

+ MinVersion string

+ func (m *Capabilities_Constraints) GetMinVersion() string

Jan 29, 2024

Changes in this version

+ var File_net_lp_rpc_proto protoreflect.FileDescriptor

+ var File_net_redeemer_proto protoreflect.FileDescriptor

+ var Orchestrator_ServiceDesc = grpc.ServiceDesc

+ var TicketRedeemer_ServiceDesc = grpc.ServiceDesc

+ var Transcoder_ServiceDesc = grpc.ServiceDesc

type AuthToken

+ func (x *AuthToken) ProtoReflect() protoreflect.Message

type Capabilities

+ func (x *Capabilities) ProtoReflect() protoreflect.Message

type Capabilities_Constraints

+ func (x *Capabilities_Constraints) ProtoReflect() protoreflect.Message

type EndTranscodingSessionRequest

+ func (x *EndTranscodingSessionRequest) ProtoReflect() protoreflect.Message

type EndTranscodingSessionResponse

+ func (x *EndTranscodingSessionResponse) ProtoReflect() protoreflect.Message

type MaxFloatReq

+ func (x *MaxFloatReq) ProtoReflect() protoreflect.Message

type MaxFloatUpdate

+ func (x *MaxFloatUpdate) ProtoReflect() protoreflect.Message

+ type MockUnsafeTicketRedeemerServer struct

+ func NewMockUnsafeTicketRedeemerServer(ctrl *gomock.Controller) *MockUnsafeTicketRedeemerServer

+ func (m *MockUnsafeTicketRedeemerServer) EXPECT() *MockUnsafeTicketRedeemerServerMockRecorder

+ type MockUnsafeTicketRedeemerServerMockRecorder struct

type NotifySegment

+ func (x *NotifySegment) ProtoReflect() protoreflect.Message

type OSInfo

+ func (x *OSInfo) ProtoReflect() protoreflect.Message

type OSInfo_StorageType

+ func (OSInfo_StorageType) Descriptor() protoreflect.EnumDescriptor

+ func (OSInfo_StorageType) Type() protoreflect.EnumType

+ func (x OSInfo_StorageType) Enum() *OSInfo_StorageType

+ func (x OSInfo_StorageType) Number() protoreflect.EnumNumber

type OrchestratorInfo

+ func (x *OrchestratorInfo) ProtoReflect() protoreflect.Message

type OrchestratorRequest

+ func (x *OrchestratorRequest) ProtoReflect() protoreflect.Message

type Payment

+ func (x *Payment) ProtoReflect() protoreflect.Message

type PingPong

+ func (x *PingPong) ProtoReflect() protoreflect.Message

type PriceInfo

+ func (x *PriceInfo) ProtoReflect() protoreflect.Message

type QueueTicketRes

+ func (x *QueueTicketRes) ProtoReflect() protoreflect.Message

type RegisterRequest

+ func (x *RegisterRequest) ProtoReflect() protoreflect.Message

type S3OSInfo

+ func (x *S3OSInfo) ProtoReflect() protoreflect.Message

type SegData

+ func (x *SegData) ProtoReflect() protoreflect.Message

type SegParameters

+ func (x *SegParameters) ProtoReflect() protoreflect.Message

type Ticket

+ func (x *Ticket) ProtoReflect() protoreflect.Message

type TicketExpirationParams

+ func (x *TicketExpirationParams) ProtoReflect() protoreflect.Message

type TicketParams

+ func (x *TicketParams) ProtoReflect() protoreflect.Message

type TicketSenderParams

+ func (x *TicketSenderParams) ProtoReflect() protoreflect.Message

type TranscodeData

+ func (x *TranscodeData) ProtoReflect() protoreflect.Message

type TranscodeResult

+ func (x *TranscodeResult) ProtoReflect() protoreflect.Message

type TranscodedSegmentData

+ func (x *TranscodedSegmentData) ProtoReflect() protoreflect.Message

+ type UnsafeOrchestratorServer interface

+ type UnsafeTicketRedeemerServer interface

+ type UnsafeTranscoderServer interface

type VideoProfile

+ func (x *VideoProfile) ProtoReflect() protoreflect.Message

type VideoProfile_ChromaSubsampling

+ func (VideoProfile_ChromaSubsampling) Descriptor() protoreflect.EnumDescriptor

+ func (VideoProfile_ChromaSubsampling) Type() protoreflect.EnumType

+ func (x VideoProfile_ChromaSubsampling) Enum() *VideoProfile_ChromaSubsampling

+ func (x VideoProfile_ChromaSubsampling) Number() protoreflect.EnumNumber

type VideoProfile_Format

+ func (VideoProfile_Format) Descriptor() protoreflect.EnumDescriptor

+ func (VideoProfile_Format) Type() protoreflect.EnumType

+ func (x VideoProfile_Format) Enum() *VideoProfile_Format

+ func (x VideoProfile_Format) Number() protoreflect.EnumNumber

type VideoProfile_Profile

+ func (VideoProfile_Profile) Descriptor() protoreflect.EnumDescriptor

+ func (VideoProfile_Profile) Type() protoreflect.EnumType

+ func (x VideoProfile_Profile) Enum() *VideoProfile_Profile

+ func (x VideoProfile_Profile) Number() protoreflect.EnumNumber

type VideoProfile_VideoCodec

+ func (VideoProfile_VideoCodec) Descriptor() protoreflect.EnumDescriptor

+ func (VideoProfile_VideoCodec) Type() protoreflect.EnumType

+ func (x VideoProfile_VideoCodec) Enum() *VideoProfile_VideoCodec

+ func (x VideoProfile_VideoCodec) Number() protoreflect.EnumNumber

Oct 10, 2023

Changes in this version

type SegData

+ ForceSessionReinit bool

+ func (m *SegData) GetForceSessionReinit() bool

Oct 4, 2023

Changes in this version

type VideoProfile

+ Quality uint32

+ func (m *VideoProfile) GetQuality() uint32

Oct 21, 2022

Changes in this version

+ type EndTranscodingSessionRequest struct

+ AuthToken *AuthToken

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*EndTranscodingSessionRequest) Descriptor() ([]byte, []int)

+ func (*EndTranscodingSessionRequest) ProtoMessage()

+ func (m *EndTranscodingSessionRequest) GetAuthToken() *AuthToken

+ func (m *EndTranscodingSessionRequest) Reset()

+ func (m *EndTranscodingSessionRequest) String() string

+ func (m *EndTranscodingSessionRequest) XXX_DiscardUnknown()

+ func (m *EndTranscodingSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EndTranscodingSessionRequest) XXX_Merge(src proto.Message)

+ func (m *EndTranscodingSessionRequest) XXX_Size() int

+ func (m *EndTranscodingSessionRequest) XXX_Unmarshal(b []byte) error

+ type EndTranscodingSessionResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*EndTranscodingSessionResponse) Descriptor() ([]byte, []int)

+ func (*EndTranscodingSessionResponse) ProtoMessage()

+ func (m *EndTranscodingSessionResponse) Reset()

+ func (m *EndTranscodingSessionResponse) String() string

+ func (m *EndTranscodingSessionResponse) XXX_DiscardUnknown()

+ func (m *EndTranscodingSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EndTranscodingSessionResponse) XXX_Merge(src proto.Message)

+ func (m *EndTranscodingSessionResponse) XXX_Size() int

+ func (m *EndTranscodingSessionResponse) XXX_Unmarshal(b []byte) error

type OrchestratorClient

+ EndTranscodingSession func(ctx context.Context, in *EndTranscodingSessionRequest, opts ...grpc.CallOption) (*EndTranscodingSessionResponse, error)

type OrchestratorServer

+ EndTranscodingSession func(context.Context, *EndTranscodingSessionRequest) (*EndTranscodingSessionResponse, error)

type UnimplementedOrchestratorServer

+ func (*UnimplementedOrchestratorServer) EndTranscodingSession(ctx context.Context, req *EndTranscodingSessionRequest) (*EndTranscodingSessionResponse, error)

May 24, 2022

Changes in this version

type Capabilities

+ func (m *Capabilities) GetCapacities() map[uint32]uint32

type SegData

+ SegmentParameters *SegParameters

+ func (m *SegData) GetSegmentParameters() *SegParameters

+ type SegParameters struct

+ From uint64

+ To uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegParameters) Descriptor() ([]byte, []int)

+ func (*SegParameters) ProtoMessage()

+ func (m *SegParameters) GetFrom() uint64

+ func (m *SegParameters) GetTo() uint64

+ func (m *SegParameters) Reset()

+ func (m *SegParameters) String() string

+ func (m *SegParameters) XXX_DiscardUnknown()

+ func (m *SegParameters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SegParameters) XXX_Merge(src proto.Message)

+ func (m *SegParameters) XXX_Size() int

+ func (m *SegParameters) XXX_Unmarshal(b []byte) error

May 11, 2022

Changes in this version

+ var VideoProfile_ChromaSubsampling_name = map[int32]string

+ var VideoProfile_ChromaSubsampling_value = map[string]int32

type Capabilities

+ Capacities map[uint32]uint32

type VideoProfile

+ ChromaFormat VideoProfile_ChromaSubsampling

+ ColorDepth int32

+ func (m *VideoProfile) GetChromaFormat() VideoProfile_ChromaSubsampling

+ func (m *VideoProfile) GetColorDepth() int32

+ type VideoProfile_ChromaSubsampling int32

+ const VideoProfile_CHROMA_420

+ const VideoProfile_CHROMA_422

+ const VideoProfile_CHROMA_444

+ func (VideoProfile_ChromaSubsampling) EnumDescriptor() ([]byte, []int)

+ func (x VideoProfile_ChromaSubsampling) String() string

Feb 11, 2022

Changes in this version

+ var VideoProfile_VideoCodec_name = map[int32]string

+ var VideoProfile_VideoCodec_value = map[string]int32

type RegisterRequest

+ Capabilities *Capabilities

+ func (m *RegisterRequest) GetCapabilities() *Capabilities

type VideoProfile

+ Encoder VideoProfile_VideoCodec

+ func (m *VideoProfile) GetEncoder() VideoProfile_VideoCodec

+ type VideoProfile_VideoCodec int32

+ const VideoProfile_H264

+ const VideoProfile_H265

+ const VideoProfile_VP8

+ const VideoProfile_VP9

+ func (VideoProfile_VideoCodec) EnumDescriptor() ([]byte, []int)

+ func (x VideoProfile_VideoCodec) String() string

Sep 29, 2021

Changes in this version

type SegData

+ CalcPerceptualHash bool

+ func (m *SegData) GetCalcPerceptualHash() bool

type TranscodedSegmentData

+ PerceptualHashUrl string

+ func (m *TranscodedSegmentData) GetPerceptualHashUrl() string

Aug 10, 2021

Changes in this version

+ type DetectData struct

+ Value isDetectData_Value

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DetectData) Descriptor() ([]byte, []int)

+ func (*DetectData) ProtoMessage()

+ func (*DetectData) XXX_OneofWrappers() []interface{}

+ func (m *DetectData) GetSceneClassification() *SceneClassificationData

+ func (m *DetectData) GetValue() isDetectData_Value

+ 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 (m *DetectData) XXX_Size() int

+ func (m *DetectData) XXX_Unmarshal(b []byte) error

+ type DetectData_SceneClassification struct

+ SceneClassification *SceneClassificationData

+ type DetectorClass struct

+ ClassId uint32

+ ClassName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DetectorClass) Descriptor() ([]byte, []int)

+ func (*DetectorClass) ProtoMessage()

+ func (m *DetectorClass) GetClassId() uint32

+ func (m *DetectorClass) GetClassName() string

+ 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 struct

+ Value isDetectorProfile_Value

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DetectorProfile) Descriptor() ([]byte, []int)

+ func (*DetectorProfile) ProtoMessage()

+ func (*DetectorProfile) XXX_OneofWrappers() []interface{}

+ func (m *DetectorProfile) GetSceneClassification() *SceneClassificationProfile

+ func (m *DetectorProfile) GetValue() isDetectorProfile_Value

+ 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 (m *DetectorProfile) XXX_Size() int

+ func (m *DetectorProfile) XXX_Unmarshal(b []byte) error

+ type DetectorProfile_SceneClassification struct

+ SceneClassification *SceneClassificationProfile

+ type SceneClassificationData struct

+ ClassProbs map[uint32]float64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SceneClassificationData) Descriptor() ([]byte, []int)

+ func (*SceneClassificationData) ProtoMessage()

+ func (m *SceneClassificationData) GetClassProbs() map[uint32]float64

+ 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 struct

+ Classes []*DetectorClass

+ SampleRate uint32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SceneClassificationProfile) Descriptor() ([]byte, []int)

+ func (*SceneClassificationProfile) ProtoMessage()

+ func (m *SceneClassificationProfile) GetClasses() []*DetectorClass

+ func (m *SceneClassificationProfile) GetSampleRate() uint32

+ 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

+ DetectorEnabled bool

+ DetectorProfiles []*DetectorProfile

+ func (m *SegData) GetDetectorEnabled() bool

+ func (m *SegData) GetDetectorProfiles() []*DetectorProfile

type TranscodeData

+ Detections []*DetectData

+ func (m *TranscodeData) GetDetections() []*DetectData

Mar 15, 2021

Changes in this version

type NodeStatus

+ StreamInfo map[string]StreamInfo

+ type StreamInfo struct

+ SourceBytes uint64

+ TranscodedBytes uint64

Dec 14, 2020

Changes in this version

type NodeStatus

+ InternalManifests map[string]string

Oct 22, 2020

Changes in this version

type AuthToken

+ Expiration int64

+ SessionId string

+ Token []byte

+ func (m *AuthToken) GetExpiration() int64

+ func (m *AuthToken) GetSessionId() string

+ func (m *AuthToken) GetToken() []byte

type OrchestratorInfo

+ AuthToken *AuthToken

+ func (m *OrchestratorInfo) GetAuthToken() *AuthToken

type SegData

+ AuthToken *AuthToken

+ func (m *SegData) GetAuthToken() *AuthToken

Aug 6, 2020

Changes in this version

+ type Capabilities struct

+ Bitstring []uint64

+ Mandatories []uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Capabilities) Descriptor() ([]byte, []int)

+ func (*Capabilities) ProtoMessage()

+ func (m *Capabilities) GetBitstring() []uint64

+ func (m *Capabilities) GetMandatories() []uint64

+ 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 struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 OrchestratorInfo

+ Capabilities *Capabilities

+ func (m *OrchestratorInfo) GetCapabilities() *Capabilities

type SegData

+ Capabilities *Capabilities

+ func (m *SegData) GetCapabilities() *Capabilities

Jul 6, 2020

Changes in this version

+ var VideoProfile_Profile_name = map[int32]string

+ var VideoProfile_Profile_value = map[string]int32

+ func RegisterTicketRedeemerServer(s *grpc.Server, srv TicketRedeemerServer)

+ type MaxFloatReq struct

+ Sender []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*MaxFloatReq) Descriptor() ([]byte, []int)

+ func (*MaxFloatReq) ProtoMessage()

+ func (m *MaxFloatReq) GetSender() []byte

+ 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 struct

+ MaxFloat []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*MaxFloatUpdate) Descriptor() ([]byte, []int)

+ func (*MaxFloatUpdate) ProtoMessage()

+ func (m *MaxFloatUpdate) GetMaxFloat() []byte

+ 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 struct

+ func NewMockTicketRedeemerClient(ctrl *gomock.Controller) *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 struct

+ 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 struct

+ func NewMockTicketRedeemerServer(ctrl *gomock.Controller) *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 struct

+ func (mr *MockTicketRedeemerServerMockRecorder) MaxFloat(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockTicketRedeemerServerMockRecorder) MonitorMaxFloat(arg0, arg1 interface{}) *gomock.Call

+ func (mr *MockTicketRedeemerServerMockRecorder) QueueTicket(arg0, arg1 interface{}) *gomock.Call

+ type MockTicketRedeemer_MonitorMaxFloatClient struct

+ func NewMockTicketRedeemer_MonitorMaxFloatClient(ctrl *gomock.Controller) *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 *MockTicketRedeemer_MonitorMaxFloatClient) Trailer() metadata.MD

+ func (m_2 *MockTicketRedeemer_MonitorMaxFloatClient) RecvMsg(m interface{}) error

+ func (m_2 *MockTicketRedeemer_MonitorMaxFloatClient) SendMsg(m interface{}) error

+ type MockTicketRedeemer_MonitorMaxFloatClientMockRecorder struct

+ 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 struct

+ func NewMockTicketRedeemer_MonitorMaxFloatServer(ctrl *gomock.Controller) *MockTicketRedeemer_MonitorMaxFloatServer

+ func (m *MockTicketRedeemer_MonitorMaxFloatServer) Context() context.Context

+ func (m *MockTicketRedeemer_MonitorMaxFloatServer) EXPECT() *MockTicketRedeemer_MonitorMaxFloatServerMockRecorder

+ func (m *MockTicketRedeemer_MonitorMaxFloatServer) Send(arg0 *MaxFloatUpdate) error

+ func (m *MockTicketRedeemer_MonitorMaxFloatServer) SendHeader(arg0 metadata.MD) error

+ func (m *MockTicketRedeemer_MonitorMaxFloatServer) SetHeader(arg0 metadata.MD) error

+ func (m *MockTicketRedeemer_MonitorMaxFloatServer) SetTrailer(arg0 metadata.MD)

+ func (m_2 *MockTicketRedeemer_MonitorMaxFloatServer) RecvMsg(m interface{}) error

+ func (m_2 *MockTicketRedeemer_MonitorMaxFloatServer) SendMsg(m interface{}) error

+ type MockTicketRedeemer_MonitorMaxFloatServerMockRecorder struct

+ 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 NotifySegment

+ SegData *SegData

+ func (m *NotifySegment) GetSegData() *SegData

type OrchestratorInfo

+ Address []byte

+ func (m *OrchestratorInfo) GetAddress() []byte

+ type QueueTicketRes struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 SegData

+ Duration int32

+ FullProfiles3 []*VideoProfile

+ func (m *SegData) GetDuration() int32

+ func (m *SegData) GetFullProfiles3() []*VideoProfile

+ type Ticket struct

+ ExpirationParams *TicketExpirationParams

+ RecipientRand []byte

+ Sender []byte

+ SenderParams *TicketSenderParams

+ TicketParams *TicketParams

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Ticket) Descriptor() ([]byte, []int)

+ func (*Ticket) ProtoMessage()

+ 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 (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 TicketRedeemerClient interface

+ MaxFloat func(ctx context.Context, in *MaxFloatReq, opts ...grpc.CallOption) (*MaxFloatUpdate, error)

+ MonitorMaxFloat func(ctx context.Context, in *MaxFloatReq, opts ...grpc.CallOption) (TicketRedeemer_MonitorMaxFloatClient, error)

+ QueueTicket func(ctx context.Context, in *Ticket, opts ...grpc.CallOption) (*QueueTicketRes, error)

+ func NewTicketRedeemerClient(cc *grpc.ClientConn) TicketRedeemerClient

+ type TicketRedeemerServer interface

+ MaxFloat func(context.Context, *MaxFloatReq) (*MaxFloatUpdate, error)

+ MonitorMaxFloat func(*MaxFloatReq, TicketRedeemer_MonitorMaxFloatServer) error

+ QueueTicket func(context.Context, *Ticket) (*QueueTicketRes, error)

+ type TicketRedeemer_MonitorMaxFloatClient interface

+ Recv func() (*MaxFloatUpdate, error)

+ type TicketRedeemer_MonitorMaxFloatServer interface

+ Send func(*MaxFloatUpdate) error

+ type UnimplementedTicketRedeemerServer struct

+ 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 VideoProfile

+ FpsDen uint32

+ Gop int32

+ Profile VideoProfile_Profile

+ func (m *VideoProfile) GetFpsDen() uint32

+ func (m *VideoProfile) GetGop() int32

+ func (m *VideoProfile) GetProfile() VideoProfile_Profile

+ type VideoProfile_Profile int32

+ const VideoProfile_ENCODER_DEFAULT

+ const VideoProfile_H264_BASELINE

+ const VideoProfile_H264_CONSTRAINED_HIGH

+ const VideoProfile_H264_HIGH

+ const VideoProfile_H264_MAIN

+ func (VideoProfile_Profile) EnumDescriptor() ([]byte, []int)

+ func (x VideoProfile_Profile) String() string

Apr 21, 2020

Changes in this version

+ var VideoProfile_Format_name = map[int32]string

+ var VideoProfile_Format_value = map[string]int32

type SegData

+ FullProfiles2 []*VideoProfile

+ func (m *SegData) GetFullProfiles2() []*VideoProfile

type TicketParams

+ ExpirationParams *TicketExpirationParams

+ func (m *TicketParams) GetExpirationParams() *TicketExpirationParams

type VideoProfile

+ Format VideoProfile_Format

+ func (m *VideoProfile) GetFormat() VideoProfile_Format

+ type VideoProfile_Format int32

+ const VideoProfile_MP4

+ const VideoProfile_MPEGTS

+ func (VideoProfile_Format) EnumDescriptor() ([]byte, []int)

+ func (x VideoProfile_Format) String() string

Mar 12, 2020

Changes in this version

type TicketParams

+ ExpirationBlock []byte

+ func (m *TicketParams) GetExpirationBlock() []byte

Jan 11, 2020

Changes in this version

type NotifySegment

+ FullProfiles []*VideoProfile

+ func (m *NotifySegment) GetFullProfiles() []*VideoProfile

type SegData

+ FullProfiles []*VideoProfile

+ func (m *SegData) GetFullProfiles() []*VideoProfile

+ type VideoProfile struct

+ Bitrate int32

+ Fps uint32

+ Height int32

+ Name string

+ Width int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*VideoProfile) Descriptor() ([]byte, []int)

+ func (*VideoProfile) ProtoMessage()

+ func (m *VideoProfile) GetBitrate() int32

+ func (m *VideoProfile) GetFps() uint32

+ func (m *VideoProfile) GetHeight() int32

+ func (m *VideoProfile) GetName() string

+ func (m *VideoProfile) GetWidth() int32

+ 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

Dec 3, 2019

Changes in this version

type NotifySegment

+ Job string

+ func (m *NotifySegment) GetJob() string

Oct 29, 2019

Changes in this version

+ var OSInfo_StorageType_name = map[int32]string

+ var OSInfo_StorageType_value = map[string]int32

+ func RegisterTranscoderServer(s *grpc.Server, srv TranscoderServer)

type NodeStatus

+ GOArch string

+ GOOS string

+ GolangRuntimeVersion string

+ LocalTranscoding bool

+ OrchestratorPool []string

+ RegisteredTranscoders []RemoteTranscoderInfo

+ RegisteredTranscodersNumber int

+ Version string

+ type NotifySegment struct

+ Profiles []byte

+ TaskId int64

+ Url string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NotifySegment) Descriptor() ([]byte, []int)

+ func (*NotifySegment) ProtoMessage()

+ func (m *NotifySegment) GetProfiles() []byte

+ func (m *NotifySegment) GetTaskId() int64

+ func (m *NotifySegment) GetUrl() string

+ 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 struct

+ S3Info *S3OSInfo

+ StorageType OSInfo_StorageType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*OSInfo) Descriptor() ([]byte, []int)

+ func (*OSInfo) ProtoMessage()

+ func (m *OSInfo) GetS3Info() *S3OSInfo

+ func (m *OSInfo) GetStorageType() OSInfo_StorageType

+ 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 int32

+ const OSInfo_DIRECT

+ const OSInfo_GOOGLE

+ const OSInfo_S3

+ func (OSInfo_StorageType) EnumDescriptor() ([]byte, []int)

+ func (x OSInfo_StorageType) String() string

type OrchestratorClient

+ GetOrchestrator func(ctx context.Context, in *OrchestratorRequest, opts ...grpc.CallOption) (*OrchestratorInfo, error)

+ Ping func(ctx context.Context, in *PingPong, opts ...grpc.CallOption) (*PingPong, error)

+ type OrchestratorInfo struct

+ PriceInfo *PriceInfo

+ Storage []*OSInfo

+ TicketParams *TicketParams

+ Transcoder string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*OrchestratorInfo) Descriptor() ([]byte, []int)

+ func (*OrchestratorInfo) ProtoMessage()

+ func (m *OrchestratorInfo) GetPriceInfo() *PriceInfo

+ func (m *OrchestratorInfo) GetStorage() []*OSInfo

+ func (m *OrchestratorInfo) GetTicketParams() *TicketParams

+ func (m *OrchestratorInfo) GetTranscoder() string

+ 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 OrchestratorPool interface

+ GetOrchestrators func(int) ([]*OrchestratorInfo, error)

+ GetURLs func() []*url.URL

+ Size func() int

+ type OrchestratorRequest struct

+ Address []byte

+ Sig []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*OrchestratorRequest) Descriptor() ([]byte, []int)

+ func (*OrchestratorRequest) ProtoMessage()

+ func (m *OrchestratorRequest) GetAddress() []byte

+ func (m *OrchestratorRequest) GetSig() []byte

+ 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

+ GetOrchestrator func(context.Context, *OrchestratorRequest) (*OrchestratorInfo, error)

+ Ping func(context.Context, *PingPong) (*PingPong, error)

+ type Payment struct

+ ExpectedPrice *PriceInfo

+ ExpirationParams *TicketExpirationParams

+ Sender []byte

+ TicketParams *TicketParams

+ TicketSenderParams []*TicketSenderParams

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Payment) Descriptor() ([]byte, []int)

+ func (*Payment) ProtoMessage()

+ 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 (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 struct

+ Value []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PingPong) Descriptor() ([]byte, []int)

+ func (*PingPong) ProtoMessage()

+ func (m *PingPong) GetValue() []byte

+ 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 struct

+ PixelsPerUnit int64

+ PricePerUnit int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PriceInfo) Descriptor() ([]byte, []int)

+ func (*PriceInfo) ProtoMessage()

+ func (m *PriceInfo) GetPixelsPerUnit() int64

+ func (m *PriceInfo) GetPricePerUnit() int64

+ 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 RegisterRequest struct

+ Capacity int64

+ Secret string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RegisterRequest) Descriptor() ([]byte, []int)

+ func (*RegisterRequest) ProtoMessage()

+ func (m *RegisterRequest) GetCapacity() int64

+ func (m *RegisterRequest) GetSecret() string

+ 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 struct

+ Address string

+ Capacity int

+ type S3OSInfo struct

+ Credential string

+ Host string

+ Key string

+ Policy string

+ Signature string

+ XAmzDate string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*S3OSInfo) Descriptor() ([]byte, []int)

+ func (*S3OSInfo) ProtoMessage()

+ 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 (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 SegData

+ ManifestId []byte

+ Profiles []byte

+ Storage []*OSInfo

+ func (m *SegData) GetManifestId() []byte

+ func (m *SegData) GetProfiles() []byte

+ func (m *SegData) GetStorage() []*OSInfo

+ type TicketExpirationParams struct

+ CreationRound int64

+ CreationRoundBlockHash []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TicketExpirationParams) Descriptor() ([]byte, []int)

+ func (*TicketExpirationParams) ProtoMessage()

+ func (m *TicketExpirationParams) GetCreationRound() int64

+ func (m *TicketExpirationParams) GetCreationRoundBlockHash() []byte

+ 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 struct

+ FaceValue []byte

+ Recipient []byte

+ RecipientRandHash []byte

+ Seed []byte

+ WinProb []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TicketParams) Descriptor() ([]byte, []int)

+ func (*TicketParams) ProtoMessage()

+ 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 (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 TicketSenderParams struct

+ SenderNonce uint32

+ Sig []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TicketSenderParams) Descriptor() ([]byte, []int)

+ func (*TicketSenderParams) ProtoMessage()

+ func (m *TicketSenderParams) GetSenderNonce() uint32

+ func (m *TicketSenderParams) GetSig() []byte

+ 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 TranscodeResult

+ Info *OrchestratorInfo

+ func (*TranscodeResult) XXX_OneofWrappers() []interface{}

+ func (m *TranscodeResult) GetInfo() *OrchestratorInfo

type TranscodedSegmentData

+ Pixels int64

+ func (m *TranscodedSegmentData) GetPixels() int64

+ type TranscoderClient interface

+ RegisterTranscoder func(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (Transcoder_RegisterTranscoderClient, error)

+ func NewTranscoderClient(cc *grpc.ClientConn) TranscoderClient

+ type TranscoderServer interface

+ RegisterTranscoder func(*RegisterRequest, Transcoder_RegisterTranscoderServer) error

+ type Transcoder_RegisterTranscoderClient interface

+ Recv func() (*NotifySegment, error)

+ type Transcoder_RegisterTranscoderServer interface

+ Send func(*NotifySegment) error

+ type UnimplementedOrchestratorServer struct

+ func (*UnimplementedOrchestratorServer) GetOrchestrator(ctx context.Context, req *OrchestratorRequest) (*OrchestratorInfo, error)

+ func (*UnimplementedOrchestratorServer) Ping(ctx context.Context, req *PingPong) (*PingPong, error)

+ type UnimplementedTranscoderServer struct

+ func (*UnimplementedTranscoderServer) RegisterTranscoder(req *RegisterRequest, srv Transcoder_RegisterTranscoderServer) error

Mar 26, 2019

Changes in this version

+ func RegisterOrchestratorServer(s *grpc.Server, srv OrchestratorServer)

+ type AuthToken struct

+ JobId int64

+ Sig []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AuthToken) Descriptor() ([]byte, []int)

+ func (*AuthToken) ProtoMessage()

+ func (dst *AuthToken) XXX_Merge(src proto.Message)

+ func (m *AuthToken) GetJobId() int64

+ func (m *AuthToken) GetSig() []byte

+ 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_Size() int

+ func (m *AuthToken) XXX_Unmarshal(b []byte) error

+ type OrchestratorClient interface

+ GetTranscoder func(ctx context.Context, in *TranscoderRequest, opts ...grpc.CallOption) (*TranscoderInfo, error)

+ func NewOrchestratorClient(cc *grpc.ClientConn) OrchestratorClient

+ type OrchestratorServer interface

+ GetTranscoder func(context.Context, *TranscoderRequest) (*TranscoderInfo, error)

+ type SegData struct

+ Hash []byte

+ Seq int64

+ Sig []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegData) Descriptor() ([]byte, []int)

+ func (*SegData) ProtoMessage()

+ func (dst *SegData) XXX_Merge(src proto.Message)

+ func (m *SegData) GetHash() []byte

+ func (m *SegData) GetSeq() int64

+ func (m *SegData) GetSig() []byte

+ 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_Size() int

+ func (m *SegData) XXX_Unmarshal(b []byte) error

+ type TranscodeData struct

+ Segments []*TranscodedSegmentData

+ Sig []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TranscodeData) Descriptor() ([]byte, []int)

+ func (*TranscodeData) ProtoMessage()

+ func (dst *TranscodeData) XXX_Merge(src proto.Message)

+ func (m *TranscodeData) GetSegments() []*TranscodedSegmentData

+ func (m *TranscodeData) GetSig() []byte

+ 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_Size() int

+ func (m *TranscodeData) XXX_Unmarshal(b []byte) error

+ type TranscodeResult struct

+ Result isTranscodeResult_Result

+ Seq int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TranscodeResult) Descriptor() ([]byte, []int)

+ func (*TranscodeResult) ProtoMessage()

+ func (*TranscodeResult) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (dst *TranscodeResult) XXX_Merge(src proto.Message)

+ func (m *TranscodeResult) GetData() *TranscodeData

+ func (m *TranscodeResult) GetError() string

+ func (m *TranscodeResult) GetResult() isTranscodeResult_Result

+ func (m *TranscodeResult) GetSeq() int64

+ 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_Size() int

+ func (m *TranscodeResult) XXX_Unmarshal(b []byte) error

+ type TranscodeResult_Data struct

+ Data *TranscodeData

+ type TranscodeResult_Error struct

+ Error string

+ type TranscodedSegmentData struct

+ Url string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TranscodedSegmentData) Descriptor() ([]byte, []int)

+ func (*TranscodedSegmentData) ProtoMessage()

+ func (dst *TranscodedSegmentData) XXX_Merge(src proto.Message)

+ func (m *TranscodedSegmentData) GetUrl() string

+ 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_Size() int

+ func (m *TranscodedSegmentData) XXX_Unmarshal(b []byte) error

+ type TranscoderInfo struct

+ AuthType string

+ Credentials string

+ StreamIds map[string]string

+ Transcoder string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TranscoderInfo) Descriptor() ([]byte, []int)

+ func (*TranscoderInfo) ProtoMessage()

+ func (dst *TranscoderInfo) XXX_Merge(src proto.Message)

+ func (m *TranscoderInfo) GetAuthType() string

+ func (m *TranscoderInfo) GetCredentials() string

+ func (m *TranscoderInfo) GetStreamIds() map[string]string

+ func (m *TranscoderInfo) GetTranscoder() string

+ func (m *TranscoderInfo) Reset()

+ func (m *TranscoderInfo) String() string

+ func (m *TranscoderInfo) XXX_DiscardUnknown()

+ func (m *TranscoderInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TranscoderInfo) XXX_Size() int

+ func (m *TranscoderInfo) XXX_Unmarshal(b []byte) error

+ type TranscoderRequest struct

+ JobId int64

+ Sig []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TranscoderRequest) Descriptor() ([]byte, []int)

+ func (*TranscoderRequest) ProtoMessage()

+ func (dst *TranscoderRequest) XXX_Merge(src proto.Message)

+ func (m *TranscoderRequest) GetJobId() int64

+ func (m *TranscoderRequest) GetSig() []byte

+ func (m *TranscoderRequest) Reset()

+ func (m *TranscoderRequest) String() string

+ func (m *TranscoderRequest) XXX_DiscardUnknown()

+ func (m *TranscoderRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TranscoderRequest) XXX_Size() int

+ func (m *TranscoderRequest) XXX_Unmarshal(b []byte) error

Dec 18, 2017

Changes in this version

+ type Broadcaster interface

+ Broadcast func(seqNo uint64, data []byte) error

+ Finish func() error

+ IsWorking func() bool

+ String func() string

+ type NodeStatus struct

+ Manifests map[string]*m3u8.MasterPlaylist

+ NodeID string

+ func (n *NodeStatus) FromString(str string) error

+ func (n NodeStatus) String() string

+ type Subscriber interface

+ IsWorking func() bool

+ String func() string

+ Subscribe func(ctx context.Context, gotData func(seqNo uint64, data []byte, eof bool)) error

+ Unsubscribe func() error

+ type TranscodeConfig struct

+ JobID *big.Int

+ PerformOnchainClaim bool

+ Profiles []lpmscore.VideoProfile

+ StrmID string

+ type Transcoder interface

+ Transcode func(strmID string, config TranscodeConfig, gotPlaylist func(masterPlaylist []byte)) error

+ type VideoNetwork interface

+ Connect func(nodeID string, nodeAddr []string) error

+ GetBroadcaster func(strmID string) (Broadcaster, error)

+ GetMasterPlaylist func(nodeID string, manifestID string) (chan *m3u8.MasterPlaylist, error)

+ GetNodeID func() string

+ GetNodeStatus func(nodeID string) (chan *NodeStatus, error)

+ GetSubscriber func(strmID string) (Subscriber, error)

+ ReceivedTranscodeResponse func(manifestID string, gotResult func(transcodeResult map[string]string))

+ SendTranscodeResponse func(nodeID string, manifestID string, transcodeResult map[string]string) error

+ SetupProtocol func() error

+ String func() string

+ UpdateMasterPlaylist func(manifestID string, mpl *m3u8.MasterPlaylist) error