net

package
v0.7.6-ai.alpha2 Latest Latest
Warning

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

 Go to latest Published: Aug 19, 2024 License: MIT Imports: 13 Imported by: 0

Documentation

Overview

Package net is a generated GoMock package.

Package net is a generated GoMock package.

Index

Constants

View Source 
const (
	Orchestrator_GetOrchestrator_FullMethodName       = "/net.Orchestrator/GetOrchestrator"
	Orchestrator_EndTranscodingSession_FullMethodName = "/net.Orchestrator/EndTranscodingSession"
	Orchestrator_Ping_FullMethodName                  = "/net.Orchestrator/Ping"
)
View Source 
const (
	Transcoder_RegisterTranscoder_FullMethodName = "/net.Transcoder/RegisterTranscoder"
)

Variables

View Source 
var File_net_redeemer_proto protoreflect.FileDescriptor
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 Orchestrator_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "net.Orchestrator",
	HandlerType: (*OrchestratorServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOrchestrator",
			Handler:    _Orchestrator_GetOrchestrator_Handler,
		},
		{
			MethodName: "EndTranscodingSession",
			Handler:    _Orchestrator_EndTranscodingSession_Handler,
		},
		{
			MethodName: "Ping",
			Handler:    _Orchestrator_Ping_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "net/lp_rpc.proto",
}

Orchestrator_ServiceDesc is the grpc.ServiceDesc for Orchestrator service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var TicketRedeemer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "net.TicketRedeemer",
	HandlerType: (*TicketRedeemerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "QueueTicket",
			Handler:    _TicketRedeemer_QueueTicket_Handler,
		},
		{
			MethodName: "MaxFloat",
			Handler:    _TicketRedeemer_MaxFloat_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "MonitorMaxFloat",
			Handler:       _TicketRedeemer_MonitorMaxFloat_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "net/redeemer.proto",
}

TicketRedeemer_ServiceDesc is the grpc.ServiceDesc for TicketRedeemer service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Transcoder_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "net.Transcoder",
	HandlerType: (*TranscoderServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "RegisterTranscoder",
			Handler:       _Transcoder_RegisterTranscoder_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "net/lp_rpc.proto",
}

Transcoder_ServiceDesc is the grpc.ServiceDesc for Transcoder service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

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.ServiceRegistrar, srv OrchestratorServer)

func RegisterTicketRedeemerServer added in v0.5.9 

func RegisterTicketRedeemerServer(s grpc.ServiceRegistrar, srv TicketRedeemerServer)

func RegisterTranscoderServer added in v0.5.0 

