pb

package
v0.0.0-...-ad2afee Latest Latest
Warning

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

 Go to latest Published: May 8, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ToWorker_RequestStream_FullMethodName         = "/api.ToWorker/RequestStream"
	ToWorker_RequestPremiere_FullMethodName       = "/api.ToWorker/RequestPremiere"
	ToWorker_RequestStreamEnd_FullMethodName      = "/api.ToWorker/RequestStreamEnd"
	ToWorker_RequestWaveform_FullMethodName       = "/api.ToWorker/RequestWaveform"
	ToWorker_RequestCut_FullMethodName            = "/api.ToWorker/RequestCut"
	ToWorker_GenerateThumbnails_FullMethodName    = "/api.ToWorker/GenerateThumbnails"
	ToWorker_GenerateLivePreview_FullMethodName   = "/api.ToWorker/GenerateLivePreview"
	ToWorker_GenerateSectionImages_FullMethodName = "/api.ToWorker/GenerateSectionImages"
	ToWorker_DeleteSectionImage_FullMethodName    = "/api.ToWorker/DeleteSectionImage"
	ToWorker_CombineThumbnails_FullMethodName     = "/api.ToWorker/CombineThumbnails"
)
View Source 
const (
	FromWorker_JoinWorkers_FullMethodName               = "/api.FromWorker/JoinWorkers"
	FromWorker_SendHeartBeat_FullMethodName             = "/api.FromWorker/SendHeartBeat"
	FromWorker_NotifyTranscodingProgress_FullMethodName = "/api.FromWorker/NotifyTranscodingProgress"
	FromWorker_NotifyTranscodingFinished_FullMethodName = "/api.FromWorker/NotifyTranscodingFinished"
	FromWorker_NotifySilenceResults_FullMethodName      = "/api.FromWorker/NotifySilenceResults"
	FromWorker_NotifyStreamStarted_FullMethodName       = "/api.FromWorker/NotifyStreamStarted"
	FromWorker_NotifyStreamFinished_FullMethodName      = "/api.FromWorker/NotifyStreamFinished"
	FromWorker_NotifyUploadFinished_FullMethodName      = "/api.FromWorker/NotifyUploadFinished"
	FromWorker_NotifyThumbnailsFinished_FullMethodName  = "/api.FromWorker/NotifyThumbnailsFinished"
	FromWorker_SendSelfStreamRequest_FullMethodName     = "/api.FromWorker/SendSelfStreamRequest"
	FromWorker_GetStreamInfoForUpload_FullMethodName    = "/api.FromWorker/GetStreamInfoForUpload"
	FromWorker_NotifyTranscodingFailure_FullMethodName  = "/api.FromWorker/NotifyTranscodingFailure"
)

Variables

View Source 
var File_api_proto protoreflect.FileDescriptor
View Source 
var FromWorker_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.FromWorker",
	HandlerType: (*FromWorkerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "JoinWorkers",
			Handler:    _FromWorker_JoinWorkers_Handler,
		},
		{
			MethodName: "SendHeartBeat",
			Handler:    _FromWorker_SendHeartBeat_Handler,
		},
		{
			MethodName: "NotifyTranscodingFinished",
			Handler:    _FromWorker_NotifyTranscodingFinished_Handler,
		},
		{
			MethodName: "NotifySilenceResults",
			Handler:    _FromWorker_NotifySilenceResults_Handler,
		},
		{
			MethodName: "NotifyStreamStarted",
			Handler:    _FromWorker_NotifyStreamStarted_Handler,
		},
		{
			MethodName: "NotifyStreamFinished",
			Handler:    _FromWorker_NotifyStreamFinished_Handler,
		},
		{
			MethodName: "NotifyUploadFinished",
			Handler:    _FromWorker_NotifyUploadFinished_Handler,
		},
		{
			MethodName: "NotifyThumbnailsFinished",
			Handler:    _FromWorker_NotifyThumbnailsFinished_Handler,
		},
		{
			MethodName: "SendSelfStreamRequest",
			Handler:    _FromWorker_SendSelfStreamRequest_Handler,
		},
		{
			MethodName: "GetStreamInfoForUpload",
			Handler:    _FromWorker_GetStreamInfoForUpload_Handler,
		},
		{
			MethodName: "NotifyTranscodingFailure",
			Handler:    _FromWorker_NotifyTranscodingFailure_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "NotifyTranscodingProgress",
			Handler:       _FromWorker_NotifyTranscodingProgress_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "api.proto",
}

FromWorker_ServiceDesc is the grpc.ServiceDesc for FromWorker 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 ToWorker_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.ToWorker",
	HandlerType: (*ToWorkerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RequestStream",
			Handler:    _ToWorker_RequestStream_Handler,
		},
		{
			MethodName: "RequestPremiere",
			Handler:    _ToWorker_RequestPremiere_Handler,
		},
		{
			MethodName: "RequestStreamEnd",
			Handler:    _ToWorker_RequestStreamEnd_Handler,
		},
		{
			MethodName: "RequestWaveform",
			Handler:    _ToWorker_RequestWaveform_Handler,
		},
		{
			MethodName: "RequestCut",
			Handler:    _ToWorker_RequestCut_Handler,
		},
		{
			MethodName: "GenerateThumbnails",
			Handler:    _ToWorker_GenerateThumbnails_Handler,
		},
		{
			MethodName: "GenerateLivePreview",
			Handler:    _ToWorker_GenerateLivePreview_Handler,
		},
		{
			MethodName: "GenerateSectionImages",
			Handler:    _ToWorker_GenerateSectionImages_Handler,
		},
		{
			MethodName: "DeleteSectionImage",
			Handler:    _ToWorker_DeleteSectionImage_Handler,
		},
		{
			MethodName: "CombineThumbnails",
			Handler:    _ToWorker_CombineThumbnails_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api.proto",
}

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

Functions

func RegisterFromWorkerServer 

func RegisterFromWorkerServer(s grpc.ServiceRegistrar, srv FromWorkerServer)

func RegisterToWorkerServer 

func RegisterToWorkerServer(s grpc.ServiceRegistrar, srv ToWorkerServer)

Types

type CombineThumbnailsRequest 

type CombineThumbnailsRequest struct {
	PrimaryThumbnail   string `protobuf:"bytes,1,opt,name=PrimaryThumbnail,proto3" json:"PrimaryThumbnail,omitempty"`
	SecondaryThumbnail string `protobuf:"bytes,2,opt,name=SecondaryThumbnail,proto3" json:"SecondaryThumbnail,omitempty"`
	Path               string `protobuf:"bytes,3,opt,name=Path,proto3" json:"Path,omitempty"`
	// contains filtered or unexported fields
}

func (*CombineThumbnailsRequest) Descriptor deprecated 

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

Deprecated: Use CombineThumbnailsRequest.ProtoReflect.Descriptor instead.

func (*CombineThumbnailsRequest) GetPath 

func (x *CombineThumbnailsRequest) GetPath() string

func (*CombineThumbnailsRequest) GetPrimaryThumbnail 

func (x *CombineThumbnailsRequest) GetPrimaryThumbnail() string

func (*CombineThumbnailsRequest) GetSecondaryThumbnail 

func (x *CombineThumbnailsRequest) GetSecondaryThumbnail() string

func (*CombineThumbnailsRequest) ProtoMessage 

func (*CombineThumbnailsRequest) ProtoMessage()

func (*CombineThumbnailsRequest) ProtoReflect 

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

func (*CombineThumbnailsRequest) Reset 

func (x *CombineThumbnailsRequest) Reset()

func (*CombineThumbnailsRequest) String 

func (x *CombineThumbnailsRequest) String() string

type CombineThumbnailsResponse 

type CombineThumbnailsResponse struct {
	FilePath string `protobuf:"bytes,1,opt,name=FilePath,proto3" json:"FilePath,omitempty"`
	// contains filtered or unexported fields
}

func (*CombineThumbnailsResponse) Descriptor deprecated 

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

Deprecated: Use CombineThumbnailsResponse.ProtoReflect.Descriptor instead.

func (*CombineThumbnailsResponse) GetFilePath 

func (x *CombineThumbnailsResponse) GetFilePath() string

func (*CombineThumbnailsResponse) ProtoMessage 

func (*CombineThumbnailsResponse) ProtoMessage()

func (*CombineThumbnailsResponse) ProtoReflect 

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

func (*CombineThumbnailsResponse) Reset 

func (x *CombineThumbnailsResponse) Reset()

