grpc_runner_v1

package
v0.0.0-...-f0b9b21 Latest Latest
Warning

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

Go to latest
Published: Feb 14, 2024 License: GPL-3.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source
const (
	RunnerService_Auth_FullMethodName      = "/grpc_runner_v1.RunnerService/Auth"
	RunnerService_Stream_FullMethodName    = "/grpc_runner_v1.RunnerService/Stream"
	RunnerService_Operation_FullMethodName = "/grpc_runner_v1.RunnerService/Operation"
)

Variables

View Source
var (
	StreamType_name = map[int32]string{
		0: "IMAGE",
		1: "VIDEO",
	}
	StreamType_value = map[string]int32{
		"IMAGE": 0,
		"VIDEO": 1,
	}
)

Enum value maps for StreamType.

View Source
var (
	Operation_name = map[int32]string{
		0: "OPEN",
		1: "INTERRUPT",
		2: "CLOSE",
		3: "PROGRESS",
		4: "METADATA",
	}
	Operation_value = map[string]int32{
		"OPEN":      0,
		"INTERRUPT": 1,
		"CLOSE":     2,
		"PROGRESS":  3,
		"METADATA":  4,
	}
)

Enum value maps for Operation.

View Source
var (
	ProgressRequest_Type_name = map[int32]string{
		0: "DOWNLOAD",
		1: "METADATA",
		2: "TRANSCODE",
		3: "UPLOAD",
	}
	ProgressRequest_Type_value = map[string]int32{
		"DOWNLOAD":  0,
		"METADATA":  1,
		"TRANSCODE": 2,
		"UPLOAD":    3,
	}
)

Enum value maps for ProgressRequest_Type.

View Source
var File_api_grpc_runner_v1_grpc_runner_proto protoreflect.FileDescriptor
View Source
var RunnerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "grpc_runner_v1.RunnerService",
	HandlerType: (*RunnerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Auth",
			Handler:    _RunnerService_Auth_Handler,
		},
		{
			MethodName: "Stream",
			Handler:    _RunnerService_Stream_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Operation",
			Handler:       _RunnerService_Operation_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "api/grpc_runner/v1/grpc_runner.proto",
}

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

Functions

func RegisterRunnerServiceServer

func RegisterRunnerServiceServer(s grpc.ServiceRegistrar, srv RunnerServiceServer)

Types

type AuthRequest

type AuthRequest struct {
	User     string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Hostname string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Ident    string `protobuf:"bytes,3,opt,name=ident,proto3" json:"ident,omitempty"`
	Docker   bool   `protobuf:"varint,4,opt,name=docker,proto3" json:"docker,omitempty"`
	// contains filtered or unexported fields
}

func (*AuthRequest) Descriptor deprecated

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

Deprecated: Use AuthRequest.ProtoReflect.Descriptor instead.

func (*AuthRequest) GetDocker

func (x *AuthRequest) GetDocker() bool

func (*AuthRequest) GetHostname

func (x *AuthRequest) GetHostname() string

func (*AuthRequest) GetIdent

func (x *AuthRequest) GetIdent() string

func (*AuthRequest) GetUser

func (x *AuthRequest) GetUser() string

func (*AuthRequest) ProtoMessage

func (*AuthRequest) ProtoMessage()

func (*AuthRequest) ProtoReflect

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

func (*AuthRequest) Reset

func (x *AuthRequest) Reset()

func (*AuthRequest) String

func (x *AuthRequest) String() string

type AuthResponse

