net

package
v0.7.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 10, 2023 License: MIT Imports: 10 Imported by: 1

Documentation

Overview

Package net is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var OSInfo_StorageType_name = map[int32]string{
	0: "DIRECT",
	1: "S3",
	2: "GOOGLE",
}
View Source 
var OSInfo_StorageType_value = map[string]int32{
	"DIRECT": 0,
	"S3":     1,
	"GOOGLE": 2,
}
View Source 
var VideoProfile_ChromaSubsampling_name = map[int32]string{
	0: "CHROMA_420",
	1: "CHROMA_422",
	2: "CHROMA_444",
}
View Source 
var VideoProfile_ChromaSubsampling_value = map[string]int32{
	"CHROMA_420": 0,
	"CHROMA_422": 1,
	"CHROMA_444": 2,
}
View Source 
var VideoProfile_Format_name = map[int32]string{
	0: "MPEGTS",
	1: "MP4",
}
View Source 
var VideoProfile_Format_value = map[string]int32{
	"MPEGTS": 0,
	"MP4":    1,
}
View Source 
var VideoProfile_Profile_name = map[int32]string{
	0: "ENCODER_DEFAULT",
	1: "H264_BASELINE",
	2: "H264_MAIN",
	3: "H264_HIGH",
	4: "H264_CONSTRAINED_HIGH",
}
View Source 
var VideoProfile_Profile_value = map[string]int32{
	"ENCODER_DEFAULT":       0,
	"H264_BASELINE":         1,
	"H264_MAIN":             2,
	"H264_HIGH":             3,
	"H264_CONSTRAINED_HIGH": 4,
}
View Source 
var VideoProfile_VideoCodec_name = map[int32]string{
	0: "H264",
	1: "H265",
	2: "VP8",
	3: "VP9",
}
View Source 
var VideoProfile_VideoCodec_value = map[string]int32{
	"H264": 0,
	"H265": 1,
	"VP8":  2,
	"VP9":  3,
}

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) Descriptor() ([]byte, []int)

func (*AuthToken) GetExpiration added in v0.5.11 

func (m *AuthToken) GetExpiration() int64

func (*AuthToken) GetSessionId added in v0.5.11 

func (m *AuthToken) GetSessionId() string

func (*AuthToken) GetToken added in v0.5.11 

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

func (*AuthToken) ProtoMessage added in v0.3.3 

func (*AuthToken) ProtoMessage()

func (*AuthToken) Reset added in v0.3.3 

func (m *AuthToken) Reset()

func (*AuthToken) String added in v0.3.3 

func (m *AuthToken) String() string

func (*AuthToken) XXX_DiscardUnknown added in v0.3.3 

func (m *AuthToken) XXX_DiscardUnknown()

func (*AuthToken) XXX_Marshal added in v0.3.3 

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

func (*AuthToken) XXX_Merge added in v0.3.3 

func (m *AuthToken) XXX_Merge(src proto.Message)

func (*AuthToken) XXX_Size added in v0.3.3 

func (m *AuthToken) XXX_Size() int

func (*AuthToken) XXX_Unmarshal added in v0.3.3 

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

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"`
	// Capacity corresponding to each capability
	Capacities           map[uint32]uint32 `` /* 163-byte string literal not displayed */
	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) GetCapacities added in v0.5.31 

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

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 EndTranscodingSessionRequest added in v0.5.35 

