net

package
v0.7.4 Latest Latest
Warning

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

 Go to latest Published: Apr 2, 2024 License: MIT Imports: 10 Imported by: 1

Documentation

Overview

Package net is a generated GoMock package.

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",
	}
	OSInfo_StorageType_value = map[string]int32{
		"DIRECT": 0,
		"S3":     1,
		"GOOGLE": 2,
	}
)

Enum value maps for OSInfo_StorageType.

View Source 
var (
	VideoProfile_Format_name = map[int32]string{
		0: "MPEGTS",
		1: "MP4",
	}
	VideoProfile_Format_value = map[string]int32{
		"MPEGTS": 0,
		"MP4":    1,
	}
)

Enum value maps for VideoProfile_Format.

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",
	}
	VideoProfile_Profile_value = map[string]int32{
		"ENCODER_DEFAULT":       0,
		"H264_BASELINE":         1,
		"H264_MAIN":             2,
		"H264_HIGH":             3,
		"H264_CONSTRAINED_HIGH": 4,
	}
)

Enum value maps for VideoProfile_Profile.

View Source 
var (
	VideoProfile_VideoCodec_name = map[int32]string{
		0: "H264",
		1: "H265",
		2: "VP8",
		3: "VP9",
	}
	VideoProfile_VideoCodec_value = map[string]int32{
		"H264": 0,
		"H265": 1,
		"VP8":  2,
		"VP9":  3,
	}
)

Enum value maps for VideoProfile_VideoCodec.

View Source 
var (
	VideoProfile_ChromaSubsampling_name = map[int32]string{
		0: "CHROMA_420",
		1: "CHROMA_422",
		2: "CHROMA_444",
	}
	VideoProfile_ChromaSubsampling_value = map[string]int32{
		"CHROMA_420": 0,
		"CHROMA_422": 1,
		"CHROMA_444": 2,
	}
)

Enum value maps for VideoProfile_ChromaSubsampling.

View Source 
var File_net_lp_rpc_proto protoreflect.FileDescriptor
View Source 
var File_net_redeemer_proto protoreflect.FileDescriptor
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)

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

Data for transcoding authentication that is included in the OrchestratorInfo message during discovery

func (*AuthToken) Descriptor deprecated added in v0.3.3 

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

Deprecated: Use AuthToken.ProtoReflect.Descriptor instead.

func (*AuthToken) GetExpiration added in v0.5.11 

func (x *AuthToken) GetExpiration() int64

func (*AuthToken) GetSessionId added in v0.5.11 

func (x *AuthToken) GetSessionId() string

func (*AuthToken) GetToken added in v0.5.11 

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

func (*AuthToken) ProtoMessage added in v0.3.3 

func (*AuthToken) ProtoMessage()

func (*AuthToken) ProtoReflect added in v0.7.2 

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

func (*AuthToken) Reset added in v0.3.3 

func (x *AuthToken) Reset()

func (*AuthToken) String added in v0.3.3 

func (x *AuthToken) String() string

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

func (*Capabilities) Descriptor deprecated added in v0.5.10 

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

Deprecated: Use Capabilities.ProtoReflect.Descriptor instead.

func (*Capabilities) GetBitstring added in v0.5.10 

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

func (*Capabilities) GetCapacities added in v0.5.31 

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

func (*Capabilities) GetMandatories added in v0.5.10 

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

func (*Capabilities) ProtoMessage added in v0.5.10 

func (*Capabilities) ProtoMessage()

func (*Capabilities) ProtoReflect added in v0.7.2 

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

func (*Capabilities) Reset added in v0.5.10 

func (x *Capabilities) Reset()

func (*Capabilities) String added in v0.5.10 

func (x *Capabilities) String() string

type Capabilities_Constraints added in v0.5.10 

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

Non-binary capability constraints, such as supported ranges.

func (*Capabilities_Constraints) Descriptor deprecated added in v0.5.10 

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

Deprecated: Use Capabilities_Constraints.ProtoReflect.Descriptor instead.

func (*Capabilities_Constraints) ProtoMessage added in v0.5.10 

func (*Capabilities_Constraints) ProtoMessage()

func (*Capabilities_Constraints) ProtoReflect added in v0.7.2 

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

func (*Capabilities_Constraints) Reset added in v0.5.10 

func (x *Capabilities_Constraints) Reset()

