net

package
v0.5.5 Latest Latest
Warning

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

 Go to latest Published: Mar 12, 2020 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var OSInfo_StorageType_name = map[int32]string{
	0: "DIRECT",
	1: "S3",
	2: "GOOGLE",
}
View Source 
var OSInfo_StorageType_value = map[string]int32{
	"DIRECT": 0,
	"S3":     1,
	"GOOGLE": 2,
}

Functions

func RegisterOrchestratorServer added in v0.3.3 

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

func RegisterTranscoderServer added in v0.5.0 

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

Types

type NodeStatus 

type NodeStatus struct {
	Manifests                   map[string]*m3u8.MasterPlaylist
	OrchestratorPool            []string
	Version                     string
	GolangRuntimeVersion        string
	GOArch                      string
	GOOS                        string
	RegisteredTranscodersNumber int
	RegisteredTranscoders       []RemoteTranscoderInfo
	LocalTranscoding            bool // Indicates orchestrator that is also transcoder

}

type NotifySegment added in v0.5.0 

type NotifySegment struct {
	// URL of the segment to transcode.
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// Job the segment belongs to.
	Job string `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"`
	// ID for this particular transcoding task.
	TaskId int64 `protobuf:"varint,16,opt,name=taskId,proto3" json:"taskId,omitempty"`
	// Set of profiles to transcode this segment into.
	Profiles []byte `protobuf:"bytes,17,opt,name=profiles,proto3" json:"profiles,omitempty"`
	// Transcoding profiles to use. Supersedes `profiles` field
	FullProfiles         []*VideoProfile `protobuf:"bytes,33,rep,name=fullProfiles,proto3" json:"fullProfiles,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) GetFullProfiles added in v0.5.2 

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

func (*NotifySegment) GetJob added in v0.5.1 

func (m *NotifySegment) GetJob() string

func (*NotifySegment) GetProfiles added in v0.5.0 

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

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)
	Ping(ctx context.Context, in *PingPong, opts ...grpc.CallOption) (*PingPong, error)
}

OrchestratorClient is the client API for Orchestrator service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewOrchestratorClient added in v0.3.3 

func NewOrchestratorClient(cc *grpc.ClientConn) OrchestratorClient

type OrchestratorInfo added in v0.5.0 

type OrchestratorInfo struct {
	// URI of the transcoder to use for submitting segments.
	Transcoder string `protobuf:"bytes,1,opt,name=transcoder,proto3" json:"transcoder,omitempty"`
	// Parameters for probabilistic micropayment tickets
	TicketParams *TicketParams `protobuf:"bytes,2,opt,name=ticket_params,json=ticketParams,proto3" json:"ticket_params,omitempty"`
	// Price Info containing the price per pixel to transcode
	PriceInfo *PriceInfo `protobuf:"bytes,3,opt,name=price_info,json=priceInfo,proto3" json:"price_info,omitempty"`
	// 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) GetPriceInfo added in v0.5.0 

func (m *OrchestratorInfo) GetPriceInfo() *PriceInfo

func (*OrchestratorInfo) GetStorage added in v0.5.0 

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

func (*OrchestratorInfo) GetTicketParams added in v0.5.0 

func (m *OrchestratorInfo) GetTicketParams() *TicketParams

func (*OrchestratorInfo) GetTranscoder added in v0.5.0 

func (m *OrchestratorInfo) GetTranscoder() string

func (*OrchestratorInfo) ProtoMessage added in v0.5.0 

func (*OrchestratorInfo) ProtoMessage()

func (*OrchestratorInfo) Reset added in v0.5.0 

func (m *OrchestratorInfo) Reset()

func (*OrchestratorInfo) String added in v0.5.0 

func (m *OrchestratorInfo) String() string

func (*OrchestratorInfo) XXX_DiscardUnknown added in v0.5.0 

func (m *OrchestratorInfo) XXX_DiscardUnknown()

func (*OrchestratorInfo) XXX_Marshal added in v0.5.0 

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

func (*OrchestratorInfo) XXX_Merge added in v0.5.0 

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

func (*OrchestratorInfo) XXX_Size added in v0.5.0 

func (m *OrchestratorInfo) XXX_Size() int

func (*OrchestratorInfo) XXX_Unmarshal added in v0.5.0 

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

type OrchestratorRequest added in v0.5.0 

type OrchestratorRequest struct {
	// Ethereum address of the broadcaster
	Address []byte `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// Broadcaster's signature over its address
	Sig                  []byte   `protobuf:"bytes,2,opt,name=sig,proto3" json:"sig,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*OrchestratorRequest) Descriptor added in v0.5.0 

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

func (*OrchestratorRequest) GetAddress added in v0.5.0 

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

func (*OrchestratorRequest) GetSig added in v0.5.0 

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

func (*OrchestratorRequest) ProtoMessage added in v0.5.0 

func (*OrchestratorRequest) ProtoMessage()

func (*OrchestratorRequest) Reset added in v0.5.0 

func (m *OrchestratorRequest) Reset()

func (*OrchestratorRequest) String added in v0.5.0 

func (m *OrchestratorRequest) String() string

func (*OrchestratorRequest) XXX_DiscardUnknown added in v0.5.0 

func (m *OrchestratorRequest) XXX_DiscardUnknown()

func (*OrchestratorRequest) XXX_Marshal added in v0.5.0 

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

func (*OrchestratorRequest) XXX_Merge added in v0.5.0 

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

func (*OrchestratorRequest) XXX_Size added in v0.5.0 

func (m *OrchestratorRequest) XXX_Size() int

func (*OrchestratorRequest) XXX_Unmarshal added in v0.5.0 

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

type OrchestratorServer added in v0.3.3 

type OrchestratorServer interface {
	// Called by the broadcaster to request transcoder info from an orchestrator.
	GetOrchestrator(context.Context, *OrchestratorRequest) (*OrchestratorInfo, error)
	Ping(context.Context, *PingPong) (*PingPong, error)
}

OrchestratorServer is the server API for Orchestrator service.

type Payment added in v0.5.0 

type Payment struct {
	// Probabilistic micropayment ticket parameters
	// These remain the same even when sending multiple tickets
	TicketParams *TicketParams `protobuf:"bytes,1,opt,name=ticket_params,json=ticketParams,proto3" json:"ticket_params,omitempty"`
	// ETH address of the sender
	Sender []byte `protobuf:"bytes,2,opt,name=sender,proto3" json:"sender,omitempty"`
	// Ticket params for expiration related validation
	ExpirationParams   *TicketExpirationParams `protobuf:"bytes,3,opt,name=expiration_params,json=expirationParams,proto3" json:"expiration_params,omitempty"`
	TicketSenderParams []*TicketSenderParams   `protobuf:"bytes,4,rep,name=ticket_sender_params,json=ticketSenderParams,proto3" json:"ticket_sender_params,omitempty"`
	// O's last known price
	ExpectedPrice        *PriceInfo `protobuf:"bytes,5,opt,name=expected_price,json=expectedPrice,proto3" json:"expected_price,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

Payment for transcoding video segments A payment can constitute of multiple tickets A broadcaster might need to send multiple tickets to top up his credit with an Orchestrator

func (*Payment) Descriptor added in v0.5.0 

func (*Payment) 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 RegisterRequest added in v0.5.0 

type RegisterRequest struct {
	// Shared secret for auth
	Secret string `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"`
	// Transcoder capacity
	Capacity             int64    `protobuf:"varint,2,opt,name=capacity,proto3" json:"capacity,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Sent by the transcoder to register itself to the orchestrator.

func (*RegisterRequest) Descriptor added in v0.5.0 

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

func (*RegisterRequest) GetCapacity added in v0.5.0 

func (m *RegisterRequest) GetCapacity() int64

func (*RegisterRequest) GetSecret added in v0.5.0 

func (m *RegisterRequest) GetSecret() string

func (*RegisterRequest) ProtoMessage added in v0.5.0 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) Reset added in v0.5.0 

func (m *RegisterRequest) Reset()

func (*RegisterRequest) String added in v0.5.0 

func (m *RegisterRequest) String() string

func (*RegisterRequest) XXX_DiscardUnknown added in v0.5.0 

func (m *RegisterRequest) XXX_DiscardUnknown()

func (*RegisterRequest) XXX_Marshal added in v0.5.0 

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

func (*RegisterRequest) XXX_Merge added in v0.5.0 

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

func (*RegisterRequest) XXX_Size added in v0.5.0 

func (m *RegisterRequest) XXX_Size() int

func (*RegisterRequest) XXX_Unmarshal added in v0.5.0 

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

type RemoteTranscoderInfo added in v0.5.0 

type RemoteTranscoderInfo struct {
	Address  string
	Capacity int
}

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"`
	// 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
	FullProfiles         []*VideoProfile `protobuf:"bytes,33,rep,name=fullProfiles,proto3" json:"fullProfiles,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) GetFullProfiles added in v0.5.2 

func (m *SegData) GetFullProfiles() []*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) 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 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"`
	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) 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 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Individual transcoded segment data.

func (*TranscodedSegmentData) Descriptor added in v0.3.3 

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

func (*TranscodedSegmentData) GetPixels added in v0.5.0 

func (m *TranscodedSegmentData) GetPixels() int64

func (*TranscodedSegmentData) GetUrl added in v0.3.3 

func (m *TranscodedSegmentData) GetUrl() string

func (*TranscodedSegmentData) ProtoMessage added in v0.3.3 

func (*TranscodedSegmentData) ProtoMessage()

func (*TranscodedSegmentData) Reset added in v0.3.3 

func (m *TranscodedSegmentData) Reset()

func (*TranscodedSegmentData) String added in v0.3.3 

func (m *TranscodedSegmentData) String() string

func (*TranscodedSegmentData) XXX_DiscardUnknown added in v0.3.3 

func (m *TranscodedSegmentData) XXX_DiscardUnknown()

func (*TranscodedSegmentData) XXX_Marshal added in v0.3.3 

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

func (*TranscodedSegmentData) XXX_Merge added in v0.3.3 

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

func (*TranscodedSegmentData) XXX_Size added in v0.3.3 

func (m *TranscodedSegmentData) XXX_Size() int

func (*TranscodedSegmentData) XXX_Unmarshal added in v0.3.3 

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

type TranscoderClient added in v0.5.0 

type TranscoderClient interface {
	// Called by the transcoder to register to an orchestrator. The orchestrator
	// notifies registered transcoders of segments as they come in.
	RegisterTranscoder(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (Transcoder_RegisterTranscoderClient, error)
}

TranscoderClient is the client API for Transcoder service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTranscoderClient added in v0.5.0 

func NewTranscoderClient(cc *grpc.ClientConn) TranscoderClient

type TranscoderServer added in v0.5.0 

type TranscoderServer interface {
	// Called by the transcoder to register to an orchestrator. The orchestrator
	// notifies registered transcoders of segments as they come in.
	RegisterTranscoder(*RegisterRequest, Transcoder_RegisterTranscoderServer) error
}

TranscoderServer is the server API for Transcoder service.

type Transcoder_RegisterTranscoderClient added in v0.5.0 

type Transcoder_RegisterTranscoderClient interface {
	Recv() (*NotifySegment, error)
	grpc.ClientStream
}

type Transcoder_RegisterTranscoderServer added in v0.5.0 

type Transcoder_RegisterTranscoderServer interface {
	Send(*NotifySegment) error
	grpc.ServerStream
}

type UnimplementedOrchestratorServer added in v0.5.0 

type UnimplementedOrchestratorServer struct {
}

UnimplementedOrchestratorServer can be embedded to have forward compatible implementations.

func (*UnimplementedOrchestratorServer) GetOrchestrator added in v0.5.0 

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

func (*UnimplementedOrchestratorServer) Ping added in v0.5.0 

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

type UnimplementedTranscoderServer added in v0.5.0 

type UnimplementedTranscoderServer struct {
}

UnimplementedTranscoderServer can be embedded to have forward compatible implementations.

func (*UnimplementedTranscoderServer) RegisterTranscoder added in v0.5.0 

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

type VideoProfile added in v0.5.2 

type VideoProfile struct {
	// Name of VideoProfile
	Name string `protobuf:"bytes,16,opt,name=name,proto3" json:"name,omitempty"`
	// Width of VideoProfile
	Width int32 `protobuf:"varint,17,opt,name=width,proto3" json:"width,omitempty"`
	// Height of VideoProfile
	Height int32 `protobuf:"varint,18,opt,name=height,proto3" json:"height,omitempty"`
	// Bitrate of VideoProfile
	Bitrate int32 `protobuf:"varint,19,opt,name=bitrate,proto3" json:"bitrate,omitempty"`
	// FPS of VideoProfile
	Fps                  uint32   `protobuf:"varint,20,opt,name=fps,proto3" json:"fps,omitempty"`
	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) GetFps added in v0.5.2 

func (m *VideoProfile) GetFps() uint32

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) 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

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.