func (*CombineThumbnailsResponse) String 

func (x *CombineThumbnailsResponse) String() string

type CutRequest 

type CutRequest struct {
	WorkerId     string                `protobuf:"bytes,1,opt,name=WorkerId,proto3" json:"WorkerId,omitempty"`
	Files        []string              `protobuf:"bytes,2,rep,name=Files,proto3" json:"Files,omitempty"`
	Segments     []*CutRequest_Segment `protobuf:"bytes,3,rep,name=segments,proto3" json:"segments,omitempty"`
	UploadResult bool                  `protobuf:"varint,4,opt,name=UploadResult,proto3" json:"UploadResult,omitempty"`
	// contains filtered or unexported fields
}

func (*CutRequest) Descriptor deprecated 

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

Deprecated: Use CutRequest.ProtoReflect.Descriptor instead.

func (*CutRequest) GetFiles 

func (x *CutRequest) GetFiles() []string

func (*CutRequest) GetSegments 

func (x *CutRequest) GetSegments() []*CutRequest_Segment

func (*CutRequest) GetUploadResult 

func (x *CutRequest) GetUploadResult() bool

func (*CutRequest) GetWorkerId 

func (x *CutRequest) GetWorkerId() string

func (*CutRequest) ProtoMessage 

func (*CutRequest) ProtoMessage()

func (*CutRequest) ProtoReflect 

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

func (*CutRequest) Reset 

func (x *CutRequest) Reset()

func (*CutRequest) String 

func (x *CutRequest) String() string

type CutRequest_Segment 

type CutRequest_Segment struct {
	StartTime int64 `protobuf:"varint,1,opt,name=Start_time,json=StartTime,proto3" json:"Start_time,omitempty"` // milliseconds
	EndTime   int64 `protobuf:"varint,2,opt,name=End_time,json=EndTime,proto3" json:"End_time,omitempty"`
	Discard   bool  `protobuf:"varint,3,opt,name=Discard,proto3" json:"Discard,omitempty"`
	// contains filtered or unexported fields
}

func (*CutRequest_Segment) Descriptor deprecated 

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

Deprecated: Use CutRequest_Segment.ProtoReflect.Descriptor instead.

func (*CutRequest_Segment) GetDiscard 

func (x *CutRequest_Segment) GetDiscard() bool

func (*CutRequest_Segment) GetEndTime 

func (x *CutRequest_Segment) GetEndTime() int64

func (*CutRequest_Segment) GetStartTime 

func (x *CutRequest_Segment) GetStartTime() int64

func (*CutRequest_Segment) ProtoMessage 

func (*CutRequest_Segment) ProtoMessage()

func (*CutRequest_Segment) ProtoReflect 

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

func (*CutRequest_Segment) Reset 

func (x *CutRequest_Segment) Reset()

func (*CutRequest_Segment) String 

func (x *CutRequest_Segment) String() string

type CutResponse 

type CutResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Error   string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // if success == false: error message
	// contains filtered or unexported fields
}

func (*CutResponse) Descriptor deprecated 

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

Deprecated: Use CutResponse.ProtoReflect.Descriptor instead.

func (*CutResponse) GetError 

func (x *CutResponse) GetError() string

func (*CutResponse) GetSuccess 

func (x *CutResponse) GetSuccess() bool

func (*CutResponse) ProtoMessage 

func (*CutResponse) ProtoMessage()

func (*CutResponse) ProtoReflect 

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

func (*CutResponse) Reset 

func (x *CutResponse) Reset()

func (*CutResponse) String 

func (x *CutResponse) String() string

type DeleteSectionImageRequest 