func (*Capabilities_Constraints) String added in v0.5.10 

func (x *Capabilities_Constraints) String() string

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

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

func (*EndTranscodingSessionRequest) Descriptor deprecated added in v0.5.35 

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

Deprecated: Use EndTranscodingSessionRequest.ProtoReflect.Descriptor instead.

func (*EndTranscodingSessionRequest) GetAuthToken added in v0.5.35 

func (x *EndTranscodingSessionRequest) GetAuthToken() *AuthToken

func (*EndTranscodingSessionRequest) ProtoMessage added in v0.5.35 

func (*EndTranscodingSessionRequest) ProtoMessage()

func (*EndTranscodingSessionRequest) ProtoReflect added in v0.7.2 

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

func (*EndTranscodingSessionRequest) Reset added in v0.5.35 

func (x *EndTranscodingSessionRequest) Reset()

func (*EndTranscodingSessionRequest) String added in v0.5.35 

func (x *EndTranscodingSessionRequest) String() string

type EndTranscodingSessionResponse added in v0.5.35 

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

func (*EndTranscodingSessionResponse) Descriptor deprecated added in v0.5.35 

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

Deprecated: Use EndTranscodingSessionResponse.ProtoReflect.Descriptor instead.

func (*EndTranscodingSessionResponse) ProtoMessage added in v0.5.35 

func (*EndTranscodingSessionResponse) ProtoMessage()

func (*EndTranscodingSessionResponse) ProtoReflect added in v0.7.2 

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

func (*EndTranscodingSessionResponse) Reset added in v0.5.35 

func (x *EndTranscodingSessionResponse) Reset()

func (*EndTranscodingSessionResponse) String added in v0.5.35 

func (x *EndTranscodingSessionResponse) String() string

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

Sent by the orchestrator to the transcoder

func (*NotifySegment) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use NotifySegment.ProtoReflect.Descriptor instead.

func (*NotifySegment) GetProfiles added in v0.5.0 

func (x *NotifySegment) GetProfiles() []byte

func (*NotifySegment) GetSegData added in v0.5.9 

func (x *NotifySegment) GetSegData() *SegData

func (*NotifySegment) GetTaskId added in v0.5.0 

func (x *NotifySegment) GetTaskId() int64

func (*NotifySegment) GetUrl added in v0.5.0 

func (x *NotifySegment) GetUrl() string

func (*NotifySegment) ProtoMessage added in v0.5.0 

func (*NotifySegment) ProtoMessage()

func (*NotifySegment) ProtoReflect added in v0.7.2 

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

func (*NotifySegment) Reset added in v0.5.0 

func (x *NotifySegment) Reset()

func (*NotifySegment) String added in v0.5.0 

func (x *NotifySegment) String() string

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

OSInfo needed to negotiate storages that will be used. It carries info needed to write to the storage.

func (*OSInfo) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use OSInfo.ProtoReflect.Descriptor instead.

func (*OSInfo) GetS3Info added in v0.5.0 

func (x *OSInfo) GetS3Info() *S3OSInfo

func (*OSInfo) GetStorageType added in v0.5.0 

func (x *OSInfo) GetStorageType() OSInfo_StorageType

func (*OSInfo) ProtoMessage added in v0.5.0 

func (*OSInfo) ProtoMessage()

func (*OSInfo) ProtoReflect added in v0.7.2 

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

func (*OSInfo) Reset added in v0.5.0 

func (x *OSInfo) Reset()

func (*OSInfo) String added in v0.5.0 

func (x *OSInfo) String() string

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

func (OSInfo_StorageType) Descriptor() protoreflect.EnumDescriptor

func (OSInfo_StorageType) Enum added in v0.7.2 

func (x OSInfo_StorageType) Enum() *OSInfo_StorageType

func (OSInfo_StorageType) EnumDescriptor deprecated added in v0.5.0 

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

Deprecated: Use OSInfo_StorageType.Descriptor instead.

func (OSInfo_StorageType) Number added in v0.7.2 

func (x OSInfo_StorageType) Number() protoreflect.EnumNumber

func (OSInfo_StorageType) String added in v0.5.0 

func (x OSInfo_StorageType) String() string

func (OSInfo_StorageType) Type added in v0.7.2 

func (OSInfo_StorageType) Type() protoreflect.EnumType

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.

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