func RegisterTranscoderServer(s grpc.ServiceRegistrar, 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 */
	Version              string                    `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	Constraints          *Capabilities_Constraints `protobuf:"bytes,5,opt,name=constraints,proto3" json:"constraints,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*Capabilities) Descriptor added in v0.5.10 

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

func (*Capabilities) GetBitstring added in v0.5.10 

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

func (*Capabilities) GetCapacities added in v0.5.31 

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

func (*Capabilities) GetConstraints added in v0.7.5 

func (m *Capabilities) GetConstraints() *Capabilities_Constraints

func (*Capabilities) GetMandatories added in v0.5.10 

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

func (*Capabilities) GetVersion added in v0.7.5 

func (m *Capabilities) GetVersion() string

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_CapabilityConstraints added in v0.8.0 

type Capabilities_CapabilityConstraints struct {
	Models               map[string]*Capabilities_CapabilityConstraints_ModelConstraint `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                                       `json:"-"`
	XXX_unrecognized     []byte                                                         `json:"-"`
	XXX_sizecache        int32                                                          `json:"-"`
}

Non-binary capability constraints, such as supported ranges.

func (*Capabilities_CapabilityConstraints) Descriptor added in v0.8.0 

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

func (*Capabilities_CapabilityConstraints) GetModels added in v0.8.0 

func (m *Capabilities_CapabilityConstraints) GetModels() map[string]*Capabilities_CapabilityConstraints_ModelConstraint

func (*Capabilities_CapabilityConstraints) ProtoMessage added in v0.8.0 

func (*Capabilities_CapabilityConstraints) ProtoMessage()

func (*Capabilities_CapabilityConstraints) Reset added in v0.8.0 

func (m *Capabilities_CapabilityConstraints) Reset()

func (*Capabilities_CapabilityConstraints) String added in v0.8.0 

func (m *Capabilities_CapabilityConstraints) String() string

func (*Capabilities_CapabilityConstraints) XXX_DiscardUnknown 

func (m *Capabilities_CapabilityConstraints) XXX_DiscardUnknown()

func (*Capabilities_CapabilityConstraints) XXX_Marshal 

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

func (*Capabilities_CapabilityConstraints) XXX_Merge 

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

func (*Capabilities_CapabilityConstraints) XXX_Size 

func (m *Capabilities_CapabilityConstraints) XXX_Size() int

func (*Capabilities_CapabilityConstraints) XXX_Unmarshal 

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

type Capabilities_CapabilityConstraints_ModelConstraint added in v0.8.0 

type Capabilities_CapabilityConstraints_ModelConstraint struct {
	Warm                 bool     `protobuf:"varint,1,opt,name=warm,proto3" json:"warm,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Capabilities_CapabilityConstraints_ModelConstraint) Descriptor added in v0.8.0 

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

func (*Capabilities_CapabilityConstraints_ModelConstraint) GetWarm added in v0.8.0 

func (m *Capabilities_CapabilityConstraints_ModelConstraint) GetWarm() bool

func (*Capabilities_CapabilityConstraints_ModelConstraint) ProtoMessage added in v0.8.0 

func (*Capabilities_CapabilityConstraints_ModelConstraint) ProtoMessage()

func (*Capabilities_CapabilityConstraints_ModelConstraint) Reset added in v0.8.0 

func (m *Capabilities_CapabilityConstraints_ModelConstraint) Reset()

func (*Capabilities_CapabilityConstraints_ModelConstraint) String added in v0.8.0 

func (m *Capabilities_CapabilityConstraints_ModelConstraint) String() string

func (*Capabilities_CapabilityConstraints_ModelConstraint) XXX_DiscardUnknown 

func (m *Capabilities_CapabilityConstraints_ModelConstraint) XXX_DiscardUnknown()

func (*Capabilities_CapabilityConstraints_ModelConstraint) XXX_Marshal 

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

func (*Capabilities_CapabilityConstraints_ModelConstraint) XXX_Merge 

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

func (*Capabilities_CapabilityConstraints_ModelConstraint) XXX_Size 

func (m *Capabilities_CapabilityConstraints_ModelConstraint) XXX_Size() int

func (*Capabilities_CapabilityConstraints_ModelConstraint) XXX_Unmarshal 

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

type Capabilities_Constraints added in v0.5.10 

type Capabilities_Constraints struct {
	MinVersion           string                                         `protobuf:"bytes,1,opt,name=minVersion,proto3" json:"minVersion,omitempty"`
	PerCapability        map[uint32]*Capabilities_CapabilityConstraints `` /* 168-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                       `json:"-"`
	XXX_unrecognized     []byte                                         `json:"-"`
	XXX_sizecache        int32                                          `json:"-"`
}

Non-binary constraints.

func (*Capabilities_Constraints) Descriptor added in v0.5.10 

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

func (*Capabilities_Constraints) GetMinVersion added in v0.7.5 

func (m *Capabilities_Constraints) GetMinVersion() string

func (*Capabilities_Constraints) GetPerCapability added in v0.8.0 

func (m *Capabilities_Constraints) GetPerCapability() map[uint32]*Capabilities_CapabilityConstraints

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 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"`
	// contains filtered or unexported fields
}

func (*MaxFloatReq) Descriptor deprecated added in v0.5.9 

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

Deprecated: Use MaxFloatReq.ProtoReflect.Descriptor instead.

func (*MaxFloatReq) GetSender added in v0.5.9 

func (x *MaxFloatReq) GetSender() []byte

func (*MaxFloatReq) ProtoMessage added in v0.5.9 

func (*MaxFloatReq) ProtoMessage()

func (*MaxFloatReq) ProtoReflect added in v0.7.2 

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

func (*MaxFloatReq) Reset added in v0.5.9 

func (x *MaxFloatReq) Reset()

func (*MaxFloatReq) String added in v0.5.9 

func (x *MaxFloatReq) String() string

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"`
	// contains filtered or unexported fields
}

func (*MaxFloatUpdate) Descriptor deprecated added in v0.5.9 

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

Deprecated: Use MaxFloatUpdate.ProtoReflect.Descriptor instead.

func (*MaxFloatUpdate) GetMaxFloat added in v0.5.9 

func (x *MaxFloatUpdate) GetMaxFloat() []byte

func (*MaxFloatUpdate) ProtoMessage added in v0.5.9 

func (*MaxFloatUpdate) ProtoMessage()

func (*MaxFloatUpdate) ProtoReflect added in v0.7.2 

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

func (*MaxFloatUpdate) Reset added in v0.5.9 

func (x *MaxFloatUpdate) Reset()

func (*MaxFloatUpdate) String added in v0.5.9 

func (x *MaxFloatUpdate) String() string

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 MockUnsafeTicketRedeemerServer added in v0.7.2 

type MockUnsafeTicketRedeemerServer struct {
	// contains filtered or unexported fields
}

MockUnsafeTicketRedeemerServer is a mock of UnsafeTicketRedeemerServer interface.

func NewMockUnsafeTicketRedeemerServer added in v0.7.2 

func NewMockUnsafeTicketRedeemerServer(ctrl *gomock.Controller) *MockUnsafeTicketRedeemerServer

NewMockUnsafeTicketRedeemerServer creates a new mock instance.

func (*MockUnsafeTicketRedeemerServer) EXPECT added in v0.7.2 

func (m *MockUnsafeTicketRedeemerServer) EXPECT() *MockUnsafeTicketRedeemerServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockUnsafeTicketRedeemerServerMockRecorder added in v0.7.2 

type MockUnsafeTicketRedeemerServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockUnsafeTicketRedeemerServerMockRecorder is the mock recorder for MockUnsafeTicketRedeemerServer.

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

RPC calls implemented by the orchestrator

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"`
	// Features and constraints required by the broadcaster
	Capabilities         *Capabilities `protobuf:"bytes,3,opt,name=capabilities,proto3" json:"capabilities,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) GetCapabilities added in v0.8.0 

func (m *OrchestratorRequest) GetCapabilities() *Capabilities

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)
	// contains filtered or unexported methods
}

OrchestratorServer is the server API for Orchestrator service. All implementations must embed UnimplementedOrchestratorServer for forward compatibility.

RPC calls implemented by the orchestrator

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 {
	// contains filtered or unexported fields
}

func (*QueueTicketRes) Descriptor deprecated added in v0.5.9 

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

Deprecated: Use QueueTicketRes.ProtoReflect.Descriptor instead.

func (*QueueTicketRes) ProtoMessage added in v0.5.9 

func (*QueueTicketRes) ProtoMessage()

func (*QueueTicketRes) ProtoReflect added in v0.7.2 

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

func (*QueueTicketRes) Reset added in v0.5.9 

func (x *QueueTicketRes) Reset()

func (*QueueTicketRes) String added in v0.5.9 

func (x *QueueTicketRes) String() string

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 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"`
	// 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"`
	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) 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"`
	// contains filtered or unexported fields
}

func (*Ticket) Descriptor deprecated added in v0.5.9 

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

Deprecated: Use Ticket.ProtoReflect.Descriptor instead.

func (*Ticket) GetExpirationParams added in v0.5.9 

func (x *Ticket) GetExpirationParams() *TicketExpirationParams

func (*Ticket) GetRecipientRand added in v0.5.9 

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

func (*Ticket) GetSender added in v0.5.9 

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

func (*Ticket) GetSenderParams added in v0.5.9 

func (x *Ticket) GetSenderParams() *TicketSenderParams

func (*Ticket) GetTicketParams added in v0.5.9 

func (x *Ticket) GetTicketParams() *TicketParams

func (*Ticket) ProtoMessage added in v0.5.9 

func (*Ticket) ProtoMessage()

func (*Ticket) ProtoReflect added in v0.7.2 

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

func (*Ticket) Reset added in v0.5.9 

func (x *Ticket) Reset()

func (*Ticket) String added in v0.5.9 

func (x *Ticket) String() string

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#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
	// contains filtered or unexported methods
}

TicketRedeemerServer is the server API for TicketRedeemer service. All implementations must embed UnimplementedTicketRedeemerServer for forward compatibility

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"`
	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) 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) (grpc.ServerStreamingClient[NotifySegment], error)
}

TranscoderClient is the client API for Transcoder service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#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, grpc.ServerStreamingServer[NotifySegment]) error
	// contains filtered or unexported methods
}

TranscoderServer is the server API for Transcoder service. All implementations must embed UnimplementedTranscoderServer for forward compatibility.

type Transcoder_RegisterTranscoderClient added in v0.5.0 

type Transcoder_RegisterTranscoderClient = grpc.ServerStreamingClient[NotifySegment]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Transcoder_RegisterTranscoderServer added in v0.5.0 

type Transcoder_RegisterTranscoderServer = grpc.ServerStreamingServer[NotifySegment]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type UnimplementedOrchestratorServer added in v0.5.0 

type UnimplementedOrchestratorServer struct{}

UnimplementedOrchestratorServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedOrchestratorServer) EndTranscodingSession added in v0.5.35 

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

func (UnimplementedOrchestratorServer) GetOrchestrator added in v0.5.0 

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

func (UnimplementedOrchestratorServer) Ping added in v0.5.0 

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

type UnimplementedTicketRedeemerServer added in v0.5.9 

type UnimplementedTicketRedeemerServer struct {
}

UnimplementedTicketRedeemerServer must be embedded to have forward compatible implementations.

func (UnimplementedTicketRedeemerServer) MaxFloat added in v0.5.9 

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

func (UnimplementedTicketRedeemerServer) MonitorMaxFloat added in v0.5.9 

func (UnimplementedTicketRedeemerServer) MonitorMaxFloat(*MaxFloatReq, TicketRedeemer_MonitorMaxFloatServer) error

func (UnimplementedTicketRedeemerServer) QueueTicket added in v0.5.9 

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

type UnimplementedTranscoderServer added in v0.5.0 

type UnimplementedTranscoderServer struct{}

UnimplementedTranscoderServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedTranscoderServer) RegisterTranscoder added in v0.5.0 

func (UnimplementedTranscoderServer) RegisterTranscoder(*RegisterRequest, grpc.ServerStreamingServer[NotifySegment]) error

type UnsafeOrchestratorServer added in v0.7.2 

type UnsafeOrchestratorServer interface {
	// contains filtered or unexported methods
}

UnsafeOrchestratorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OrchestratorServer will result in compilation errors.

type UnsafeTicketRedeemerServer added in v0.7.2 

type UnsafeTicketRedeemerServer interface {
	// contains filtered or unexported methods
}

UnsafeTicketRedeemerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TicketRedeemerServer will result in compilation errors.

type UnsafeTranscoderServer added in v0.7.2 

type UnsafeTranscoderServer interface {
	// contains filtered or unexported methods
}

UnsafeTranscoderServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TranscoderServer will result in compilation errors.

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.