pb

package
v0.0.0-...-41b1be1 Latest Latest
Warning

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

 Go to latest Published: Aug 25, 2020 License: GPL-3.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var MessageType_name = map[int32]string{
	0: "Add",
	1: "AsyncAdd",
	2: "Status",
	3: "List",
	4: "Delete",
}

MessageType_name ...

View Source 
var MessageType_value = map[string]int32{
	"Add":      0,
	"AsyncAdd": 1,
	"Status":   2,
	"List":     3,
	"Delete":   4,
}

MessageType_value ...

View Source 
var WorkMode_name = map[int32]string{
	0: "LocalMode",
	1: "RemoteMode",
	2: "DownloadMode",
}

WorkMode_name ...

View Source 
var WorkMode_value = map[string]int32{
	"LocalMode":    0,
	"RemoteMode":   1,
	"DownloadMode": 2,
}

WorkMode_value ...

View Source 
var WorkStatus_name = map[int32]string{
	0: "WorkAbnormal",
	1: "WorkWaiting",
	2: "WorkRunning",
	3: "WorkStopped",
	4: "WorkFinish",
}

WorkStatus_name ...

View Source 
var WorkStatus_value = map[string]int32{
	"WorkAbnormal": 0,
	"WorkWaiting":  1,
	"WorkRunning":  2,
	"WorkStopped":  3,
	"WorkFinish":   4,
}

WorkStatus_value ...

Functions

func RegisterServiceServer 

func RegisterServiceServer(s *grpc.Server, srv ServiceServer)

RegisterServiceServer ...

Types

type MessageType 

type MessageType int32

MessageType ... 

const (
	MessageType_Add      MessageType = 0
	MessageType_AsyncAdd MessageType = 1
	MessageType_Status   MessageType = 2
	MessageType_List     MessageType = 3
	MessageType_Delete   MessageType = 4
)

MessageType_Add ...

func (MessageType) EnumDescriptor 

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

EnumDescriptor ...

func (MessageType) String 

func (x MessageType) String() string

String ...

type NodeReply 