The orchestrator sends this in response to `GetOrchestrator`, containing miscellaneous data related to the job.

func (*OrchestratorInfo) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use OrchestratorInfo.ProtoReflect.Descriptor instead.

func (*OrchestratorInfo) GetAddress added in v0.5.9 

func (x *OrchestratorInfo) GetAddress() []byte

func (*OrchestratorInfo) GetAuthToken added in v0.5.11 

func (x *OrchestratorInfo) GetAuthToken() *AuthToken

func (*OrchestratorInfo) GetCapabilities added in v0.5.10 

func (x *OrchestratorInfo) GetCapabilities() *Capabilities

func (*OrchestratorInfo) GetPriceInfo added in v0.5.0 

func (x *OrchestratorInfo) GetPriceInfo() *PriceInfo

func (*OrchestratorInfo) GetStorage added in v0.5.0 

func (x *OrchestratorInfo) GetStorage() []*OSInfo

func (*OrchestratorInfo) GetTicketParams added in v0.5.0 

func (x *OrchestratorInfo) GetTicketParams() *TicketParams

func (*OrchestratorInfo) GetTranscoder added in v0.5.0 

func (x *OrchestratorInfo) GetTranscoder() string

func (*OrchestratorInfo) ProtoMessage added in v0.5.0 

func (*OrchestratorInfo) ProtoMessage()

func (*OrchestratorInfo) ProtoReflect added in v0.7.2 

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

func (*OrchestratorInfo) Reset added in v0.5.0 

func (x *OrchestratorInfo) Reset()

func (*OrchestratorInfo) String added in v0.5.0 

func (x *OrchestratorInfo) String() string

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

This request is sent by the broadcaster in `GetTranscoder` to request information on which transcoder to use.

func (*OrchestratorRequest) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use OrchestratorRequest.ProtoReflect.Descriptor instead.

func (*OrchestratorRequest) GetAddress added in v0.5.0 

func (x *OrchestratorRequest) GetAddress() []byte

func (*OrchestratorRequest) GetSig added in v0.5.0 

func (x *OrchestratorRequest) GetSig() []byte

func (*OrchestratorRequest) ProtoMessage added in v0.5.0 

func (*OrchestratorRequest) ProtoMessage()

func (*OrchestratorRequest) ProtoReflect added in v0.7.2 

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

func (*OrchestratorRequest) Reset added in v0.5.0 

func (x *OrchestratorRequest) Reset()

func (*OrchestratorRequest) String added in v0.5.0 

func (x *OrchestratorRequest) String() string

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

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

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

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

Deprecated: Use Payment.ProtoReflect.Descriptor instead.

func (*Payment) GetExpectedPrice added in v0.5.0 

func (x *Payment) GetExpectedPrice() *PriceInfo

func (*Payment) GetExpirationParams added in v0.5.0 

func (x *Payment) GetExpirationParams() *TicketExpirationParams

func (*Payment) GetSender added in v0.5.0 

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

func (*Payment) GetTicketParams added in v0.5.0 

func (x *Payment) GetTicketParams() *TicketParams

func (*Payment) GetTicketSenderParams added in v0.5.0 

func (x *Payment) GetTicketSenderParams() []*TicketSenderParams

func (*Payment) ProtoMessage added in v0.5.0 

func (*Payment) ProtoMessage()

func (*Payment) ProtoReflect added in v0.7.2 

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

func (*Payment) Reset added in v0.5.0 

func (x *Payment) Reset()

func (*Payment) String added in v0.5.0 

func (x *Payment) String() string

type PingPong added in v0.5.0 

type PingPong struct {

	// Implementation defined
	Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*PingPong) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use PingPong.ProtoReflect.Descriptor instead.

func (*PingPong) GetValue added in v0.5.0 

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

func (*PingPong) ProtoMessage added in v0.5.0 

func (*PingPong) ProtoMessage()

func (*PingPong) ProtoReflect added in v0.7.2 

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

func (*PingPong) Reset added in v0.5.0 

func (x *PingPong) Reset()

func (*PingPong) String added in v0.5.0 

func (x *PingPong) String() string

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

PriceInfo conveys pricing info for transcoding services

func (*PriceInfo) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use PriceInfo.ProtoReflect.Descriptor instead.

func (*PriceInfo) GetPixelsPerUnit added in v0.5.0 