type AuthResponse struct {
	Token     string                 `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	ExpiresAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// contains filtered or unexported fields
}

func (*AuthResponse) Descriptor deprecated

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

Deprecated: Use AuthResponse.ProtoReflect.Descriptor instead.

func (*AuthResponse) GetExpiresAt

func (x *AuthResponse) GetExpiresAt() *timestamppb.Timestamp

func (*AuthResponse) GetToken

func (x *AuthResponse) GetToken() string

func (*AuthResponse) ProtoMessage

func (*AuthResponse) ProtoMessage()

func (*AuthResponse) ProtoReflect

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

func (*AuthResponse) Reset

func (x *AuthResponse) Reset()

func (*AuthResponse) String

func (x *AuthResponse) String() string

type CloseRequest

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

func (*CloseRequest) Descriptor deprecated

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

Deprecated: Use CloseRequest.ProtoReflect.Descriptor instead.

func (*CloseRequest) GetError

func (x *CloseRequest) GetError() string

func (*CloseRequest) ProtoMessage

func (*CloseRequest) ProtoMessage()

func (*CloseRequest) ProtoReflect

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

func (*CloseRequest) Reset

func (x *CloseRequest) Reset()

func (*CloseRequest) String

func (x *CloseRequest) String() string

type CloseResponse

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

func (*CloseResponse) Descriptor deprecated

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

Deprecated: Use CloseResponse.ProtoReflect.Descriptor instead.

func (*CloseResponse) ProtoMessage

func (*CloseResponse) ProtoMessage()

func (*CloseResponse) ProtoReflect

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

func (*CloseResponse) Reset

func (x *CloseResponse) Reset()

func (*CloseResponse) String

func (x *CloseResponse) String() string

type InterruptRequest

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

func (*InterruptRequest) Descriptor deprecated

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

Deprecated: Use InterruptRequest.ProtoReflect.Descriptor instead.

func (*InterruptRequest) GetError

func (x *InterruptRequest) GetError() string

func (*InterruptRequest) ProtoMessage

func (*InterruptRequest) ProtoMessage()

func (*InterruptRequest) ProtoReflect

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

func (*InterruptRequest) Reset

func (x *InterruptRequest) Reset()

func (*InterruptRequest) String

func (x *InterruptRequest) String() string

type InterruptResponse

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

func (*InterruptResponse) Descriptor deprecated

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

Deprecated: Use InterruptResponse.ProtoReflect.Descriptor instead.

func (*InterruptResponse) ProtoMessage

func (*InterruptResponse) ProtoMessage()

func (*InterruptResponse) ProtoReflect

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

func (*InterruptResponse) Reset

func (x *InterruptResponse) Reset()

func (*InterruptResponse) String

func (x *InterruptResponse) String() string

type MetadataImage

type MetadataImage struct {
	Sha256 string `protobuf:"bytes,1,opt,name=sha256,proto3" json:"sha256,omitempty"`
	Size   int64  `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*MetadataImage) Descriptor deprecated

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

Deprecated: Use MetadataImage.ProtoReflect.Descriptor instead.

func (*MetadataImage) GetSha256

func (x *MetadataImage) GetSha256() string

func (*MetadataImage) GetSize

func (x *MetadataImage) GetSize() int64

func (*MetadataImage) ProtoMessage

func (*MetadataImage) ProtoMessage()

func (*MetadataImage) ProtoReflect

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

func (*MetadataImage) Reset

func (x *MetadataImage) Reset()

func (*MetadataImage) String

func (x *MetadataImage) String() string

type MetadataRequest

type MetadataRequest struct {

	// Deprecated: Marked as deprecated in api/grpc_runner/v1/grpc_runner.proto.
	VideoSha256 string `protobuf:"bytes,1,opt,name=video_sha256,json=videoSha256,proto3" json:"video_sha256,omitempty"`
	// Deprecated: Marked as deprecated in api/grpc_runner/v1/grpc_runner.proto.
	ImageSha256 string `protobuf:"bytes,2,opt,name=image_sha256,json=imageSha256,proto3" json:"image_sha256,omitempty"`
	// Deprecated: Marked as deprecated in api/grpc_runner/v1/grpc_runner.proto.
	VideoCrc32 string `protobuf:"bytes,3,opt,name=video_crc32,json=videoCrc32,proto3" json:"video_crc32,omitempty"`
	// Deprecated: Marked as deprecated in api/grpc_runner/v1/grpc_runner.proto.
	ImageSize int64 `protobuf:"varint,4,opt,name=image_size,json=imageSize,proto3" json:"image_size,omitempty"`
	// Deprecated: Marked as deprecated in api/grpc_runner/v1/grpc_runner.proto.
	VideoSize int64 `protobuf:"varint,5,opt,name=video_size,json=videoSize,proto3" json:"video_size,omitempty"`
	// Deprecated: Marked as deprecated in api/grpc_runner/v1/grpc_runner.proto.
	Duration float64        `protobuf:"fixed64,6,opt,name=duration,proto3" json:"duration,omitempty"`
	Video    *MetadataVideo `protobuf:"bytes,7,opt,name=video,proto3" json:"video,omitempty"`
	Image    *MetadataImage `protobuf:"bytes,8,opt,name=image,proto3" json:"image,omitempty"`
	// contains filtered or unexported fields
}