type DeleteSectionImageRequest struct {
	Path string `protobuf:"bytes,1,opt,name=Path,proto3" json:"Path,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteSectionImageRequest) Descriptor deprecated 

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

Deprecated: Use DeleteSectionImageRequest.ProtoReflect.Descriptor instead.

func (*DeleteSectionImageRequest) GetPath 

func (x *DeleteSectionImageRequest) GetPath() string

func (*DeleteSectionImageRequest) ProtoMessage 

func (*DeleteSectionImageRequest) ProtoMessage()

func (*DeleteSectionImageRequest) ProtoReflect 

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

func (*DeleteSectionImageRequest) Reset 

func (x *DeleteSectionImageRequest) Reset()

func (*DeleteSectionImageRequest) String 

func (x *DeleteSectionImageRequest) String() string

type EndStreamRequest 

type EndStreamRequest struct {
	StreamID   uint32 `protobuf:"varint,1,opt,name=StreamID,proto3" json:"StreamID,omitempty"`
	WorkerID   string `protobuf:"bytes,2,opt,name=WorkerID,proto3" json:"WorkerID,omitempty"`
	DiscardVoD bool   `protobuf:"varint,3,opt,name=DiscardVoD,proto3" json:"DiscardVoD,omitempty"`
	// contains filtered or unexported fields
}

func (*EndStreamRequest) Descriptor deprecated 

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

Deprecated: Use EndStreamRequest.ProtoReflect.Descriptor instead.

func (*EndStreamRequest) GetDiscardVoD 

func (x *EndStreamRequest) GetDiscardVoD() bool

func (*EndStreamRequest) GetStreamID 

func (x *EndStreamRequest) GetStreamID() uint32

func (*EndStreamRequest) GetWorkerID 

func (x *EndStreamRequest) GetWorkerID() string

func (*EndStreamRequest) ProtoMessage 

func (*EndStreamRequest) ProtoMessage()

func (*EndStreamRequest) ProtoReflect 

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

func (*EndStreamRequest) Reset 

func (x *EndStreamRequest) Reset()

func (*EndStreamRequest) String 

func (x *EndStreamRequest) String() string

type FromWorkerClient 

type FromWorkerClient interface {
	// JoinWorkers is a request to the server to join the worker pool.
	JoinWorkers(ctx context.Context, in *JoinWorkersRequest, opts ...grpc.CallOption) (*JoinWorkersResponse, error)
	SendHeartBeat(ctx context.Context, in *HeartBeat, opts ...grpc.CallOption) (*Status, error)
	NotifyTranscodingProgress(ctx context.Context, opts ...grpc.CallOption) (FromWorker_NotifyTranscodingProgressClient, error)
	NotifyTranscodingFinished(ctx context.Context, in *TranscodingFinished, opts ...grpc.CallOption) (*Status, error)
	NotifySilenceResults(ctx context.Context, in *SilenceResults, opts ...grpc.CallOption) (*Status, error)
	NotifyStreamStarted(ctx context.Context, in *StreamStarted, opts ...grpc.CallOption) (*Status, error)
	NotifyStreamFinished(ctx context.Context, in *StreamFinished, opts ...grpc.CallOption) (*Status, error)
	NotifyUploadFinished(ctx context.Context, in *UploadFinished, opts ...grpc.CallOption) (*Status, error)
	NotifyThumbnailsFinished(ctx context.Context, in *ThumbnailsFinished, opts ...grpc.CallOption) (*Status, error)
	SendSelfStreamRequest(ctx context.Context, in *SelfStreamRequest, opts ...grpc.CallOption) (*SelfStreamResponse, error)
	GetStreamInfoForUpload(ctx context.Context, in *GetStreamInfoForUploadRequest, opts ...grpc.CallOption) (*GetStreamInfoForUploadResponse, error)
	NotifyTranscodingFailure(ctx context.Context, in *NotifyTranscodingFailureRequest, opts ...grpc.CallOption) (*NotifyTranscodingFailureResponse, error)
}

FromWorkerClient is the client API for FromWorker service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.golang.ir/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewFromWorkerClient 

func NewFromWorkerClient(cc grpc.ClientConnInterface) FromWorkerClient

type FromWorkerServer 

type FromWorkerServer interface {
	// JoinWorkers is a request to the server to join the worker pool.
	JoinWorkers(context.Context, *JoinWorkersRequest) (*JoinWorkersResponse, error)
	SendHeartBeat(context.Context, *HeartBeat) (*Status, error)
	NotifyTranscodingProgress(FromWorker_NotifyTranscodingProgressServer) error
	NotifyTranscodingFinished(context.Context, *TranscodingFinished) (*Status, error)
	NotifySilenceResults(context.Context, *SilenceResults) (*Status, error)
	NotifyStreamStarted(context.Context, *StreamStarted) (*Status, error)
	NotifyStreamFinished(context.Context, *StreamFinished) (*Status, error)
	NotifyUploadFinished(context.Context, *UploadFinished) (*Status, error)
	NotifyThumbnailsFinished(context.Context, *ThumbnailsFinished) (*Status, error)
	SendSelfStreamRequest(context.Context, *SelfStreamRequest) (*SelfStreamResponse, error)
	GetStreamInfoForUpload(context.Context, *GetStreamInfoForUploadRequest) (*GetStreamInfoForUploadResponse, error)
	NotifyTranscodingFailure(context.Context, *NotifyTranscodingFailureRequest) (*NotifyTranscodingFailureResponse, error)
	// contains filtered or unexported methods
}

FromWorkerServer is the server API for FromWorker service. All implementations must embed UnimplementedFromWorkerServer for forward compatibility

type FromWorker_NotifyTranscodingProgressClient 

type FromWorker_NotifyTranscodingProgressClient interface {
	Send(*NotifyTranscodingProgressRequest) error
	CloseAndRecv() (*Status, error)
	grpc.ClientStream
}

type FromWorker_NotifyTranscodingProgressServer 

type FromWorker_NotifyTranscodingProgressServer interface {
	SendAndClose(*Status) error
	Recv() (*NotifyTranscodingProgressRequest, error)
	grpc.ServerStream
}

type GenerateSectionImageRequest 

type GenerateSectionImageRequest struct {
	PlaylistURL        string     `protobuf:"bytes,1,opt,name=PlaylistURL,proto3" json:"PlaylistURL,omitempty"`
	CourseName         string     `protobuf:"bytes,2,opt,name=CourseName,proto3" json:"CourseName,omitempty"`
	CourseYear         uint32     `protobuf:"varint,3,opt,name=CourseYear,proto3" json:"CourseYear,omitempty"`
	CourseTeachingTerm string     `protobuf:"bytes,4,opt,name=CourseTeachingTerm,proto3" json:"CourseTeachingTerm,omitempty"`
	Sections           []*Section `protobuf:"bytes,5,rep,name=Sections,proto3" json:"Sections,omitempty"`
	// contains filtered or unexported fields
}

func (*GenerateSectionImageRequest) Descriptor deprecated 

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

Deprecated: Use GenerateSectionImageRequest.ProtoReflect.Descriptor instead.

func (*GenerateSectionImageRequest) GetCourseName 

func (x *GenerateSectionImageRequest) GetCourseName() string

func (*GenerateSectionImageRequest) GetCourseTeachingTerm 

func (x *GenerateSectionImageRequest) GetCourseTeachingTerm() string

func (*GenerateSectionImageRequest) GetCourseYear 

func (x *GenerateSectionImageRequest) GetCourseYear() uint32

func (*GenerateSectionImageRequest) GetPlaylistURL 

func (x *GenerateSectionImageRequest) GetPlaylistURL() string

func (*GenerateSectionImageRequest) GetSections 

func (x *GenerateSectionImageRequest) GetSections() []*Section

func (*GenerateSectionImageRequest) ProtoMessage 

func (*GenerateSectionImageRequest) ProtoMessage()

func (*GenerateSectionImageRequest) ProtoReflect 

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

func (*GenerateSectionImageRequest) Reset 

func (x *GenerateSectionImageRequest) Reset()

func (*GenerateSectionImageRequest) String 

func (x *GenerateSectionImageRequest) String() string

type GenerateSectionImageResponse 

type GenerateSectionImageResponse struct {
	Paths []string `protobuf:"bytes,1,rep,name=Paths,proto3" json:"Paths,omitempty"`
	// contains filtered or unexported fields
}

func (*GenerateSectionImageResponse) Descriptor deprecated 

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

Deprecated: Use GenerateSectionImageResponse.ProtoReflect.Descriptor instead.

func (*GenerateSectionImageResponse) GetPaths 

func (x *GenerateSectionImageResponse) GetPaths() []string

func (*GenerateSectionImageResponse) ProtoMessage 

func (*GenerateSectionImageResponse) ProtoMessage()

func (*GenerateSectionImageResponse) ProtoReflect 

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

func (*GenerateSectionImageResponse) Reset 

func (x *GenerateSectionImageResponse) Reset()

func (*GenerateSectionImageResponse) String 

func (x *GenerateSectionImageResponse) String() string

type GenerateThumbnailRequest 

type GenerateThumbnailRequest struct {
	Path          string                 `protobuf:"bytes,1,opt,name=Path,proto3" json:"Path,omitempty"`
	WorkerID      string                 `protobuf:"bytes,2,opt,name=WorkerID,proto3" json:"WorkerID,omitempty"`
	StreamID      uint32                 `protobuf:"varint,3,opt,name=StreamID,proto3" json:"StreamID,omitempty"`
	StreamVersion string                 `protobuf:"bytes,4,opt,name=StreamVersion,proto3" json:"StreamVersion,omitempty"`
	CourseSlug    string                 `protobuf:"bytes,5,opt,name=CourseSlug,proto3" json:"CourseSlug,omitempty"`
	CourseYear    uint32                 `protobuf:"varint,6,opt,name=CourseYear,proto3" json:"CourseYear,omitempty"`
	TeachingTerm  string                 `protobuf:"bytes,7,opt,name=TeachingTerm,proto3" json:"TeachingTerm,omitempty"`
	Start         *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=start,proto3" json:"start,omitempty"`
	// contains filtered or unexported fields
}

func (*GenerateThumbnailRequest) Descriptor deprecated 

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

Deprecated: Use GenerateThumbnailRequest.ProtoReflect.Descriptor instead.

func (*GenerateThumbnailRequest) GetCourseSlug 

func (x *GenerateThumbnailRequest) GetCourseSlug() string

func (*GenerateThumbnailRequest) GetCourseYear 

func (x *GenerateThumbnailRequest) GetCourseYear() uint32

func (*GenerateThumbnailRequest) GetPath 

func (x *GenerateThumbnailRequest) GetPath() string

func (*GenerateThumbnailRequest) GetStart 

func (x *GenerateThumbnailRequest) GetStart() *timestamppb.Timestamp

func (*GenerateThumbnailRequest) GetStreamID 

func (x *GenerateThumbnailRequest) GetStreamID() uint32

func (*GenerateThumbnailRequest) GetStreamVersion 

func (x *GenerateThumbnailRequest) GetStreamVersion() string

func (*GenerateThumbnailRequest) GetTeachingTerm 

func (x *GenerateThumbnailRequest) GetTeachingTerm() string

func (*GenerateThumbnailRequest) GetWorkerID 

func (x *GenerateThumbnailRequest) GetWorkerID() string

func (*GenerateThumbnailRequest) ProtoMessage 

func (*GenerateThumbnailRequest) ProtoMessage()

func (*GenerateThumbnailRequest) ProtoReflect 

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

func (*GenerateThumbnailRequest) Reset 

func (x *GenerateThumbnailRequest) Reset()

func (*GenerateThumbnailRequest) String 

func (x *GenerateThumbnailRequest) String() string

type GetStreamInfoForUploadRequest 