func (x *PriceInfo) GetPixelsPerUnit() int64

func (*PriceInfo) GetPricePerUnit added in v0.5.0 

func (x *PriceInfo) GetPricePerUnit() int64

func (*PriceInfo) ProtoMessage added in v0.5.0 

func (*PriceInfo) ProtoMessage()

func (*PriceInfo) ProtoReflect added in v0.7.2 

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

func (*PriceInfo) Reset added in v0.5.0 

func (x *PriceInfo) Reset()

func (*PriceInfo) String added in v0.5.0 

func (x *PriceInfo) String() string

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

Sent by the transcoder to register itself to the orchestrator.

func (*RegisterRequest) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.

func (*RegisterRequest) GetCapabilities added in v0.5.28 

func (x *RegisterRequest) GetCapabilities() *Capabilities

func (*RegisterRequest) GetCapacity added in v0.5.0 

func (x *RegisterRequest) GetCapacity() int64

func (*RegisterRequest) GetSecret added in v0.5.0 

func (x *RegisterRequest) GetSecret() string

func (*RegisterRequest) ProtoMessage added in v0.5.0 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) ProtoReflect added in v0.7.2 

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

func (*RegisterRequest) Reset added in v0.5.0 

func (x *RegisterRequest) Reset()

func (*RegisterRequest) String added in v0.5.0 

func (x *RegisterRequest) String() string

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

func (*S3OSInfo) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use S3OSInfo.ProtoReflect.Descriptor instead.

func (*S3OSInfo) GetCredential added in v0.5.0 

func (x *S3OSInfo) GetCredential() string

func (*S3OSInfo) GetHost added in v0.5.0 

func (x *S3OSInfo) GetHost() string

func (*S3OSInfo) GetKey added in v0.5.0 

func (x *S3OSInfo) GetKey() string

func (*S3OSInfo) GetPolicy added in v0.5.0 

func (x *S3OSInfo) GetPolicy() string

func (*S3OSInfo) GetSignature added in v0.5.0 

func (x *S3OSInfo) GetSignature() string

func (*S3OSInfo) GetXAmzDate added in v0.5.0 

func (x *S3OSInfo) GetXAmzDate() string

func (*S3OSInfo) ProtoMessage added in v0.5.0 

func (*S3OSInfo) ProtoMessage()

func (*S3OSInfo) ProtoReflect added in v0.7.2 

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

func (*S3OSInfo) Reset added in v0.5.0 

func (x *S3OSInfo) Reset()

func (*S3OSInfo) String added in v0.5.0 

func (x *S3OSInfo) String() string

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

Data included by the broadcaster when submitting a segment for transcoding.

func (*SegData) Descriptor deprecated added in v0.3.3 

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

Deprecated: Use SegData.ProtoReflect.Descriptor instead.

func (*SegData) GetAuthToken added in v0.5.11 

func (x *SegData) GetAuthToken() *AuthToken

func (*SegData) GetCalcPerceptualHash added in v0.5.21 

func (x *SegData) GetCalcPerceptualHash() bool

func (*SegData) GetCapabilities added in v0.5.10 

func (x *SegData) GetCapabilities() *Capabilities

func (*SegData) GetDuration added in v0.5.9 

func (x *SegData) GetDuration() int32

func (*SegData) GetForceSessionReinit added in v0.7.1 

func (x *SegData) GetForceSessionReinit() bool

func (*SegData) GetFullProfiles added in v0.5.2 

func (x *SegData) GetFullProfiles() []*VideoProfile

func (*SegData) GetFullProfiles2 added in v0.5.6 

func (x *SegData) GetFullProfiles2() []*VideoProfile

func (*SegData) GetFullProfiles3 added in v0.5.9 

func (x *SegData) GetFullProfiles3() []*VideoProfile

func (*SegData) GetHash added in v0.3.3 

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

func (*SegData) GetManifestId added in v0.5.0 

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

func (*SegData) GetProfiles added in v0.5.0 

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

func (*SegData) GetSegmentParameters added in v0.5.31 

func (x *SegData) GetSegmentParameters() *SegParameters

func (*SegData) GetSeq added in v0.3.3 

func (x *SegData) GetSeq() int64

func (*SegData) GetSig added in v0.3.3 

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

func (*SegData) GetStorage added in v0.5.0 

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