func (*MetadataRequest) Descriptor deprecated

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

Deprecated: Use MetadataRequest.ProtoReflect.Descriptor instead.

func (*MetadataRequest) GetDuration deprecated

func (x *MetadataRequest) GetDuration() float64

Deprecated: Marked as deprecated in api/grpc_runner/v1/grpc_runner.proto.

func (*MetadataRequest) GetImage

func (x *MetadataRequest) GetImage() *MetadataImage

func (*MetadataRequest) GetImageSha256 deprecated

func (x *MetadataRequest) GetImageSha256() string

Deprecated: Marked as deprecated in api/grpc_runner/v1/grpc_runner.proto.

func (*MetadataRequest) GetImageSize deprecated

func (x *MetadataRequest) GetImageSize() int64

Deprecated: Marked as deprecated in api/grpc_runner/v1/grpc_runner.proto.

func (*MetadataRequest) GetVideo

func (x *MetadataRequest) GetVideo() *MetadataVideo

func (*MetadataRequest) GetVideoCrc32 deprecated

func (x *MetadataRequest) GetVideoCrc32() string

Deprecated: Marked as deprecated in api/grpc_runner/v1/grpc_runner.proto.

func (*MetadataRequest) GetVideoSha256 deprecated

func (x *MetadataRequest) GetVideoSha256() string

Deprecated: Marked as deprecated in api/grpc_runner/v1/grpc_runner.proto.

func (*MetadataRequest) GetVideoSize deprecated

func (x *MetadataRequest) GetVideoSize() int64

Deprecated: Marked as deprecated in api/grpc_runner/v1/grpc_runner.proto.

func (*MetadataRequest) ProtoMessage

func (*MetadataRequest) ProtoMessage()

func (*MetadataRequest) ProtoReflect

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

func (*MetadataRequest) Reset

func (x *MetadataRequest) Reset()

func (*MetadataRequest) String

func (x *MetadataRequest) String() string

type MetadataResponse

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

func (*MetadataResponse) Descriptor deprecated

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

Deprecated: Use MetadataResponse.ProtoReflect.Descriptor instead.

func (*MetadataResponse) ProtoMessage

func (*MetadataResponse) ProtoMessage()

func (*MetadataResponse) ProtoReflect

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

func (*MetadataResponse) Reset

func (x *MetadataResponse) Reset()

func (*MetadataResponse) String

func (x *MetadataResponse) String() string

type MetadataVideo