type GetStreamInfoForUploadRequest struct {
	WorkerID  string `protobuf:"bytes,1,opt,name=WorkerID,proto3" json:"WorkerID,omitempty"`
	UploadKey string `protobuf:"bytes,2,opt,name=UploadKey,proto3" json:"UploadKey,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStreamInfoForUploadRequest) Descriptor deprecated 

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

Deprecated: Use GetStreamInfoForUploadRequest.ProtoReflect.Descriptor instead.

func (*GetStreamInfoForUploadRequest) GetUploadKey 

func (x *GetStreamInfoForUploadRequest) GetUploadKey() string

func (*GetStreamInfoForUploadRequest) GetWorkerID 

func (x *GetStreamInfoForUploadRequest) GetWorkerID() string

func (*GetStreamInfoForUploadRequest) ProtoMessage 

func (*GetStreamInfoForUploadRequest) ProtoMessage()

func (*GetStreamInfoForUploadRequest) ProtoReflect 

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

func (*GetStreamInfoForUploadRequest) Reset 

func (x *GetStreamInfoForUploadRequest) Reset()

func (*GetStreamInfoForUploadRequest) String 

func (x *GetStreamInfoForUploadRequest) String() string

type GetStreamInfoForUploadResponse 

type GetStreamInfoForUploadResponse struct {
	CourseSlug  string                 `protobuf:"bytes,1,opt,name=CourseSlug,proto3" json:"CourseSlug,omitempty"`
	CourseTerm  string                 `protobuf:"bytes,2,opt,name=CourseTerm,proto3" json:"CourseTerm,omitempty"`
	CourseYear  uint32                 `protobuf:"varint,3,opt,name=CourseYear,proto3" json:"CourseYear,omitempty"`
	StreamStart *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=StreamStart,proto3" json:"StreamStart,omitempty"`
	StreamEnd   *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=StreamEnd,proto3" json:"StreamEnd,omitempty"`
	StreamID    uint32                 `protobuf:"varint,6,opt,name=StreamID,proto3" json:"StreamID,omitempty"`
	VideoType   string                 `protobuf:"bytes,7,opt,name=VideoType,proto3" json:"VideoType,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStreamInfoForUploadResponse) Descriptor deprecated 

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

Deprecated: Use GetStreamInfoForUploadResponse.ProtoReflect.Descriptor instead.

func (*GetStreamInfoForUploadResponse) GetCourseSlug 

func (x *GetStreamInfoForUploadResponse) GetCourseSlug() string

func (*GetStreamInfoForUploadResponse) GetCourseTerm 

func (x *GetStreamInfoForUploadResponse) GetCourseTerm() string

func (*GetStreamInfoForUploadResponse) GetCourseYear 

func (x *GetStreamInfoForUploadResponse) GetCourseYear() uint32

func (*GetStreamInfoForUploadResponse) GetStreamEnd 

func (x *GetStreamInfoForUploadResponse) GetStreamEnd() *timestamppb.Timestamp

func (*GetStreamInfoForUploadResponse) GetStreamID 

func (x *GetStreamInfoForUploadResponse) GetStreamID() uint32

func (*GetStreamInfoForUploadResponse) GetStreamStart 

func (x *GetStreamInfoForUploadResponse) GetStreamStart() *timestamppb.Timestamp

func (*GetStreamInfoForUploadResponse) GetVideoType 

func (x *GetStreamInfoForUploadResponse) GetVideoType() string

func (*GetStreamInfoForUploadResponse) ProtoMessage 

func (*GetStreamInfoForUploadResponse) ProtoMessage()

func (*GetStreamInfoForUploadResponse) ProtoReflect 

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

func (*GetStreamInfoForUploadResponse) Reset 

func (x *GetStreamInfoForUploadResponse) Reset()

func (*GetStreamInfoForUploadResponse) String 

func (x *GetStreamInfoForUploadResponse) String() string

type HeartBeat 

type HeartBeat struct {
	WorkerID string   `protobuf:"bytes,1,opt,name=WorkerID,proto3" json:"WorkerID,omitempty"`
	Workload uint32   `protobuf:"varint,2,opt,name=Workload,proto3" json:"Workload,omitempty"`
	Jobs     []string `protobuf:"bytes,3,rep,name=Jobs,proto3" json:"Jobs,omitempty"`
	Version  string   `protobuf:"bytes,4,opt,name=Version,proto3" json:"Version,omitempty"`
	CPU      string   `protobuf:"bytes,5,opt,name=CPU,proto3" json:"CPU,omitempty"`
	Memory   string   `protobuf:"bytes,6,opt,name=Memory,proto3" json:"Memory,omitempty"`
	Disk     string   `protobuf:"bytes,7,opt,name=Disk,proto3" json:"Disk,omitempty"`
	Uptime   string   `protobuf:"bytes,8,opt,name=Uptime,proto3" json:"Uptime,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartBeat) Descriptor deprecated 

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

Deprecated: Use HeartBeat.ProtoReflect.Descriptor instead.

func (*HeartBeat) GetCPU 

func (x *HeartBeat) GetCPU() string

func (*HeartBeat) GetDisk 

func (x *HeartBeat) GetDisk() string

func (*HeartBeat) GetJobs 

func (x *HeartBeat) GetJobs() []string

func (*HeartBeat) GetMemory 

func (x *HeartBeat) GetMemory() string

func (*HeartBeat) GetUptime 

func (x *HeartBeat) GetUptime() string

func (*HeartBeat) GetVersion 

func (x *HeartBeat) GetVersion() string

func (*HeartBeat) GetWorkerID 

func (x *HeartBeat) GetWorkerID() string

func (*HeartBeat) GetWorkload 

func (x *HeartBeat) GetWorkload() uint32

func (*HeartBeat) ProtoMessage 

func (*HeartBeat) ProtoMessage()

func (*HeartBeat) ProtoReflect 

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

func (*HeartBeat) Reset 

func (x *HeartBeat) Reset()

func (*HeartBeat) String 

func (x *HeartBeat) String() string

type JoinWorkersRequest 

type JoinWorkersRequest struct {
	Token    string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`       // token to authenticate the worker
	Hostname string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"` // hostname of the worker
	// contains filtered or unexported fields
}

func (*JoinWorkersRequest) Descriptor deprecated 

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

Deprecated: Use JoinWorkersRequest.ProtoReflect.Descriptor instead.

func (*JoinWorkersRequest) GetHostname 

func (x *JoinWorkersRequest) GetHostname() string

func (*JoinWorkersRequest) GetToken 

func (x *JoinWorkersRequest) GetToken() string

func (*JoinWorkersRequest) ProtoMessage 

func (*JoinWorkersRequest) ProtoMessage()

func (*JoinWorkersRequest) ProtoReflect 

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

func (*JoinWorkersRequest) Reset 

func (x *JoinWorkersRequest) Reset()

func (*JoinWorkersRequest) String 

func (x *JoinWorkersRequest) String() string

type JoinWorkersResponse 

type JoinWorkersResponse struct {
	WorkerId string `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"` // worker id, secret set for further communication in case of success
	// contains filtered or unexported fields
}

func (*JoinWorkersResponse) Descriptor deprecated 

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

Deprecated: Use JoinWorkersResponse.ProtoReflect.Descriptor instead.

func (*JoinWorkersResponse) GetWorkerId 

func (x *JoinWorkersResponse) GetWorkerId() string

func (*JoinWorkersResponse) ProtoMessage 

func (*JoinWorkersResponse) ProtoMessage()

func (*JoinWorkersResponse) ProtoReflect 

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

func (*JoinWorkersResponse) Reset 

func (x *JoinWorkersResponse) Reset()

func (*JoinWorkersResponse) String 

func (x *JoinWorkersResponse) String() string

type LivePreviewRequest 

type LivePreviewRequest struct {
	WorkerID string `protobuf:"bytes,1,opt,name=WorkerID,proto3" json:"WorkerID,omitempty"`
	HLSUrl   string `protobuf:"bytes,2,opt,name=HLSUrl,proto3" json:"HLSUrl,omitempty"`
	// contains filtered or unexported fields
}

func (*LivePreviewRequest) Descriptor deprecated 

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

Deprecated: Use LivePreviewRequest.ProtoReflect.Descriptor instead.

func (*LivePreviewRequest) GetHLSUrl 

func (x *LivePreviewRequest) GetHLSUrl() string

func (*LivePreviewRequest) GetWorkerID 

func (x *LivePreviewRequest) GetWorkerID() string

func (*LivePreviewRequest) ProtoMessage 

func (*LivePreviewRequest) ProtoMessage()

func (*LivePreviewRequest) ProtoReflect 

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

func (*LivePreviewRequest) Reset 

func (x *LivePreviewRequest) Reset()

func (*LivePreviewRequest) String 

func (x *LivePreviewRequest) String() string

type LivePreviewResponse 

type LivePreviewResponse struct {
	LiveThumb []byte `protobuf:"bytes,1,opt,name=LiveThumb,proto3" json:"LiveThumb,omitempty"`
	// contains filtered or unexported fields
}

func (*LivePreviewResponse) Descriptor deprecated 

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

Deprecated: Use LivePreviewResponse.ProtoReflect.Descriptor instead.

func (*LivePreviewResponse) GetLiveThumb 

func (x *LivePreviewResponse) GetLiveThumb() []byte

func (*LivePreviewResponse) ProtoMessage 

func (*LivePreviewResponse) ProtoMessage()

func (*LivePreviewResponse) ProtoReflect 

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

func (*LivePreviewResponse) Reset 

func (x *LivePreviewResponse) Reset()

func (*LivePreviewResponse) String 

func (x *LivePreviewResponse) String() string

type NotifyTranscodingFailureRequest 

type NotifyTranscodingFailureRequest struct {
	WorkerID string `protobuf:"bytes,1,opt,name=WorkerID,proto3" json:"WorkerID,omitempty"`
	StreamID uint32 `protobuf:"varint,2,opt,name=StreamID,proto3" json:"StreamID,omitempty"`
	Version  string `protobuf:"bytes,3,opt,name=Version,proto3" json:"Version,omitempty"`
	FilePath string `protobuf:"bytes,4,opt,name=FilePath,proto3" json:"FilePath,omitempty"`
	Logs     string `protobuf:"bytes,5,opt,name=Logs,proto3" json:"Logs,omitempty"`
	ExitCode int64  `protobuf:"varint,6,opt,name=ExitCode,proto3" json:"ExitCode,omitempty"`
	// contains filtered or unexported fields
}

func (*NotifyTranscodingFailureRequest) Descriptor deprecated 

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

Deprecated: Use NotifyTranscodingFailureRequest.ProtoReflect.Descriptor instead.

func (*NotifyTranscodingFailureRequest) GetExitCode 

func (x *NotifyTranscodingFailureRequest) GetExitCode() int64

func (*NotifyTranscodingFailureRequest) GetFilePath 

func (x *NotifyTranscodingFailureRequest) GetFilePath() string

func (*NotifyTranscodingFailureRequest) GetLogs 

func (x *NotifyTranscodingFailureRequest) GetLogs() string

func (*NotifyTranscodingFailureRequest) GetStreamID 

func (x *NotifyTranscodingFailureRequest) GetStreamID() uint32

func (*NotifyTranscodingFailureRequest) GetVersion 

func (x *NotifyTranscodingFailureRequest) GetVersion() string

func (*NotifyTranscodingFailureRequest) GetWorkerID 

func (x *NotifyTranscodingFailureRequest) GetWorkerID() string

func (*NotifyTranscodingFailureRequest) ProtoMessage 

func (*NotifyTranscodingFailureRequest) ProtoMessage()

func (*NotifyTranscodingFailureRequest) ProtoReflect 

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

func (*NotifyTranscodingFailureRequest) Reset 

func (x *NotifyTranscodingFailureRequest) Reset()

func (*NotifyTranscodingFailureRequest) String 

func (x *NotifyTranscodingFailureRequest) String() string

type NotifyTranscodingFailureResponse 

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

func (*NotifyTranscodingFailureResponse) Descriptor deprecated 

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

Deprecated: Use NotifyTranscodingFailureResponse.ProtoReflect.Descriptor instead.

func (*NotifyTranscodingFailureResponse) ProtoMessage 

func (*NotifyTranscodingFailureResponse) ProtoMessage()

func (*NotifyTranscodingFailureResponse) ProtoReflect 

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

func (*NotifyTranscodingFailureResponse) Reset 

func (x *NotifyTranscodingFailureResponse) Reset()

func (*NotifyTranscodingFailureResponse) String 

func (x *NotifyTranscodingFailureResponse) String() string

type NotifyTranscodingProgressRequest 

type NotifyTranscodingProgressRequest struct {
	WorkerID string `protobuf:"bytes,1,opt,name=WorkerID,proto3" json:"WorkerID,omitempty"`
	StreamId uint32 `protobuf:"varint,2,opt,name=StreamId,proto3" json:"StreamId,omitempty"`
	Version  string `protobuf:"bytes,3,opt,name=Version,proto3" json:"Version,omitempty"`
	Progress int32  `protobuf:"varint,4,opt,name=Progress,proto3" json:"Progress,omitempty"`
	// contains filtered or unexported fields
}

func (*NotifyTranscodingProgressRequest) Descriptor deprecated 

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

Deprecated: Use NotifyTranscodingProgressRequest.ProtoReflect.Descriptor instead.

func (*NotifyTranscodingProgressRequest) GetProgress 

func (x *NotifyTranscodingProgressRequest) GetProgress() int32

func (*NotifyTranscodingProgressRequest) GetStreamId 

func (x *NotifyTranscodingProgressRequest) GetStreamId() uint32

func (*NotifyTranscodingProgressRequest) GetVersion 

func (x *NotifyTranscodingProgressRequest) GetVersion() string

func (*NotifyTranscodingProgressRequest) GetWorkerID 

func (x *NotifyTranscodingProgressRequest) GetWorkerID() string

func (*NotifyTranscodingProgressRequest) ProtoMessage 

func (*NotifyTranscodingProgressRequest) ProtoMessage()

func (*NotifyTranscodingProgressRequest) ProtoReflect 

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

func (*NotifyTranscodingProgressRequest) Reset 

func (x *NotifyTranscodingProgressRequest) Reset()

func (*NotifyTranscodingProgressRequest) String 

func (x *NotifyTranscodingProgressRequest) String() string

type PremiereRequest 

type PremiereRequest struct {
	StreamID     uint32 `protobuf:"varint,1,opt,name=StreamID,proto3" json:"StreamID,omitempty"`
	FilePath     string `protobuf:"bytes,2,opt,name=FilePath,proto3" json:"FilePath,omitempty"`
	WorkerID     string `protobuf:"bytes,3,opt,name=WorkerID,proto3" json:"WorkerID,omitempty"`
	StreamName   string `protobuf:"bytes,4,opt,name=StreamName,proto3" json:"StreamName,omitempty"`
	IngestServer string `protobuf:"bytes,5,opt,name=IngestServer,proto3" json:"IngestServer,omitempty"`
	OutUrl       string `protobuf:"bytes,6,opt,name=OutUrl,proto3" json:"OutUrl,omitempty"`
	// contains filtered or unexported fields
}

func (*PremiereRequest) Descriptor deprecated 

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

Deprecated: Use PremiereRequest.ProtoReflect.Descriptor instead.

func (*PremiereRequest) GetFilePath 

func (x *PremiereRequest) GetFilePath() string

func (*PremiereRequest) GetIngestServer 

func (x *PremiereRequest) GetIngestServer() string

func (*PremiereRequest) GetOutUrl 

func (x *PremiereRequest) GetOutUrl() string

func (*PremiereRequest) GetStreamID 

func (x *PremiereRequest) GetStreamID() uint32

func (*PremiereRequest) GetStreamName 

func (x *PremiereRequest) GetStreamName() string

func (*PremiereRequest) GetWorkerID 

func (x *PremiereRequest) GetWorkerID() string

func (*PremiereRequest) ProtoMessage 

func (*PremiereRequest) ProtoMessage()

func (*PremiereRequest) ProtoReflect 

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

func (*PremiereRequest) Reset 

func (x *PremiereRequest) Reset()

func (*PremiereRequest) String 

func (x *PremiereRequest) String() string

type Section 

type Section struct {
	Hours   uint32 `protobuf:"varint,1,opt,name=Hours,proto3" json:"Hours,omitempty"`
	Minutes uint32 `protobuf:"varint,2,opt,name=Minutes,proto3" json:"Minutes,omitempty"`
	Seconds uint32 `protobuf:"varint,3,opt,name=Seconds,proto3" json:"Seconds,omitempty"`
	// contains filtered or unexported fields
}

func (*Section) Descriptor deprecated 

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

Deprecated: Use Section.ProtoReflect.Descriptor instead.

func (*Section) GetHours 

func (x *Section) GetHours() uint32

func (*Section) GetMinutes 

func (x *Section) GetMinutes() uint32

func (*Section) GetSeconds 

func (x *Section) GetSeconds() uint32

func (*Section) ProtoMessage 

func (*Section) ProtoMessage()

func (*Section) ProtoReflect 

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

func (*Section) Reset 

func (x *Section) Reset()

func (*Section) String 

func (x *Section) String() string

type SelfStreamRequest 

type SelfStreamRequest struct {
	WorkerID   string `protobuf:"bytes,1,opt,name=WorkerID,proto3" json:"WorkerID,omitempty"`
	StreamKey  string `protobuf:"bytes,2,opt,name=StreamKey,proto3" json:"StreamKey,omitempty"`
	CourseSlug string `protobuf:"bytes,3,opt,name=CourseSlug,proto3" json:"CourseSlug,omitempty"`
	// contains filtered or unexported fields
}

func (*SelfStreamRequest) Descriptor deprecated 

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

Deprecated: Use SelfStreamRequest.ProtoReflect.Descriptor instead.

func (*SelfStreamRequest) GetCourseSlug 

func (x *SelfStreamRequest) GetCourseSlug() string

func (*SelfStreamRequest) GetStreamKey 

func (x *SelfStreamRequest) GetStreamKey() string

func (*SelfStreamRequest) GetWorkerID 

func (x *SelfStreamRequest) GetWorkerID() string

func (*SelfStreamRequest) ProtoMessage 

func (*SelfStreamRequest) ProtoMessage()

func (*SelfStreamRequest) ProtoReflect 

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

func (*SelfStreamRequest) Reset 

func (x *SelfStreamRequest) Reset()

func (*SelfStreamRequest) String 

func (x *SelfStreamRequest) String() string

type SelfStreamResponse 

type SelfStreamResponse struct {
	StreamID     uint32                 `protobuf:"varint,1,opt,name=StreamID,proto3" json:"StreamID,omitempty"`
	CourseSlug   string                 `protobuf:"bytes,2,opt,name=CourseSlug,proto3" json:"CourseSlug,omitempty"`
	CourseYear   uint32                 `protobuf:"varint,3,opt,name=CourseYear,proto3" json:"CourseYear,omitempty"`
	StreamStart  *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=StreamStart,proto3" json:"StreamStart,omitempty"`
	CourseTerm   string                 `protobuf:"bytes,5,opt,name=CourseTerm,proto3" json:"CourseTerm,omitempty"`
	UploadVoD    bool                   `protobuf:"varint,6,opt,name=uploadVoD,proto3" json:"uploadVoD,omitempty"`
	IngestServer string                 `protobuf:"bytes,7,opt,name=IngestServer,proto3" json:"IngestServer,omitempty"`
	StreamName   string                 `protobuf:"bytes,8,opt,name=StreamName,proto3" json:"StreamName,omitempty"`
	OutUrl       string                 `protobuf:"bytes,9,opt,name=OutUrl,proto3" json:"OutUrl,omitempty"`
	// contains filtered or unexported fields
}

func (*SelfStreamResponse) Descriptor deprecated 

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

Deprecated: Use SelfStreamResponse.ProtoReflect.Descriptor instead.

func (*SelfStreamResponse) GetCourseSlug 

func (x *SelfStreamResponse) GetCourseSlug() string

func (*SelfStreamResponse) GetCourseTerm 

func (x *SelfStreamResponse) GetCourseTerm() string

func (*SelfStreamResponse) GetCourseYear 

func (x *SelfStreamResponse) GetCourseYear() uint32

func (*SelfStreamResponse) GetIngestServer 

func (x *SelfStreamResponse) GetIngestServer() string

func (*SelfStreamResponse) GetOutUrl 

func (x *SelfStreamResponse) GetOutUrl() string

func (*SelfStreamResponse) GetStreamID 

func (x *SelfStreamResponse) GetStreamID() uint32

func (*SelfStreamResponse) GetStreamName 

func (x *SelfStreamResponse) GetStreamName() string

func (*SelfStreamResponse) GetStreamStart 

func (x *SelfStreamResponse) GetStreamStart() *timestamppb.Timestamp

func (*SelfStreamResponse) GetUploadVoD 

func (x *SelfStreamResponse) GetUploadVoD() bool

func (*SelfStreamResponse) ProtoMessage 

func (*SelfStreamResponse) ProtoMessage()

func (*SelfStreamResponse) ProtoReflect 

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

func (*SelfStreamResponse) Reset 

func (x *SelfStreamResponse) Reset()

func (*SelfStreamResponse) String 

func (x *SelfStreamResponse) String() string

type SilenceResults 

type SilenceResults struct {
	WorkerID string   `protobuf:"bytes,1,opt,name=WorkerID,proto3" json:"WorkerID,omitempty"`
	StreamID uint32   `protobuf:"varint,2,opt,name=StreamID,proto3" json:"StreamID,omitempty"`
	Starts   []uint32 `protobuf:"varint,3,rep,packed,name=starts,proto3" json:"starts,omitempty"`
	Ends     []uint32 `protobuf:"varint,4,rep,packed,name=ends,proto3" json:"ends,omitempty"`
	// contains filtered or unexported fields
}

func (*SilenceResults) Descriptor deprecated 

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

Deprecated: Use SilenceResults.ProtoReflect.Descriptor instead.

func (*SilenceResults) GetEnds 

func (x *SilenceResults) GetEnds() []uint32

func (*SilenceResults) GetStarts 

func (x *SilenceResults) GetStarts() []uint32

func (*SilenceResults) GetStreamID 

func (x *SilenceResults) GetStreamID() uint32

func (*SilenceResults) GetWorkerID 

func (x *SilenceResults) GetWorkerID() string

func (*SilenceResults) ProtoMessage 

func (*SilenceResults) ProtoMessage()

func (*SilenceResults) ProtoReflect 

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

func (*SilenceResults) Reset 

func (x *SilenceResults) Reset()

func (*SilenceResults) String 

func (x *SilenceResults) String() string

type Status 

type Status struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated 

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetOk 

func (x *Status) GetOk() bool

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

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

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

func (x *Status) String() string

type StreamFinished 

type StreamFinished struct {
	WorkerID string `protobuf:"bytes,1,opt,name=WorkerID,proto3" json:"WorkerID,omitempty"`
	StreamID uint32 `protobuf:"varint,2,opt,name=StreamID,proto3" json:"StreamID,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFinished) Descriptor deprecated 

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

Deprecated: Use StreamFinished.ProtoReflect.Descriptor instead.

func (*StreamFinished) GetStreamID 

func (x *StreamFinished) GetStreamID() uint32

func (*StreamFinished) GetWorkerID 

func (x *StreamFinished) GetWorkerID() string

func (*StreamFinished) ProtoMessage 

func (*StreamFinished) ProtoMessage()

func (*StreamFinished) ProtoReflect 

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

func (*StreamFinished) Reset 

func (x *StreamFinished) Reset()

func (*StreamFinished) String 

func (x *StreamFinished) String() string

type StreamRequest 

type StreamRequest struct {
	WorkerId     string                 `protobuf:"bytes,1,opt,name=WorkerId,proto3" json:"WorkerId,omitempty"`
	SourceType   string                 `protobuf:"bytes,2,opt,name=SourceType,proto3" json:"SourceType,omitempty"`
	SourceUrl    string                 `protobuf:"bytes,3,opt,name=SourceUrl,proto3" json:"SourceUrl,omitempty"`
	CourseSlug   string                 `protobuf:"bytes,4,opt,name=CourseSlug,proto3" json:"CourseSlug,omitempty"`
	Start        *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=Start,proto3" json:"Start,omitempty"`
	End          *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=End,proto3" json:"End,omitempty"`
	PublishVoD   bool                   `protobuf:"varint,9,opt,name=PublishVoD,proto3" json:"PublishVoD,omitempty"`
	StreamID     uint32                 `protobuf:"varint,10,opt,name=StreamID,proto3" json:"StreamID,omitempty"`
	CourseTerm   string                 `protobuf:"bytes,11,opt,name=CourseTerm,proto3" json:"CourseTerm,omitempty"`
	CourseYear   uint32                 `protobuf:"varint,12,opt,name=CourseYear,proto3" json:"CourseYear,omitempty"`
	StreamName   string                 `protobuf:"bytes,13,opt,name=StreamName,proto3" json:"StreamName,omitempty"`
	IngestServer string                 `protobuf:"bytes,14,opt,name=IngestServer,proto3" json:"IngestServer,omitempty"`
	OutUrl       string                 `protobuf:"bytes,15,opt,name=OutUrl,proto3" json:"OutUrl,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamRequest) Descriptor deprecated 

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

Deprecated: Use StreamRequest.ProtoReflect.Descriptor instead.

func (*StreamRequest) GetCourseSlug 

func (x *StreamRequest) GetCourseSlug() string

func (*StreamRequest) GetCourseTerm 

func (x *StreamRequest) GetCourseTerm() string

func (*StreamRequest) GetCourseYear 

func (x *StreamRequest) GetCourseYear() uint32

func (*StreamRequest) GetEnd 

func (x *StreamRequest) GetEnd() *timestamppb.Timestamp

func (*StreamRequest) GetIngestServer 

func (x *StreamRequest) GetIngestServer() string

func (*StreamRequest) GetOutUrl 

func (x *StreamRequest) GetOutUrl() string

func (*StreamRequest) GetPublishVoD 

func (x *StreamRequest) GetPublishVoD() bool

func (*StreamRequest) GetSourceType 

func (x *StreamRequest) GetSourceType() string

func (*StreamRequest) GetSourceUrl 

func (x *StreamRequest) GetSourceUrl() string

func (*StreamRequest) GetStart 

func (x *StreamRequest) GetStart() *timestamppb.Timestamp

func (*StreamRequest) GetStreamID 

func (x *StreamRequest) GetStreamID() uint32

func (*StreamRequest) GetStreamName 

func (x *StreamRequest) GetStreamName() string

func (*StreamRequest) GetWorkerId 

func (x *StreamRequest) GetWorkerId() string

func (*StreamRequest) ProtoMessage 

func (*StreamRequest) ProtoMessage()

func (*StreamRequest) ProtoReflect 

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

func (*StreamRequest) Reset 

func (x *StreamRequest) Reset()

func (*StreamRequest) String 

func (x *StreamRequest) String() string

type StreamStarted 

type StreamStarted struct {
	WorkerID   string `protobuf:"bytes,1,opt,name=WorkerID,proto3" json:"WorkerID,omitempty"`
	StreamID   uint32 `protobuf:"varint,2,opt,name=StreamID,proto3" json:"StreamID,omitempty"`
	HlsUrl     string `protobuf:"bytes,3,opt,name=HlsUrl,proto3" json:"HlsUrl,omitempty"`
	SourceType string `protobuf:"bytes,5,opt,name=SourceType,proto3" json:"SourceType,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamStarted) Descriptor deprecated 

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

Deprecated: Use StreamStarted.ProtoReflect.Descriptor instead.

func (*StreamStarted) GetHlsUrl 

func (x *StreamStarted) GetHlsUrl() string

func (*StreamStarted) GetSourceType 

func (x *StreamStarted) GetSourceType() string

func (*StreamStarted) GetStreamID 

func (x *StreamStarted) GetStreamID() uint32

func (*StreamStarted) GetWorkerID 

func (x *StreamStarted) GetWorkerID() string

func (*StreamStarted) ProtoMessage 

func (*StreamStarted) ProtoMessage()

func (*StreamStarted) ProtoReflect 

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

func (*StreamStarted) Reset 

func (x *StreamStarted) Reset()

func (*StreamStarted) String 

func (x *StreamStarted) String() string

type ThumbnailsFinished 

type ThumbnailsFinished struct {
	WorkerID           string `protobuf:"bytes,1,opt,name=WorkerID,proto3" json:"WorkerID,omitempty"`
	StreamID           uint32 `protobuf:"varint,2,opt,name=StreamID,proto3" json:"StreamID,omitempty"`
	FilePath           string `protobuf:"bytes,3,opt,name=FilePath,proto3" json:"FilePath,omitempty"`
	Interval           uint32 `protobuf:"varint,4,opt,name=Interval,proto3" json:"Interval,omitempty"`
	SourceType         string `protobuf:"bytes,5,opt,name=SourceType,proto3" json:"SourceType,omitempty"`
	LargeThumbnailPath string `protobuf:"bytes,6,opt,name=LargeThumbnailPath,proto3" json:"LargeThumbnailPath,omitempty"`
	// contains filtered or unexported fields
}

func (*ThumbnailsFinished) Descriptor deprecated 

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

Deprecated: Use ThumbnailsFinished.ProtoReflect.Descriptor instead.

func (*ThumbnailsFinished) GetFilePath 

func (x *ThumbnailsFinished) GetFilePath() string

func (*ThumbnailsFinished) GetInterval 

func (x *ThumbnailsFinished) GetInterval() uint32

func (*ThumbnailsFinished) GetLargeThumbnailPath 

func (x *ThumbnailsFinished) GetLargeThumbnailPath() string

func (*ThumbnailsFinished) GetSourceType 

func (x *ThumbnailsFinished) GetSourceType() string

func (*ThumbnailsFinished) GetStreamID 

func (x *ThumbnailsFinished) GetStreamID() uint32

func (*ThumbnailsFinished) GetWorkerID 

func (x *ThumbnailsFinished) GetWorkerID() string

func (*ThumbnailsFinished) ProtoMessage 

func (*ThumbnailsFinished) ProtoMessage()

func (*ThumbnailsFinished) ProtoReflect 

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

func (*ThumbnailsFinished) Reset 

func (x *ThumbnailsFinished) Reset()

func (*ThumbnailsFinished) String 

func (x *ThumbnailsFinished) String() string

type ToWorkerClient 

type ToWorkerClient interface {
	// Requests a stream from a lecture hall
	RequestStream(ctx context.Context, in *StreamRequest, opts ...grpc.CallOption) (*Status, error)
	RequestPremiere(ctx context.Context, in *PremiereRequest, opts ...grpc.CallOption) (*Status, error)
	RequestStreamEnd(ctx context.Context, in *EndStreamRequest, opts ...grpc.CallOption) (*Status, error)
	RequestWaveform(ctx context.Context, in *WaveformRequest, opts ...grpc.CallOption) (*WaveFormResponse, error)
	RequestCut(ctx context.Context, in *CutRequest, opts ...grpc.CallOption) (*CutResponse, error)
	GenerateThumbnails(ctx context.Context, in *GenerateThumbnailRequest, opts ...grpc.CallOption) (*Status, error)
	GenerateLivePreview(ctx context.Context, in *LivePreviewRequest, opts ...grpc.CallOption) (*LivePreviewResponse, error)
	GenerateSectionImages(ctx context.Context, in *GenerateSectionImageRequest, opts ...grpc.CallOption) (*GenerateSectionImageResponse, error)
	DeleteSectionImage(ctx context.Context, in *DeleteSectionImageRequest, opts ...grpc.CallOption) (*Status, error)
	CombineThumbnails(ctx context.Context, in *CombineThumbnailsRequest, opts ...grpc.CallOption) (*CombineThumbnailsResponse, error)
}

ToWorkerClient is the client API for ToWorker service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.golang.ir/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewToWorkerClient 

func NewToWorkerClient(cc grpc.ClientConnInterface) ToWorkerClient

type ToWorkerServer 

type ToWorkerServer interface {
	// Requests a stream from a lecture hall
	RequestStream(context.Context, *StreamRequest) (*Status, error)
	RequestPremiere(context.Context, *PremiereRequest) (*Status, error)
	RequestStreamEnd(context.Context, *EndStreamRequest) (*Status, error)
	RequestWaveform(context.Context, *WaveformRequest) (*WaveFormResponse, error)
	RequestCut(context.Context, *CutRequest) (*CutResponse, error)
	GenerateThumbnails(context.Context, *GenerateThumbnailRequest) (*Status, error)
	GenerateLivePreview(context.Context, *LivePreviewRequest) (*LivePreviewResponse, error)
	GenerateSectionImages(context.Context, *GenerateSectionImageRequest) (*GenerateSectionImageResponse, error)
	DeleteSectionImage(context.Context, *DeleteSectionImageRequest) (*Status, error)
	CombineThumbnails(context.Context, *CombineThumbnailsRequest) (*CombineThumbnailsResponse, error)
	// contains filtered or unexported methods
}

ToWorkerServer is the server API for ToWorker service. All implementations must embed UnimplementedToWorkerServer for forward compatibility

type TranscodingFinished 

type TranscodingFinished struct {
	WorkerID   string `protobuf:"bytes,1,opt,name=WorkerID,proto3" json:"WorkerID,omitempty"`
	StreamID   uint32 `protobuf:"varint,2,opt,name=StreamID,proto3" json:"StreamID,omitempty"`
	FilePath   string `protobuf:"bytes,3,opt,name=FilePath,proto3" json:"FilePath,omitempty"`
	Duration   uint32 `protobuf:"varint,4,opt,name=Duration,proto3" json:"Duration,omitempty"`
	SourceType string `protobuf:"bytes,5,opt,name=SourceType,proto3" json:"SourceType,omitempty"`
	// contains filtered or unexported fields
}

func (*TranscodingFinished) Descriptor deprecated 

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

Deprecated: Use TranscodingFinished.ProtoReflect.Descriptor instead.

func (*TranscodingFinished) GetDuration 

func (x *TranscodingFinished) GetDuration() uint32

func (*TranscodingFinished) GetFilePath 

func (x *TranscodingFinished) GetFilePath() string

func (*TranscodingFinished) GetSourceType 

func (x *TranscodingFinished) GetSourceType() string

func (*TranscodingFinished) GetStreamID 

func (x *TranscodingFinished) GetStreamID() uint32

func (*TranscodingFinished) GetWorkerID 

func (x *TranscodingFinished) GetWorkerID() string

func (*TranscodingFinished) ProtoMessage 

func (*TranscodingFinished) ProtoMessage()

func (*TranscodingFinished) ProtoReflect 

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

func (*TranscodingFinished) Reset 

func (x *TranscodingFinished) Reset()

func (*TranscodingFinished) String 

func (x *TranscodingFinished) String() string

type UnimplementedFromWorkerServer 

type UnimplementedFromWorkerServer struct {
}

UnimplementedFromWorkerServer must be embedded to have forward compatible implementations.

func (UnimplementedFromWorkerServer) GetStreamInfoForUpload 

func (UnimplementedFromWorkerServer) GetStreamInfoForUpload(context.Context, *GetStreamInfoForUploadRequest) (*GetStreamInfoForUploadResponse, error)

func (UnimplementedFromWorkerServer) JoinWorkers 

func (UnimplementedFromWorkerServer) JoinWorkers(context.Context, *JoinWorkersRequest) (*JoinWorkersResponse, error)

func (UnimplementedFromWorkerServer) NotifySilenceResults 

func (UnimplementedFromWorkerServer) NotifySilenceResults(context.Context, *SilenceResults) (*Status, error)

func (UnimplementedFromWorkerServer) NotifyStreamFinished 

func (UnimplementedFromWorkerServer) NotifyStreamFinished(context.Context, *StreamFinished) (*Status, error)

func (UnimplementedFromWorkerServer) NotifyStreamStarted 

func (UnimplementedFromWorkerServer) NotifyStreamStarted(context.Context, *StreamStarted) (*Status, error)

func (UnimplementedFromWorkerServer) NotifyThumbnailsFinished 

func (UnimplementedFromWorkerServer) NotifyThumbnailsFinished(context.Context, *ThumbnailsFinished) (*Status, error)

func (UnimplementedFromWorkerServer) NotifyTranscodingFailure 

func (UnimplementedFromWorkerServer) NotifyTranscodingFailure(context.Context, *NotifyTranscodingFailureRequest) (*NotifyTranscodingFailureResponse, error)

func (UnimplementedFromWorkerServer) NotifyTranscodingFinished 

func (UnimplementedFromWorkerServer) NotifyTranscodingFinished(context.Context, *TranscodingFinished) (*Status, error)

func (UnimplementedFromWorkerServer) NotifyTranscodingProgress 

func (UnimplementedFromWorkerServer) NotifyTranscodingProgress(FromWorker_NotifyTranscodingProgressServer) error

func (UnimplementedFromWorkerServer) NotifyUploadFinished 

func (UnimplementedFromWorkerServer) NotifyUploadFinished(context.Context, *UploadFinished) (*Status, error)

func (UnimplementedFromWorkerServer) SendHeartBeat 

func (UnimplementedFromWorkerServer) SendHeartBeat(context.Context, *HeartBeat) (*Status, error)

func (UnimplementedFromWorkerServer) SendSelfStreamRequest 

func (UnimplementedFromWorkerServer) SendSelfStreamRequest(context.Context, *SelfStreamRequest) (*SelfStreamResponse, error)

type UnimplementedToWorkerServer 

type UnimplementedToWorkerServer struct {
}

UnimplementedToWorkerServer must be embedded to have forward compatible implementations.

func (UnimplementedToWorkerServer) CombineThumbnails 

func (UnimplementedToWorkerServer) CombineThumbnails(context.Context, *CombineThumbnailsRequest) (*CombineThumbnailsResponse, error)

func (UnimplementedToWorkerServer) DeleteSectionImage 

func (UnimplementedToWorkerServer) DeleteSectionImage(context.Context, *DeleteSectionImageRequest) (*Status, error)

func (UnimplementedToWorkerServer) GenerateLivePreview 

func (UnimplementedToWorkerServer) GenerateLivePreview(context.Context, *LivePreviewRequest) (*LivePreviewResponse, error)

func (UnimplementedToWorkerServer) GenerateSectionImages 

func (UnimplementedToWorkerServer) GenerateSectionImages(context.Context, *GenerateSectionImageRequest) (*GenerateSectionImageResponse, error)

func (UnimplementedToWorkerServer) GenerateThumbnails 

func (UnimplementedToWorkerServer) GenerateThumbnails(context.Context, *GenerateThumbnailRequest) (*Status, error)

func (UnimplementedToWorkerServer) RequestCut 

func (UnimplementedToWorkerServer) RequestCut(context.Context, *CutRequest) (*CutResponse, error)

func (UnimplementedToWorkerServer) RequestPremiere 

func (UnimplementedToWorkerServer) RequestPremiere(context.Context, *PremiereRequest) (*Status, error)

func (UnimplementedToWorkerServer) RequestStream 

func (UnimplementedToWorkerServer) RequestStream(context.Context, *StreamRequest) (*Status, error)

func (UnimplementedToWorkerServer) RequestStreamEnd 

func (UnimplementedToWorkerServer) RequestStreamEnd(context.Context, *EndStreamRequest) (*Status, error)

func (UnimplementedToWorkerServer) RequestWaveform 

func (UnimplementedToWorkerServer) RequestWaveform(context.Context, *WaveformRequest) (*WaveFormResponse, error)

type UnsafeFromWorkerServer 

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

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

type UnsafeToWorkerServer 

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

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

type UploadFinished 

type UploadFinished struct {
	WorkerID     string `protobuf:"bytes,1,opt,name=WorkerID,proto3" json:"WorkerID,omitempty"`
	StreamID     uint32 `protobuf:"varint,2,opt,name=StreamID,proto3" json:"StreamID,omitempty"`
	HLSUrl       string `protobuf:"bytes,4,opt,name=HLSUrl,proto3" json:"HLSUrl,omitempty"`
	SourceType   string `protobuf:"bytes,5,opt,name=SourceType,proto3" json:"SourceType,omitempty"`
	ThumbnailUrl string `protobuf:"bytes,6,opt,name=ThumbnailUrl,proto3" json:"ThumbnailUrl,omitempty"`
	// contains filtered or unexported fields
}

func (*UploadFinished) Descriptor deprecated 

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

Deprecated: Use UploadFinished.ProtoReflect.Descriptor instead.

func (*UploadFinished) GetHLSUrl 

func (x *UploadFinished) GetHLSUrl() string

func (*UploadFinished) GetSourceType 

func (x *UploadFinished) GetSourceType() string

func (*UploadFinished) GetStreamID 

func (x *UploadFinished) GetStreamID() uint32

func (*UploadFinished) GetThumbnailUrl 

func (x *UploadFinished) GetThumbnailUrl() string

func (*UploadFinished) GetWorkerID 

func (x *UploadFinished) GetWorkerID() string

func (*UploadFinished) ProtoMessage 

func (*UploadFinished) ProtoMessage()

func (*UploadFinished) ProtoReflect 

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

func (*UploadFinished) Reset 

func (x *UploadFinished) Reset()

func (*UploadFinished) String 

func (x *UploadFinished) String() string

type WaveFormResponse 

type WaveFormResponse struct {
	Waveform []byte `protobuf:"bytes,1,opt,name=Waveform,proto3" json:"Waveform,omitempty"`
	// contains filtered or unexported fields
}

func (*WaveFormResponse) Descriptor deprecated 

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

Deprecated: Use WaveFormResponse.ProtoReflect.Descriptor instead.

func (*WaveFormResponse) GetWaveform 

func (x *WaveFormResponse) GetWaveform() []byte

func (*WaveFormResponse) ProtoMessage 

func (*WaveFormResponse) ProtoMessage()

func (*WaveFormResponse) ProtoReflect 

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

func (*WaveFormResponse) Reset 

func (x *WaveFormResponse) Reset()

func (*WaveFormResponse) String 

func (x *WaveFormResponse) String() string

type WaveformRequest 

type WaveformRequest struct {
	WorkerId string `protobuf:"bytes,1,opt,name=WorkerId,proto3" json:"WorkerId,omitempty"`
	File     string `protobuf:"bytes,2,opt,name=File,proto3" json:"File,omitempty"`
	// contains filtered or unexported fields
}

func (*WaveformRequest) Descriptor deprecated 

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

Deprecated: Use WaveformRequest.ProtoReflect.Descriptor instead.

func (*WaveformRequest) GetFile 

func (x *WaveformRequest) GetFile() string

func (*WaveformRequest) GetWorkerId 

func (x *WaveformRequest) GetWorkerId() string

func (*WaveformRequest) ProtoMessage 

func (*WaveformRequest) ProtoMessage()

func (*WaveformRequest) ProtoReflect 

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

func (*WaveformRequest) Reset 

func (x *WaveformRequest) Reset()

func (*WaveformRequest) String 

func (x *WaveformRequest) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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