func (*SegData) ProtoMessage added in v0.3.3 

func (*SegData) ProtoMessage()

func (*SegData) ProtoReflect added in v0.7.2 

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

func (*SegData) Reset added in v0.3.3 

func (x *SegData) Reset()

func (*SegData) String added in v0.3.3 

func (x *SegData) String() string

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

func (*SegParameters) Descriptor deprecated added in v0.5.31 

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

Deprecated: Use SegParameters.ProtoReflect.Descriptor instead.

func (*SegParameters) GetFrom added in v0.5.31 

func (x *SegParameters) GetFrom() uint64

func (*SegParameters) GetTo added in v0.5.31 

func (x *SegParameters) GetTo() uint64

func (*SegParameters) ProtoMessage added in v0.5.31 

func (*SegParameters) ProtoMessage()

func (*SegParameters) ProtoReflect added in v0.7.2 

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

func (*SegParameters) Reset added in v0.5.31 

func (x *SegParameters) Reset()

func (*SegParameters) String added in v0.5.31 

func (x *SegParameters) String() string

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

Ticket params for expiration related validation

func (*TicketExpirationParams) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use TicketExpirationParams.ProtoReflect.Descriptor instead.

func (*TicketExpirationParams) GetCreationRound added in v0.5.0 

func (x *TicketExpirationParams) GetCreationRound() int64

func (*TicketExpirationParams) GetCreationRoundBlockHash added in v0.5.0 

func (x *TicketExpirationParams) GetCreationRoundBlockHash() []byte

func (*TicketExpirationParams) ProtoMessage added in v0.5.0 

func (*TicketExpirationParams) ProtoMessage()

func (*TicketExpirationParams) ProtoReflect added in v0.7.2 

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

func (*TicketExpirationParams) Reset added in v0.5.0 

func (x *TicketExpirationParams) Reset()

func (*TicketExpirationParams) String added in v0.5.0 

func (x *TicketExpirationParams) String() string

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

Required parameters for probabilistic micropayment tickets

func (*TicketParams) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use TicketParams.ProtoReflect.Descriptor instead.

func (*TicketParams) GetExpirationBlock added in v0.5.5 

func (x *TicketParams) GetExpirationBlock() []byte

func (*TicketParams) GetExpirationParams added in v0.5.6 

func (x *TicketParams) GetExpirationParams() *TicketExpirationParams

func (*TicketParams) GetFaceValue added in v0.5.0 

func (x *TicketParams) GetFaceValue() []byte

func (*TicketParams) GetRecipient added in v0.5.0 

func (x *TicketParams) GetRecipient() []byte

func (*TicketParams) GetRecipientRandHash added in v0.5.0 

func (x *TicketParams) GetRecipientRandHash() []byte

func (*TicketParams) GetSeed added in v0.5.0 

func (x *TicketParams) GetSeed() []byte

func (*TicketParams) GetWinProb added in v0.5.0 

func (x *TicketParams) GetWinProb() []byte

func (*TicketParams) ProtoMessage added in v0.5.0 

func (*TicketParams) ProtoMessage()

func (*TicketParams) ProtoReflect added in v0.7.2 

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

func (*TicketParams) Reset added in v0.5.0 

func (x *TicketParams) Reset()

func (*TicketParams) String added in v0.5.0 

func (x *TicketParams) String() string

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

Sender Params (nonces and signatures)

func (*TicketSenderParams) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use TicketSenderParams.ProtoReflect.Descriptor instead.

func (*TicketSenderParams) GetSenderNonce added in v0.5.0 

func (x *TicketSenderParams) GetSenderNonce() uint32

func (*TicketSenderParams) GetSig added in v0.5.0 

func (x *TicketSenderParams) GetSig() []byte

func (*TicketSenderParams) ProtoMessage added in v0.5.0 

func (*TicketSenderParams) ProtoMessage()

func (*TicketSenderParams) ProtoReflect added in v0.7.2 

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

func (*TicketSenderParams) Reset added in v0.5.0 

func (x *TicketSenderParams) Reset()

func (*TicketSenderParams) String added in v0.5.0 

func (x *TicketSenderParams) String() string

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

A set of transcoded segments following the profiles specified in the job.

func (*TranscodeData) Descriptor deprecated added in v0.3.3 

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

Deprecated: Use TranscodeData.ProtoReflect.Descriptor instead.

func (*TranscodeData) GetSegments added in v0.3.3 

func (x *TranscodeData) GetSegments() []*TranscodedSegmentData

func (*TranscodeData) GetSig added in v0.3.3 

func (x *TranscodeData) GetSig() []byte

func (*TranscodeData) ProtoMessage added in v0.3.3 

func (*TranscodeData) ProtoMessage()

func (*TranscodeData) ProtoReflect added in v0.7.2 

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

func (*TranscodeData) Reset added in v0.3.3 

func (x *TranscodeData) Reset()

func (*TranscodeData) String added in v0.3.3 

func (x *TranscodeData) String() string

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

Response that a transcoder sends after transcoding a segment.

func (*TranscodeResult) Descriptor deprecated added in v0.3.3 

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

Deprecated: Use TranscodeResult.ProtoReflect.Descriptor instead.

func (*TranscodeResult) GetData added in v0.3.3 

func (x *TranscodeResult) GetData() *TranscodeData

func (*TranscodeResult) GetError added in v0.3.3 

func (x *TranscodeResult) GetError() string

func (*TranscodeResult) GetInfo added in v0.5.0 

func (x *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 (x *TranscodeResult) GetSeq() int64

func (*TranscodeResult) ProtoMessage added in v0.3.3 

func (*TranscodeResult) ProtoMessage()

func (*TranscodeResult) ProtoReflect added in v0.7.2 

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

func (*TranscodeResult) Reset added in v0.3.3 

func (x *TranscodeResult) Reset()

func (*TranscodeResult) String added in v0.3.3 

func (x *TranscodeResult) String() string

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

Individual transcoded segment data.

func (*TranscodedSegmentData) Descriptor deprecated added in v0.3.3 

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

Deprecated: Use TranscodedSegmentData.ProtoReflect.Descriptor instead.

func (*TranscodedSegmentData) GetPerceptualHashUrl added in v0.5.21 

func (x *TranscodedSegmentData) GetPerceptualHashUrl() string

func (*TranscodedSegmentData) GetPixels added in v0.5.0 

func (x *TranscodedSegmentData) GetPixels() int64

func (*TranscodedSegmentData) GetUrl added in v0.3.3 

func (x *TranscodedSegmentData) GetUrl() string

func (*TranscodedSegmentData) ProtoMessage added in v0.3.3 

func (*TranscodedSegmentData) ProtoMessage()

func (*TranscodedSegmentData) ProtoReflect added in v0.7.2 

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

func (*TranscodedSegmentData) Reset added in v0.3.3 

func (x *TranscodedSegmentData) Reset()

func (*TranscodedSegmentData) String added in v0.3.3 

func (x *TranscodedSegmentData) String() string

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://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, Transcoder_RegisterTranscoderServer) 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 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 must be embedded to have forward compatible implementations.

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.

func (UnimplementedTranscoderServer) RegisterTranscoder added in v0.5.0 

func (UnimplementedTranscoderServer) RegisterTranscoder(*RegisterRequest, Transcoder_RegisterTranscoderServer) 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"`
	// contains filtered or unexported fields
}

func (*VideoProfile) Descriptor deprecated added in v0.5.2 

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

Deprecated: Use VideoProfile.ProtoReflect.Descriptor instead.

func (*VideoProfile) GetBitrate added in v0.5.2 

func (x *VideoProfile) GetBitrate() int32

func (*VideoProfile) GetChromaFormat added in v0.5.30 

func (x *VideoProfile) GetChromaFormat() VideoProfile_ChromaSubsampling

func (*VideoProfile) GetColorDepth added in v0.5.30 

func (x *VideoProfile) GetColorDepth() int32

func (*VideoProfile) GetEncoder added in v0.5.28 

func (x *VideoProfile) GetEncoder() VideoProfile_VideoCodec

func (*VideoProfile) GetFormat added in v0.5.6 

func (x *VideoProfile) GetFormat() VideoProfile_Format

func (*VideoProfile) GetFps added in v0.5.2 

func (x *VideoProfile) GetFps() uint32

func (*VideoProfile) GetFpsDen added in v0.5.9 

func (x *VideoProfile) GetFpsDen() uint32

func (*VideoProfile) GetGop added in v0.5.9 

func (x *VideoProfile) GetGop() int32

func (*VideoProfile) GetHeight added in v0.5.2 

func (x *VideoProfile) GetHeight() int32

func (*VideoProfile) GetName added in v0.5.2 

func (x *VideoProfile) GetName() string

func (*VideoProfile) GetProfile added in v0.5.9 

func (x *VideoProfile) GetProfile() VideoProfile_Profile

func (*VideoProfile) GetQuality added in v0.7.0 

func (x *VideoProfile) GetQuality() uint32

func (*VideoProfile) GetWidth added in v0.5.2 

func (x *VideoProfile) GetWidth() int32

func (*VideoProfile) ProtoMessage added in v0.5.2 

func (*VideoProfile) ProtoMessage()

func (*VideoProfile) ProtoReflect added in v0.7.2 

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

func (*VideoProfile) Reset added in v0.5.2 

func (x *VideoProfile) Reset()

func (*VideoProfile) String added in v0.5.2 

func (x *VideoProfile) String() string

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

func (VideoProfile_ChromaSubsampling) Descriptor() protoreflect.EnumDescriptor

func (VideoProfile_ChromaSubsampling) Enum added in v0.7.2 

func (x VideoProfile_ChromaSubsampling) Enum() *VideoProfile_ChromaSubsampling

func (VideoProfile_ChromaSubsampling) EnumDescriptor deprecated added in v0.5.30 

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

Deprecated: Use VideoProfile_ChromaSubsampling.Descriptor instead.

func (VideoProfile_ChromaSubsampling) Number added in v0.7.2 

func (x VideoProfile_ChromaSubsampling) Number() protoreflect.EnumNumber

func (VideoProfile_ChromaSubsampling) String added in v0.5.30 

func (x VideoProfile_ChromaSubsampling) String() string

func (VideoProfile_ChromaSubsampling) Type added in v0.7.2 

func (VideoProfile_ChromaSubsampling) Type() protoreflect.EnumType

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

func (VideoProfile_Format) Descriptor() protoreflect.EnumDescriptor

func (VideoProfile_Format) Enum added in v0.7.2 

func (x VideoProfile_Format) Enum() *VideoProfile_Format

func (VideoProfile_Format) EnumDescriptor deprecated added in v0.5.6 

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

Deprecated: Use VideoProfile_Format.Descriptor instead.

func (VideoProfile_Format) Number added in v0.7.2 

func (x VideoProfile_Format) Number() protoreflect.EnumNumber

func (VideoProfile_Format) String added in v0.5.6 

func (x VideoProfile_Format) String() string

func (VideoProfile_Format) Type added in v0.7.2 

func (VideoProfile_Format) Type() protoreflect.EnumType

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

func (VideoProfile_Profile) Descriptor() protoreflect.EnumDescriptor

func (VideoProfile_Profile) Enum added in v0.7.2 

func (x VideoProfile_Profile) Enum() *VideoProfile_Profile

func (VideoProfile_Profile) EnumDescriptor deprecated added in v0.5.9 

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

Deprecated: Use VideoProfile_Profile.Descriptor instead.

func (VideoProfile_Profile) Number added in v0.7.2 

func (x VideoProfile_Profile) Number() protoreflect.EnumNumber

func (VideoProfile_Profile) String added in v0.5.9 

func (x VideoProfile_Profile) String() string

func (VideoProfile_Profile) Type added in v0.7.2 

func (VideoProfile_Profile) Type() protoreflect.EnumType

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

func (VideoProfile_VideoCodec) Descriptor() protoreflect.EnumDescriptor

func (VideoProfile_VideoCodec) Enum added in v0.7.2 

func (x VideoProfile_VideoCodec) Enum() *VideoProfile_VideoCodec

func (VideoProfile_VideoCodec) EnumDescriptor deprecated added in v0.5.28 

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

Deprecated: Use VideoProfile_VideoCodec.Descriptor instead.

func (VideoProfile_VideoCodec) Number added in v0.7.2 

func (x VideoProfile_VideoCodec) Number() protoreflect.EnumNumber

func (VideoProfile_VideoCodec) String added in v0.5.28 

func (x VideoProfile_VideoCodec) String() string

func (VideoProfile_VideoCodec) Type added in v0.7.2 

func (VideoProfile_VideoCodec) Type() protoreflect.EnumType

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.