type MetadataVideo struct {
	Sha256    string                  `protobuf:"bytes,1,opt,name=sha256,proto3" json:"sha256,omitempty"`
	Size      int64                   `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Crc32     string                  `protobuf:"bytes,3,opt,name=crc32,proto3" json:"crc32,omitempty"`
	Duration  float64                 `protobuf:"fixed64,4,opt,name=duration,proto3" json:"duration,omitempty"`
	Dimension *MetadataVideoDimension `protobuf:"bytes,5,opt,name=dimension,proto3" json:"dimension,omitempty"`
	// contains filtered or unexported fields
}

func (*MetadataVideo) Descriptor deprecated

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

Deprecated: Use MetadataVideo.ProtoReflect.Descriptor instead.

func (*MetadataVideo) GetCrc32

func (x *MetadataVideo) GetCrc32() string

func (*MetadataVideo) GetDimension

func (x *MetadataVideo) GetDimension() *MetadataVideoDimension

func (*MetadataVideo) GetDuration

func (x *MetadataVideo) GetDuration() float64

func (*MetadataVideo) GetSha256

func (x *MetadataVideo) GetSha256() string

func (*MetadataVideo) GetSize

func (x *MetadataVideo) GetSize() int64

func (*MetadataVideo) ProtoMessage

func (*MetadataVideo) ProtoMessage()

func (*MetadataVideo) ProtoReflect

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

func (*MetadataVideo) Reset

func (x *MetadataVideo) Reset()

func (*MetadataVideo) String

func (x *MetadataVideo) String() string

type MetadataVideoDimension

type MetadataVideoDimension struct {
	Height int64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	Width  int64 `protobuf:"varint,2,opt,name=width,proto3" json:"width,omitempty"`
	// contains filtered or unexported fields
}

func (*MetadataVideoDimension) Descriptor deprecated

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

Deprecated: Use MetadataVideoDimension.ProtoReflect.Descriptor instead.

func (*MetadataVideoDimension) GetHeight

func (x *MetadataVideoDimension) GetHeight() int64

func (*MetadataVideoDimension) GetWidth

func (x *MetadataVideoDimension) GetWidth() int64

func (*MetadataVideoDimension) ProtoMessage

func (*MetadataVideoDimension) ProtoMessage()

func (*MetadataVideoDimension) ProtoReflect

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

func (*MetadataVideoDimension) Reset

func (x *MetadataVideoDimension) Reset()

func (*MetadataVideoDimension) String

func (x *MetadataVideoDimension) String() string

type OpenRequest

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

func (*OpenRequest) Descriptor deprecated

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

Deprecated: Use OpenRequest.ProtoReflect.Descriptor instead.

func (*OpenRequest) GetError

func (x *OpenRequest) GetError() string

func (*OpenRequest) ProtoMessage

func (*OpenRequest) ProtoMessage()

func (*OpenRequest) ProtoReflect

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

func (*OpenRequest) Reset

func (x *OpenRequest) Reset()

func (*OpenRequest) String

func (x *OpenRequest) String() string

type OpenResponse

type OpenResponse struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Size    int64  `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*OpenResponse) Descriptor deprecated

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

Deprecated: Use OpenResponse.ProtoReflect.Descriptor instead.

func (*OpenResponse) GetAddress

func (x *OpenResponse) GetAddress() string

func (*OpenResponse) GetSize

func (x *OpenResponse) GetSize() int64

func (*OpenResponse) ProtoMessage

func (*OpenResponse) ProtoMessage()

func (*OpenResponse) ProtoReflect

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

func (*OpenResponse) Reset

func (x *OpenResponse) Reset()

func (*OpenResponse) String

func (x *OpenResponse) String() string

type Operation

type Operation int32
const (
	Operation_OPEN      Operation = 0
	Operation_INTERRUPT Operation = 1
	Operation_CLOSE     Operation = 2
	Operation_PROGRESS  Operation = 3
	Operation_METADATA  Operation = 4
)

func (Operation) Descriptor

func (Operation) Descriptor() protoreflect.EnumDescriptor

func (Operation) Enum

func (x Operation) Enum() *Operation

func (Operation) EnumDescriptor deprecated

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

Deprecated: Use Operation.Descriptor instead.

func (Operation) Number

func (x Operation) Number() protoreflect.EnumNumber

func (Operation) String

func (x Operation) String() string

func (Operation) Type

type OperationRequest