type NodeReply struct {
	Msg                  MessageType `protobuf:"varint,1,opt,name=msg,proto3,enum=pb.MessageType" json:"msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

NodeReply ...

func (*NodeReply) Descriptor 

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

Descriptor ...

func (*NodeReply) GetMsg 

func (m *NodeReply) GetMsg() MessageType

GetMsg ...

func (*NodeReply) ProtoMessage 

func (*NodeReply) ProtoMessage()

ProtoMessage ...

func (*NodeReply) Reset 

func (m *NodeReply) Reset()

Reset ...

func (*NodeReply) String 

func (m *NodeReply) String() string

String ...

func (*NodeReply) XXX_DiscardUnknown 

func (m *NodeReply) XXX_DiscardUnknown()

XXX_DiscardUnknown ...

func (*NodeReply) XXX_Marshal 

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

XXX_Marshal ...

func (*NodeReply) XXX_Merge 

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

XXX_Merge ...

func (*NodeReply) XXX_Size 

func (m *NodeReply) XXX_Size() int

XXX_Size ...

func (*NodeReply) XXX_Unmarshal 

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

XXX_Unmarshal ...

type NodeRequest 

type NodeRequest struct {
	Msg                  MessageType `protobuf:"varint,1,opt,name=msg,proto3,enum=pb.MessageType" json:"msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

NodeRequest ...

func (*NodeRequest) Descriptor 

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

Descriptor ...

func (*NodeRequest) GetMsg 

func (m *NodeRequest) GetMsg() MessageType

GetMsg ...

func (*NodeRequest) ProtoMessage 

func (*NodeRequest) ProtoMessage()

ProtoMessage ...

func (*NodeRequest) Reset 

func (m *NodeRequest) Reset()

Reset ...

func (*NodeRequest) String 

func (m *NodeRequest) String() string

String ...

func (*NodeRequest) XXX_DiscardUnknown 

func (m *NodeRequest) XXX_DiscardUnknown()

XXX_DiscardUnknown ...

func (*NodeRequest) XXX_Marshal 

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

XXX_Marshal ...

func (*NodeRequest) XXX_Merge 

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

XXX_Merge ...

func (*NodeRequest) XXX_Size 

func (m *NodeRequest) XXX_Size() int

XXX_Size ...

func (*NodeRequest) XXX_Unmarshal 

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

XXX_Unmarshal ...

type ServiceClient 

type ServiceClient interface {
	Work(ctx context.Context, in *WorkRequest, opts ...grpc.CallOption) (*WorkReply, error)
	//    rpc AsyncAddWork (WorkRequest) returns (WorkReply) {
	//    }
	//    rpc WorkStatus (WorkRequest) returns (WorkReply) {
	//    }
	Node(ctx context.Context, in *NodeRequest, opts ...grpc.CallOption) (*NodeReply, error)
}

ServiceClient is the client API for Service service.

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

func NewServiceClient 

func NewServiceClient(cc *grpc.ClientConn) ServiceClient

NewServiceClient ...

type ServiceServer 

type ServiceServer interface {
	Work(context.Context, *WorkRequest) (*WorkReply, error)
	//    rpc AsyncAddWork (WorkRequest) returns (WorkReply) {
	//    }
	//    rpc WorkStatus (WorkRequest) returns (WorkReply) {
	//    }
	Node(context.Context, *NodeRequest) (*NodeReply, error)
}

ServiceServer is the server API for Service service.

type Work 

type Work struct {
	Status               WorkStatus `protobuf:"varint,1,opt,name=status,proto3,enum=pb.WorkStatus" json:"status,omitempty"`
	ID                   string     `protobuf:"bytes,2,opt,name=ID,proto3" json:"ID,omitempty"`
	VideoPath            []string   `protobuf:"bytes,3,rep,name=video_path,json=videoPath,proto3" json:"video_path,omitempty"`
	PosterPath           string     `protobuf:"bytes,4,opt,name=poster_path,json=posterPath,proto3" json:"poster_path,omitempty"`
	ThumbPath            string     `protobuf:"bytes,5,opt,name=thumb_path,json=thumbPath,proto3" json:"thumb_path,omitempty"`
	SamplePath           []string   `protobuf:"bytes,6,rep,name=sample_path,json=samplePath,proto3" json:"sample_path,omitempty"`
	VideoInfo            string     `protobuf:"bytes,7,opt,name=video_info,json=videoInfo,proto3" json:"video_info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

Work ...

func (*Work) Descriptor 

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

Descriptor ...

func (*Work) GetID 

func (m *Work) GetID() string

GetID ...

func (*Work) GetPosterPath 

func (m *Work) GetPosterPath() string

GetPosterPath ...

func (*Work) GetSamplePath 

func (m *Work) GetSamplePath() []string

GetSamplePath ...

func (*Work) GetStatus 

func (m *Work) GetStatus() WorkStatus

GetStatus ...

func (*Work) GetThumbPath 

func (m *Work) GetThumbPath() string

GetThumbPath ...

func (*Work) GetVideoInfo 

func (m *Work) GetVideoInfo() string

GetVideoInfo ...

func (*Work) GetVideoPath 

func (m *Work) GetVideoPath() []string

GetVideoPath ...

func (*Work) ProtoMessage 

func (*Work) ProtoMessage()

ProtoMessage ...

func (*Work) Reset 

func (m *Work) Reset()

Reset ...

func (*Work) String 

func (m *Work) String() string

String ...

func (*Work) XXX_DiscardUnknown 

func (m *Work) XXX_DiscardUnknown()

XXX_DiscardUnknown ...

func (*Work) XXX_Marshal 

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

XXX_Marshal ...

func (*Work) XXX_Merge 

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

XXX_Merge ...

func (*Work) XXX_Size 

func (m *Work) XXX_Size() int

XXX_Size ...

func (*Work) XXX_Unmarshal 

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

XXX_Unmarshal ...

type WorkMode 

type WorkMode int32

WorkMode ... 

const (
	WorkMode_LocalMode    WorkMode = 0
	WorkMode_RemoteMode   WorkMode = 1
	WorkMode_DownloadMode WorkMode = 2
)

WorkMode_LocalMode ...

func (WorkMode) EnumDescriptor 

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

EnumDescriptor ...

func (WorkMode) String 

func (x WorkMode) String() string

String ...

type WorkReply 

type WorkReply struct {
	Msg                  MessageType `protobuf:"varint,1,opt,name=msg,proto3,enum=pb.MessageType" json:"msg,omitempty"`
	Total                int32       `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	Works                []*Work     `protobuf:"bytes,3,rep,name=works,proto3" json:"works,omitempty"`
	Error                string      `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

WorkReply ...

func (*WorkReply) Descriptor 

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

Descriptor ...

func (*WorkReply) GetError 

func (m *WorkReply) GetError() string

GetError ...

func (*WorkReply) GetMsg 

func (m *WorkReply) GetMsg() MessageType

GetMsg ...

func (*WorkReply) GetTotal 

func (m *WorkReply) GetTotal() int32

GetTotal ...

func (*WorkReply) GetWorks 

func (m *WorkReply) GetWorks() []*Work

GetWorks ...

func (*WorkReply) ProtoMessage 

func (*WorkReply) ProtoMessage()

ProtoMessage ...

func (*WorkReply) Reset 

func (m *WorkReply) Reset()

Reset ...

func (*WorkReply) String 

func (m *WorkReply) String() string

String ...

func (*WorkReply) XXX_DiscardUnknown 

func (m *WorkReply) XXX_DiscardUnknown()

XXX_DiscardUnknown ...

func (*WorkReply) XXX_Marshal 

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

XXX_Marshal ...

func (*WorkReply) XXX_Merge 

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

XXX_Merge ...

func (*WorkReply) XXX_Size 

func (m *WorkReply) XXX_Size() int

XXX_Size ...

func (*WorkReply) XXX_Unmarshal 

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

XXX_Unmarshal ...

type WorkRequest 

type WorkRequest struct {
	Msg      MessageType `protobuf:"varint,1,opt,name=msg,proto3,enum=pb.MessageType" json:"msg,omitempty"`
	WorkMode WorkMode    `protobuf:"varint,2,opt,name=work_mode,json=workMode,proto3,enum=pb.WorkMode" json:"work_mode,omitempty"`
	//    string ID = 3;
	Work                 *Work    `protobuf:"bytes,4,opt,name=work,proto3" json:"work,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

WorkRequest ...

func (*WorkRequest) Descriptor 

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

Descriptor ...

func (*WorkRequest) GetMsg 

func (m *WorkRequest) GetMsg() MessageType

GetMsg ...

func (*WorkRequest) GetWork 

func (m *WorkRequest) GetWork() *Work

GetWork ...

func (*WorkRequest) GetWorkMode 

func (m *WorkRequest) GetWorkMode() WorkMode

GetWorkMode ...

func (*WorkRequest) ProtoMessage 

func (*WorkRequest) ProtoMessage()

ProtoMessage ...

func (*WorkRequest) Reset 

func (m *WorkRequest) Reset()

Reset ...

func (*WorkRequest) String 

func (m *WorkRequest) String() string

String ...

func (*WorkRequest) XXX_DiscardUnknown 

func (m *WorkRequest) XXX_DiscardUnknown()

XXX_DiscardUnknown ...

func (*WorkRequest) XXX_Marshal 

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

XXX_Marshal ...

func (*WorkRequest) XXX_Merge 

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

XXX_Merge ...

func (*WorkRequest) XXX_Size 

func (m *WorkRequest) XXX_Size() int

XXX_Size ...

func (*WorkRequest) XXX_Unmarshal 

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

XXX_Unmarshal ...

type WorkStatus 

type WorkStatus int32

WorkStatus ... 

const (
	WorkStatus_WorkAbnormal WorkStatus = 0
	WorkStatus_WorkWaiting  WorkStatus = 1
	WorkStatus_WorkRunning  WorkStatus = 2
	WorkStatus_WorkStopped  WorkStatus = 3
	WorkStatus_WorkFinish   WorkStatus = 4
)

WorkStatus_WorkAbnormal ...

func (WorkStatus) EnumDescriptor 

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

EnumDescriptor ...

func (WorkStatus) String 

func (x WorkStatus) String() 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.