type EndTranscodingSessionRequest struct {
	// Data for transcoding authentication
	AuthToken            *AuthToken `protobuf:"bytes,1,opt,name=auth_token,json=authToken,proto3" json:"auth_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

sent by Broadcaster to Orchestrator to terminate the transcoding session and free resources (used for verification sessions)

func (*EndTranscodingSessionRequest) Descriptor added in v0.5.35 

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

func (*EndTranscodingSessionRequest) GetAuthToken added in v0.5.35 

func (m *EndTranscodingSessionRequest) GetAuthToken() *AuthToken

func (*EndTranscodingSessionRequest) ProtoMessage added in v0.5.35 

func (*EndTranscodingSessionRequest) ProtoMessage()

func (*EndTranscodingSessionRequest) Reset added in v0.5.35 

func (m *EndTranscodingSessionRequest) Reset()

func (*EndTranscodingSessionRequest) String added in v0.5.35 

func (m *EndTranscodingSessionRequest) String() string

func (*EndTranscodingSessionRequest) XXX_DiscardUnknown added in v0.5.35 

func (m *EndTranscodingSessionRequest) XXX_DiscardUnknown()

func (*EndTranscodingSessionRequest) XXX_Marshal added in v0.5.35 

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

func (*EndTranscodingSessionRequest) XXX_Merge added in v0.5.35 

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

func (*EndTranscodingSessionRequest) XXX_Size added in v0.5.35 

func (m *EndTranscodingSessionRequest) XXX_Size() int

func (*EndTranscodingSessionRequest) XXX_Unmarshal added in v0.5.35 

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

type EndTranscodingSessionResponse added in v0.5.35 

type EndTranscodingSessionResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EndTranscodingSessionResponse) Descriptor added in v0.5.35 

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

func (*EndTranscodingSessionResponse) ProtoMessage added in v0.5.35 

func (*EndTranscodingSessionResponse) ProtoMessage()

func (*EndTranscodingSessionResponse) Reset added in v0.5.35 

func (m *EndTranscodingSessionResponse) Reset()

func (*EndTranscodingSessionResponse) String added in v0.5.35 

func (m *EndTranscodingSessionResponse) String() string

func (*EndTranscodingSessionResponse) XXX_DiscardUnknown added in v0.5.35 

func (m *EndTranscodingSessionResponse) XXX_DiscardUnknown()

func (*EndTranscodingSessionResponse) XXX_Marshal added in v0.5.35 

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

func (*EndTranscodingSessionResponse) XXX_Merge added in v0.5.35 

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

func (*EndTranscodingSessionResponse) XXX_Size added in v0.5.35 

func (m *EndTranscodingSessionResponse) XXX_Size() int

func (*EndTranscodingSessionResponse) XXX_Unmarshal added in v0.5.35 

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

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 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) Descriptor() ([]byte, []int)

func (*OSInfo) GetS3Info added in v0.5.0 

func (m *OSInfo) GetS3Info() *S3OSInfo

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) Reset added in v0.5.0 

func (m *OSInfo) Reset()

func (*OSInfo) String added in v0.5.0 

func (m *OSInfo) String() string

func (*OSInfo) XXX_DiscardUnknown added in v0.5.0 

func (m *OSInfo) XXX_DiscardUnknown()

func (*OSInfo) XXX_Marshal added in v0.5.0 

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

func (*OSInfo) XXX_Merge added in v0.5.0 

func (m *OSInfo) XXX_Merge(src proto.Message)

func (*OSInfo) XXX_Size added in v0.5.0 

func (m *OSInfo) XXX_Size() int

func (*OSInfo) XXX_Unmarshal added in v0.5.0 

func (m *OSInfo) XXX_Unmarshal(b []byte) error

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)
	EndTranscodingSession(ctx context.Context, in *EndTranscodingSessionRequest, opts ...grpc.CallOption) (*EndTranscodingSessionResponse, 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.ClientConnInterface) 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)
	EndTranscodingSession(context.Context, *EndTranscodingSessionRequest) (*EndTranscodingSessionResponse, 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) Descriptor() ([]byte, []int)

func (*Payment) GetExpectedPrice added in v0.5.0 

func (m *Payment) GetExpectedPrice() *PriceInfo

func (*Payment) GetExpirationParams added in v0.5.0 

func (m *Payment) GetExpirationParams() *TicketExpirationParams

func (*Payment) GetSender added in v0.5.0 

func (m *Payment) GetSender() []byte

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) Reset added in v0.5.0 

func (m *Payment) Reset()

func (*Payment) String added in v0.5.0 

func (m *Payment) String() string

func (*Payment) XXX_DiscardUnknown added in v0.5.0 

func (m *Payment) XXX_DiscardUnknown()

func (*Payment) XXX_Marshal added in v0.5.0 

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

func (*Payment) XXX_Merge added in v0.5.0 

func (m *Payment) XXX_Merge(src proto.Message)

func (*Payment) XXX_Size added in v0.5.0 

func (m *Payment) XXX_Size() int

func (*Payment) XXX_Unmarshal added in v0.5.0 

func (m *Payment) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*PingPong) GetValue added in v0.5.0 

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

func (*PingPong) ProtoMessage added in v0.5.0 

func (*PingPong) ProtoMessage()

func (*PingPong) Reset added in v0.5.0 

func (m *PingPong) Reset()

func (*PingPong) String added in v0.5.0 

func (m *PingPong) String() string

func (*PingPong) XXX_DiscardUnknown added in v0.5.0 

func (m *PingPong) XXX_DiscardUnknown()

func (*PingPong) XXX_Marshal added in v0.5.0 

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

func (*PingPong) XXX_Merge added in v0.5.0 

func (m *PingPong) XXX_Merge(src proto.Message)

func (*PingPong) XXX_Size added in v0.5.0 

func (m *PingPong) XXX_Size() int

func (*PingPong) XXX_Unmarshal added in v0.5.0 

func (m *PingPong) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*PriceInfo) GetPixelsPerUnit added in v0.5.0 

func (m *PriceInfo) GetPixelsPerUnit() int64

func (*PriceInfo) GetPricePerUnit added in v0.5.0 

func (m *PriceInfo) GetPricePerUnit() int64

func (*PriceInfo) ProtoMessage added in v0.5.0 

func (*PriceInfo) ProtoMessage()

func (*PriceInfo) Reset added in v0.5.0 

func (m *PriceInfo) Reset()

func (*PriceInfo) String added in v0.5.0 

func (m *PriceInfo) String() string

func (*PriceInfo) XXX_DiscardUnknown added in v0.5.0 

func (m *PriceInfo) XXX_DiscardUnknown()

func (*PriceInfo) XXX_Marshal added in v0.5.0 

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

func (*PriceInfo) XXX_Merge added in v0.5.0 

func (m *PriceInfo) XXX_Merge(src proto.Message)

func (*PriceInfo) XXX_Size added in v0.5.0 

func (m *PriceInfo) XXX_Size() int

func (*PriceInfo) XXX_Unmarshal added in v0.5.0 

func (m *PriceInfo) XXX_Unmarshal(b []byte) error

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"`
	// Transcoder capabilities
	Capabilities         *Capabilities `protobuf:"bytes,3,opt,name=capabilities,proto3" json:"capabilities,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) GetCapabilities added in v0.5.28 

func (m *RegisterRequest) GetCapabilities() *Capabilities

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 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) Descriptor() ([]byte, []int)

func (*S3OSInfo) GetCredential added in v0.5.0 

func (m *S3OSInfo) GetCredential() string

func (*S3OSInfo) GetHost added in v0.5.0 

func (m *S3OSInfo) GetHost() string

func (*S3OSInfo) GetKey added in v0.5.0 

func (m *S3OSInfo) GetKey() string

func (*S3OSInfo) GetPolicy added in v0.5.0 

func (m *S3OSInfo) GetPolicy() string

func (*S3OSInfo) GetSignature added in v0.5.0 

func (m *S3OSInfo) GetSignature() string

func (*S3OSInfo) GetXAmzDate added in v0.5.0 

func (m *S3OSInfo) GetXAmzDate() string

func (*S3OSInfo) ProtoMessage added in v0.5.0 

func (*S3OSInfo) ProtoMessage()

func (*S3OSInfo) Reset added in v0.5.0 

func (m *S3OSInfo) Reset()

func (*S3OSInfo) String added in v0.5.0 

func (m *S3OSInfo) String() string

func (*S3OSInfo) XXX_DiscardUnknown added in v0.5.0 

func (m *S3OSInfo) XXX_DiscardUnknown()

func (*S3OSInfo) XXX_Marshal added in v0.5.0 

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

func (*S3OSInfo) XXX_Merge added in v0.5.0 

func (m *S3OSInfo) XXX_Merge(src proto.Message)

func (*S3OSInfo) XXX_Size added in v0.5.0 

func (m *S3OSInfo) XXX_Size() int

func (*S3OSInfo) XXX_Unmarshal added in v0.5.0 

func (m *S3OSInfo) XXX_Unmarshal(b []byte) error

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"`
	// Calculate perceptual hash for this segment
	CalcPerceptualHash bool `protobuf:"varint,10,opt,name=calc_perceptual_hash,json=calcPerceptualHash,proto3" json:"calc_perceptual_hash,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"`
	// Transcoding parameters specific to this segment
	SegmentParameters *SegParameters `protobuf:"bytes,37,opt,name=segment_parameters,json=segmentParameters,proto3" json:"segment_parameters,omitempty"`
	// Force HW Session Reinit
	ForceSessionReinit bool `protobuf:"varint,38,opt,name=ForceSessionReinit,proto3" json:"ForceSessionReinit,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) Descriptor() ([]byte, []int)

func (*SegData) GetAuthToken added in v0.5.11 

func (m *SegData) GetAuthToken() *AuthToken

func (*SegData) GetCalcPerceptualHash added in v0.5.21 

func (m *SegData) GetCalcPerceptualHash() bool

func (*SegData) GetCapabilities added in v0.5.10 

func (m *SegData) GetCapabilities() *Capabilities

func (*SegData) GetDetectorEnabled added in v0.5.19 

func (m *SegData) GetDetectorEnabled() bool

func (*SegData) GetDetectorProfiles added in v0.5.19 

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

func (*SegData) GetDuration added in v0.5.9 

func (m *SegData) GetDuration() int32

func (*SegData) GetForceSessionReinit added in v0.7.1 

func (m *SegData) GetForceSessionReinit() bool

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) GetHash added in v0.3.3 

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

func (*SegData) GetManifestId added in v0.5.0 

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

func (*SegData) GetProfiles added in v0.5.0 

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

func (*SegData) GetSegmentParameters added in v0.5.31 

func (m *SegData) GetSegmentParameters() *SegParameters

func (*SegData) GetSeq added in v0.3.3 

func (m *SegData) GetSeq() int64

func (*SegData) GetSig added in v0.3.3 

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

func (*SegData) GetStorage added in v0.5.0 

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

func (*SegData) ProtoMessage added in v0.3.3 

func (*SegData) ProtoMessage()

func (*SegData) Reset added in v0.3.3 

func (m *SegData) Reset()

func (*SegData) String added in v0.3.3 

func (m *SegData) String() string

func (*SegData) XXX_DiscardUnknown added in v0.3.3 

func (m *SegData) XXX_DiscardUnknown()

func (*SegData) XXX_Marshal added in v0.3.3 

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

func (*SegData) XXX_Merge added in v0.3.3 

func (m *SegData) XXX_Merge(src proto.Message)

func (*SegData) XXX_Size added in v0.3.3 

func (m *SegData) XXX_Size() int

func (*SegData) XXX_Unmarshal added in v0.3.3 

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

type SegParameters added in v0.5.31 

type SegParameters struct {
	// Start timestamp from which to start encoding
	// Milliseconds, from start of the file
	From uint64 `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"`
	// Skip all frames after that timestamp
	// Milliseconds, from start of the file
	To                   uint64   `protobuf:"varint,2,opt,name=to,proto3" json:"to,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SegParameters) Descriptor added in v0.5.31 

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

func (*SegParameters) GetFrom added in v0.5.31 

func (m *SegParameters) GetFrom() uint64

func (*SegParameters) GetTo added in v0.5.31 

func (m *SegParameters) GetTo() uint64

func (*SegParameters) ProtoMessage added in v0.5.31 

func (*SegParameters) ProtoMessage()

func (*SegParameters) Reset added in v0.5.31 

func (m *SegParameters) Reset()

func (*SegParameters) String added in v0.5.31 

func (m *SegParameters) String() string

func (*SegParameters) XXX_DiscardUnknown added in v0.5.31 

func (m *SegParameters) XXX_DiscardUnknown()

func (*SegParameters) XXX_Marshal added in v0.5.31 

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

func (*SegParameters) XXX_Merge added in v0.5.31 

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

func (*SegParameters) XXX_Size added in v0.5.31 

func (m *SegParameters) XXX_Size() int

func (*SegParameters) XXX_Unmarshal added in v0.5.31 

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

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) Descriptor() ([]byte, []int)

func (*Ticket) GetExpirationParams added in v0.5.9 

func (m *Ticket) GetExpirationParams() *TicketExpirationParams

func (*Ticket) GetRecipientRand added in v0.5.9 

func (m *Ticket) GetRecipientRand() []byte

func (*Ticket) GetSender added in v0.5.9 

func (m *Ticket) GetSender() []byte

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) Reset added in v0.5.9 

func (m *Ticket) Reset()

func (*Ticket) String added in v0.5.9 

func (m *Ticket) String() string

func (*Ticket) XXX_DiscardUnknown added in v0.5.9 

func (m *Ticket) XXX_DiscardUnknown()

func (*Ticket) XXX_Marshal added in v0.5.9 

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

func (*Ticket) XXX_Merge added in v0.5.9 

func (m *Ticket) XXX_Merge(src proto.Message)

func (*Ticket) XXX_Size added in v0.5.9 

func (m *Ticket) XXX_Size() int

func (*Ticket) XXX_Unmarshal added in v0.5.9 

func (m *Ticket) XXX_Unmarshal(b []byte) error

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.ClientConnInterface) 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"`
	// URL where the perceptual hash data can be downloaded from (can be empty)
	PerceptualHashUrl    string   `protobuf:"bytes,3,opt,name=perceptual_hash_url,json=perceptualHashUrl,proto3" json:"perceptual_hash_url,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) GetPerceptualHashUrl added in v0.5.21 

func (m *TranscodedSegmentData) GetPerceptualHashUrl() string

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.ClientConnInterface) 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) EndTranscodingSession added in v0.5.35 

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

func (*UnimplementedOrchestratorServer) GetOrchestrator added in v0.5.0 

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

func (*UnimplementedOrchestratorServer) Ping added in v0.5.0 

func (*UnimplementedOrchestratorServer) Ping(ctx context.Context, req *PingPong) (*PingPong, 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"`
	// Encoder (video codec)
	Encoder              VideoProfile_VideoCodec        `protobuf:"varint,25,opt,name=encoder,proto3,enum=net.VideoProfile_VideoCodec" json:"encoder,omitempty"`
	ColorDepth           int32                          `protobuf:"varint,26,opt,name=colorDepth,proto3" json:"colorDepth,omitempty"`
	ChromaFormat         VideoProfile_ChromaSubsampling `protobuf:"varint,27,opt,name=chromaFormat,proto3,enum=net.VideoProfile_ChromaSubsampling" json:"chromaFormat,omitempty"`
	Quality              uint32                         `protobuf:"varint,28,opt,name=quality,proto3" json:"quality,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) GetChromaFormat added in v0.5.30 

func (m *VideoProfile) GetChromaFormat() VideoProfile_ChromaSubsampling

func (*VideoProfile) GetColorDepth added in v0.5.30 

func (m *VideoProfile) GetColorDepth() int32

func (*VideoProfile) GetEncoder added in v0.5.28 

func (m *VideoProfile) GetEncoder() VideoProfile_VideoCodec

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) GetQuality added in v0.7.0 

func (m *VideoProfile) GetQuality() uint32

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_ChromaSubsampling added in v0.5.30 

type VideoProfile_ChromaSubsampling int32
const (
	VideoProfile_CHROMA_420 VideoProfile_ChromaSubsampling = 0
	VideoProfile_CHROMA_422 VideoProfile_ChromaSubsampling = 1
	VideoProfile_CHROMA_444 VideoProfile_ChromaSubsampling = 2
)

func (VideoProfile_ChromaSubsampling) EnumDescriptor added in v0.5.30 

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

func (VideoProfile_ChromaSubsampling) String added in v0.5.30 

func (x VideoProfile_ChromaSubsampling) String() string

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

type VideoProfile_VideoCodec added in v0.5.28 

type VideoProfile_VideoCodec int32
const (
	VideoProfile_H264 VideoProfile_VideoCodec = 0
	VideoProfile_H265 VideoProfile_VideoCodec = 1
	VideoProfile_VP8  VideoProfile_VideoCodec = 2
	VideoProfile_VP9  VideoProfile_VideoCodec = 3
)

func (VideoProfile_VideoCodec) EnumDescriptor added in v0.5.28 

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

func (VideoProfile_VideoCodec) String added in v0.5.28 

func (x VideoProfile_VideoCodec) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.