type OperationRequest struct {
	Operation Operation `protobuf:"varint,1,opt,name=operation,proto3,enum=grpc_runner_v1.Operation" json:"operation,omitempty"`
	// Types that are assignable to Request:
	//
	//	*OperationRequest_OpenRequest
	//	*OperationRequest_InterruptRequest
	//	*OperationRequest_CloseRequest
	//	*OperationRequest_ProgressRequest
	//	*OperationRequest_MetadataRequest
	Request isOperationRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

func (*OperationRequest) Descriptor deprecated

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

Deprecated: Use OperationRequest.ProtoReflect.Descriptor instead.

func (*OperationRequest) GetCloseRequest

func (x *OperationRequest) GetCloseRequest() *CloseRequest

func (*OperationRequest) GetInterruptRequest

func (x *OperationRequest) GetInterruptRequest() *InterruptRequest

func (*OperationRequest) GetMetadataRequest

func (x *OperationRequest) GetMetadataRequest() *MetadataRequest

func (*OperationRequest) GetOpenRequest

func (x *OperationRequest) GetOpenRequest() *OpenRequest

func (*OperationRequest) GetOperation

func (x *OperationRequest) GetOperation() Operation

func (*OperationRequest) GetProgressRequest

func (x *OperationRequest) GetProgressRequest() *ProgressRequest

func (*OperationRequest) GetRequest

func (m *OperationRequest) GetRequest() isOperationRequest_Request

func (*OperationRequest) ProtoMessage

func (*OperationRequest) ProtoMessage()

func (*OperationRequest) ProtoReflect

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

func (*OperationRequest) Reset

func (x *OperationRequest) Reset()

func (*OperationRequest) String

func (x *OperationRequest) String() string

type OperationRequest_CloseRequest

type OperationRequest_CloseRequest struct {
	CloseRequest *CloseRequest `protobuf:"bytes,5,opt,name=close_request,json=closeRequest,proto3,oneof"`
}

type OperationRequest_InterruptRequest

type OperationRequest_InterruptRequest struct {
	InterruptRequest *InterruptRequest `protobuf:"bytes,4,opt,name=interrupt_request,json=interruptRequest,proto3,oneof"`
}

type OperationRequest_MetadataRequest

type OperationRequest_MetadataRequest struct {
	MetadataRequest *MetadataRequest `protobuf:"bytes,7,opt,name=metadata_request,json=metadataRequest,proto3,oneof"`
}

type OperationRequest_OpenRequest

type OperationRequest_OpenRequest struct {
	OpenRequest *OpenRequest `protobuf:"bytes,2,opt,name=open_request,json=openRequest,proto3,oneof"`
}

type OperationRequest_ProgressRequest

type OperationRequest_ProgressRequest struct {
	ProgressRequest *ProgressRequest `protobuf:"bytes,6,opt,name=progress_request,json=progressRequest,proto3,oneof"`
}

type OperationResponse

type OperationResponse struct {
	Operation Operation `protobuf:"varint,1,opt,name=operation,proto3,enum=grpc_runner_v1.Operation" json:"operation,omitempty"`
	// Types that are assignable to Response:
	//
	//	*OperationResponse_OpenResponse
	//	*OperationResponse_InterruptResponse
	//	*OperationResponse_CloseResponse
	//	*OperationResponse_ProgressResponse
	//	*OperationResponse_MetadataResponse
	Response isOperationResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

func (*OperationResponse) Descriptor deprecated

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

Deprecated: Use OperationResponse.ProtoReflect.Descriptor instead.

func (*OperationResponse) GetCloseResponse

func (x *OperationResponse) GetCloseResponse() *CloseResponse

func (*OperationResponse) GetInterruptResponse

func (x *OperationResponse) GetInterruptResponse() *InterruptResponse

func (*OperationResponse) GetMetadataResponse

func (x *OperationResponse) GetMetadataResponse() *MetadataResponse

func (*OperationResponse) GetOpenResponse

func (x *OperationResponse) GetOpenResponse() *OpenResponse

func (*OperationResponse) GetOperation

func (x *OperationResponse) GetOperation() Operation

func (*OperationResponse) GetProgressResponse

func (x *OperationResponse) GetProgressResponse() *ProgressResponse

func (*OperationResponse) GetResponse

func (m *OperationResponse) GetResponse() isOperationResponse_Response

func (*OperationResponse) ProtoMessage

func (*OperationResponse) ProtoMessage()

func (*OperationResponse) ProtoReflect

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

func (*OperationResponse) Reset

func (x *OperationResponse) Reset()

func (*OperationResponse) String

func (x *OperationResponse) String() string

type OperationResponse_CloseResponse

type OperationResponse_CloseResponse struct {
	CloseResponse *CloseResponse `protobuf:"bytes,5,opt,name=close_response,json=closeResponse,proto3,oneof"`
}

type OperationResponse_InterruptResponse

type OperationResponse_InterruptResponse struct {
	InterruptResponse *InterruptResponse `protobuf:"bytes,4,opt,name=interrupt_response,json=interruptResponse,proto3,oneof"`
}

type OperationResponse_MetadataResponse

type OperationResponse_MetadataResponse struct {
	MetadataResponse *MetadataResponse `protobuf:"bytes,7,opt,name=metadata_response,json=metadataResponse,proto3,oneof"`
}

type OperationResponse_OpenResponse

type OperationResponse_OpenResponse struct {
	OpenResponse *OpenResponse `protobuf:"bytes,2,opt,name=open_response,json=openResponse,proto3,oneof"`
}

type OperationResponse_ProgressResponse

type OperationResponse_ProgressResponse struct {
	ProgressResponse *ProgressResponse `protobuf:"bytes,6,opt,name=progress_response,json=progressResponse,proto3,oneof"`
}

type ProgressRequest

type ProgressRequest struct {
	Type            ProgressRequest_Type `protobuf:"varint,1,opt,name=type,proto3,enum=grpc_runner_v1.ProgressRequest_Type" json:"type,omitempty"`
	Percentage      float64              `protobuf:"fixed64,2,opt,name=percentage,proto3" json:"percentage,omitempty"`
	Speed           float64              `protobuf:"fixed64,3,opt,name=speed,proto3" json:"speed,omitempty"`
	CurrentDuration *float64             `protobuf:"fixed64,4,opt,name=current_duration,json=currentDuration,proto3,oneof" json:"current_duration,omitempty"`
	Duration        *float64             `protobuf:"fixed64,5,opt,name=duration,proto3,oneof" json:"duration,omitempty"`
	CurrentFilesize *float64             `protobuf:"fixed64,6,opt,name=current_filesize,json=currentFilesize,proto3,oneof" json:"current_filesize,omitempty"`
	Filesize        *float64             `protobuf:"fixed64,7,opt,name=filesize,proto3,oneof" json:"filesize,omitempty"`
	// contains filtered or unexported fields
}

func (*ProgressRequest) Descriptor deprecated

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

Deprecated: Use ProgressRequest.ProtoReflect.Descriptor instead.

func (*ProgressRequest) GetCurrentDuration

func (x *ProgressRequest) GetCurrentDuration() float64

func (*ProgressRequest) GetCurrentFilesize

func (x *ProgressRequest) GetCurrentFilesize() float64

func (*ProgressRequest) GetDuration

func (x *ProgressRequest) GetDuration() float64

func (*ProgressRequest) GetFilesize

func (x *ProgressRequest) GetFilesize() float64

func (*ProgressRequest) GetPercentage

func (x *ProgressRequest) GetPercentage() float64

func (*ProgressRequest) GetSpeed

func (x *ProgressRequest) GetSpeed() float64

func (*ProgressRequest) GetType

func (*ProgressRequest) ProtoMessage

func (*ProgressRequest) ProtoMessage()

func (*ProgressRequest) ProtoReflect

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

func (*ProgressRequest) Reset

func (x *ProgressRequest) Reset()

func (*ProgressRequest) String

func (x *ProgressRequest) String() string

type ProgressRequest_Type

type ProgressRequest_Type int32
const (
	ProgressRequest_DOWNLOAD  ProgressRequest_Type = 0
	ProgressRequest_METADATA  ProgressRequest_Type = 1
	ProgressRequest_TRANSCODE ProgressRequest_Type = 2
	ProgressRequest_UPLOAD    ProgressRequest_Type = 3
)

func (ProgressRequest_Type) Descriptor

func (ProgressRequest_Type) Enum

func (ProgressRequest_Type) EnumDescriptor deprecated

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

Deprecated: Use ProgressRequest_Type.Descriptor instead.

func (ProgressRequest_Type) Number

func (ProgressRequest_Type) String

func (x ProgressRequest_Type) String() string

func (ProgressRequest_Type) Type

type ProgressResponse

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

func (*ProgressResponse) Descriptor deprecated

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

Deprecated: Use ProgressResponse.ProtoReflect.Descriptor instead.

func (*ProgressResponse) ProtoMessage

func (*ProgressResponse) ProtoMessage()

func (*ProgressResponse) ProtoReflect

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

func (*ProgressResponse) Reset

func (x *ProgressResponse) Reset()

func (*ProgressResponse) String

func (x *ProgressResponse) String() string

type RunnerServiceClient

type RunnerServiceClient interface {
	Auth(ctx context.Context, in *AuthRequest, opts ...grpc.CallOption) (*AuthResponse, error)
	Stream(ctx context.Context, in *StreamRequest, opts ...grpc.CallOption) (*StreamResponse, error)
	Operation(ctx context.Context, opts ...grpc.CallOption) (RunnerService_OperationClient, error)
}

RunnerServiceClient is the client API for RunnerService 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.

type RunnerServiceServer

type RunnerServiceServer interface {
	Auth(context.Context, *AuthRequest) (*AuthResponse, error)
	Stream(context.Context, *StreamRequest) (*StreamResponse, error)
	Operation(RunnerService_OperationServer) error
	// contains filtered or unexported methods
}

RunnerServiceServer is the server API for RunnerService service. All implementations must embed UnimplementedRunnerServiceServer for forward compatibility

type RunnerService_OperationClient

type RunnerService_OperationClient interface {
	Send(*OperationRequest) error
	Recv() (*OperationResponse, error)
	grpc.ClientStream
}

type RunnerService_OperationServer

type RunnerService_OperationServer interface {
	Send(*OperationResponse) error
	Recv() (*OperationRequest, error)
	grpc.ServerStream
}

type StreamRequest

type StreamRequest struct {
	Stream  StreamType `protobuf:"varint,1,opt,name=stream,proto3,enum=grpc_runner_v1.StreamType" json:"stream,omitempty"`
	Start   int64      `protobuf:"varint,2,opt,name=start,proto3" json:"start,omitempty"`
	End     int64      `protobuf:"varint,3,opt,name=end,proto3" json:"end,omitempty"`
	Size    int64      `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	Content []byte     `protobuf:"bytes,5,opt,name=content,proto3" json:"content,omitempty"`
	Offset  int64      `protobuf:"varint,6,opt,name=offset,proto3" json:"offset,omitempty"`
	Adler32 uint32     `protobuf:"fixed32,7,opt,name=adler32,proto3" json:"adler32,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamRequest) Descriptor deprecated

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

Deprecated: Use StreamRequest.ProtoReflect.Descriptor instead.

func (*StreamRequest) GetAdler32

func (x *StreamRequest) GetAdler32() uint32

func (*StreamRequest) GetContent

func (x *StreamRequest) GetContent() []byte

func (*StreamRequest) GetEnd

func (x *StreamRequest) GetEnd() int64

func (*StreamRequest) GetOffset

func (x *StreamRequest) GetOffset() int64

func (*StreamRequest) GetSize

func (x *StreamRequest) GetSize() int64

func (*StreamRequest) GetStart

func (x *StreamRequest) GetStart() int64

func (*StreamRequest) GetStream

func (x *StreamRequest) GetStream() StreamType

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 StreamResponse

type StreamResponse struct {
	Error  string     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Stream StreamType `protobuf:"varint,2,opt,name=stream,proto3,enum=grpc_runner_v1.StreamType" json:"stream,omitempty"`
	Start  int64      `protobuf:"varint,3,opt,name=start,proto3" json:"start,omitempty"`
	End    int64      `protobuf:"varint,4,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamResponse) Descriptor deprecated

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

Deprecated: Use StreamResponse.ProtoReflect.Descriptor instead.

func (*StreamResponse) GetEnd

func (x *StreamResponse) GetEnd() int64

func (*StreamResponse) GetError

func (x *StreamResponse) GetError() string

func (*StreamResponse) GetStart

func (x *StreamResponse) GetStart() int64

func (*StreamResponse) GetStream

func (x *StreamResponse) GetStream() StreamType

func (*StreamResponse) ProtoMessage

func (*StreamResponse) ProtoMessage()

func (*StreamResponse) ProtoReflect

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

func (*StreamResponse) Reset

func (x *StreamResponse) Reset()

func (*StreamResponse) String

func (x *StreamResponse) String() string

type StreamType

type StreamType int32
const (
	StreamType_IMAGE StreamType = 0
	StreamType_VIDEO StreamType = 1
)

func (StreamType) Descriptor

func (StreamType) Descriptor() protoreflect.EnumDescriptor

func (StreamType) Enum

func (x StreamType) Enum() *StreamType

func (StreamType) EnumDescriptor deprecated

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

Deprecated: Use StreamType.Descriptor instead.

func (StreamType) Number

func (x StreamType) Number() protoreflect.EnumNumber

func (StreamType) String

func (x StreamType) String() string

func (StreamType) Type

type UnimplementedRunnerServiceServer

type UnimplementedRunnerServiceServer struct {
}

UnimplementedRunnerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedRunnerServiceServer) Auth

func (UnimplementedRunnerServiceServer) Operation

func (UnimplementedRunnerServiceServer) Stream

type UnsafeRunnerServiceServer

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL