Documentation ¶
Overview ¶
Package proto is a generated protocol buffer package.
It is generated from these files:
censor.proto
It has these top-level messages:
ValidateRequest CensorReply CensorReplyDetail
Package proto is a generated protocol buffer package.
It is generated from these files:
manager.proto
It has these top-level messages:
ManagerNodeRequest ManagerCensorRequest ManagerReply ManagerReplyDetail
Package proto is a generated protocol buffer package.
It is generated from these files:
node.proto
It has these top-level messages:
StatusRequest RemoteDownloadRequest NodeReply NodeReplyDetail
Index ¶
- Variables
- func RegisterCensorServiceHandler(s server.Server, hdlr CensorServiceHandler, opts ...server.HandlerOption) error
- func RegisterCensorServiceServer(s *grpc.Server, srv CensorServiceServer)
- func RegisterManagerServiceHandler(s server.Server, hdlr ManagerServiceHandler, opts ...server.HandlerOption) error
- func RegisterManagerServiceServer(s *grpc.Server, srv ManagerServiceServer)
- func RegisterNodeServiceHandler(s server.Server, hdlr NodeServiceHandler, opts ...server.HandlerOption) error
- func RegisterNodeServiceServer(s *grpc.Server, srv NodeServiceServer)
- type CensorReply
- func (*CensorReply) Descriptor() ([]byte, []int)
- func (m *CensorReply) GetCode() int32
- func (m *CensorReply) GetDetail() *CensorReplyDetail
- func (m *CensorReply) GetMessage() string
- func (*CensorReply) ProtoMessage()
- func (m *CensorReply) Reset()
- func (m *CensorReply) String() string
- func (m *CensorReply) XXX_DiscardUnknown()
- func (m *CensorReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CensorReply) XXX_Merge(src proto.Message)
- func (m *CensorReply) XXX_Size() int
- func (m *CensorReply) XXX_Unmarshal(b []byte) error
- type CensorReplyDetail
- func (*CensorReplyDetail) Descriptor() ([]byte, []int)
- func (m *CensorReplyDetail) GetID() string
- func (m *CensorReplyDetail) GetJson() string
- func (*CensorReplyDetail) ProtoMessage()
- func (m *CensorReplyDetail) Reset()
- func (m *CensorReplyDetail) String() string
- func (m *CensorReplyDetail) XXX_DiscardUnknown()
- func (m *CensorReplyDetail) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CensorReplyDetail) XXX_Merge(src proto.Message)
- func (m *CensorReplyDetail) XXX_Size() int
- func (m *CensorReplyDetail) XXX_Unmarshal(b []byte) error
- type CensorService
- type CensorServiceClient
- type CensorServiceHandler
- type CensorServiceServer
- type CensorValidateType
- type ManagerCensorRequest
- func (*ManagerCensorRequest) Descriptor() ([]byte, []int)
- func (m *ManagerCensorRequest) GetDetail() string
- func (m *ManagerCensorRequest) GetID() string
- func (*ManagerCensorRequest) ProtoMessage()
- func (m *ManagerCensorRequest) Reset()
- func (m *ManagerCensorRequest) String() string
- func (m *ManagerCensorRequest) XXX_DiscardUnknown()
- func (m *ManagerCensorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ManagerCensorRequest) XXX_Merge(src proto.Message)
- func (m *ManagerCensorRequest) XXX_Size() int
- func (m *ManagerCensorRequest) XXX_Unmarshal(b []byte) error
- type ManagerNodeRequest
- func (*ManagerNodeRequest) Descriptor() ([]byte, []int)
- func (m *ManagerNodeRequest) GetDetail() string
- func (m *ManagerNodeRequest) GetID() string
- func (*ManagerNodeRequest) ProtoMessage()
- func (m *ManagerNodeRequest) Reset()
- func (m *ManagerNodeRequest) String() string
- func (m *ManagerNodeRequest) XXX_DiscardUnknown()
- func (m *ManagerNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ManagerNodeRequest) XXX_Merge(src proto.Message)
- func (m *ManagerNodeRequest) XXX_Size() int
- func (m *ManagerNodeRequest) XXX_Unmarshal(b []byte) error
- type ManagerReply
- func (*ManagerReply) Descriptor() ([]byte, []int)
- func (m *ManagerReply) GetCode() int32
- func (m *ManagerReply) GetDetail() *ManagerReplyDetail
- func (m *ManagerReply) GetMessage() string
- func (*ManagerReply) ProtoMessage()
- func (m *ManagerReply) Reset()
- func (m *ManagerReply) String() string
- func (m *ManagerReply) XXX_DiscardUnknown()
- func (m *ManagerReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ManagerReply) XXX_Merge(src proto.Message)
- func (m *ManagerReply) XXX_Size() int
- func (m *ManagerReply) XXX_Unmarshal(b []byte) error
- type ManagerReplyDetail
- func (*ManagerReplyDetail) Descriptor() ([]byte, []int)
- func (m *ManagerReplyDetail) GetID() string
- func (m *ManagerReplyDetail) GetJson() string
- func (*ManagerReplyDetail) ProtoMessage()
- func (m *ManagerReplyDetail) Reset()
- func (m *ManagerReplyDetail) String() string
- func (m *ManagerReplyDetail) XXX_DiscardUnknown()
- func (m *ManagerReplyDetail) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ManagerReplyDetail) XXX_Merge(src proto.Message)
- func (m *ManagerReplyDetail) XXX_Size() int
- func (m *ManagerReplyDetail) XXX_Unmarshal(b []byte) error
- type ManagerService
- type ManagerServiceClient
- type ManagerServiceHandler
- type ManagerServiceServer
- type NodeBackType
- type NodeRemoteType
- type NodeReply
- func (*NodeReply) Descriptor() ([]byte, []int)
- func (m *NodeReply) GetCode() int32
- func (m *NodeReply) GetDetail() *NodeReplyDetail
- func (m *NodeReply) GetMessage() string
- func (*NodeReply) ProtoMessage()
- func (m *NodeReply) Reset()
- func (m *NodeReply) String() string
- func (m *NodeReply) XXX_DiscardUnknown()
- func (m *NodeReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NodeReply) XXX_Merge(src proto.Message)
- func (m *NodeReply) XXX_Size() int
- func (m *NodeReply) XXX_Unmarshal(b []byte) error
- type NodeReplyDetail
- func (*NodeReplyDetail) Descriptor() ([]byte, []int)
- func (m *NodeReplyDetail) GetID() string
- func (m *NodeReplyDetail) GetJson() string
- func (*NodeReplyDetail) ProtoMessage()
- func (m *NodeReplyDetail) Reset()
- func (m *NodeReplyDetail) String() string
- func (m *NodeReplyDetail) XXX_DiscardUnknown()
- func (m *NodeReplyDetail) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NodeReplyDetail) XXX_Merge(src proto.Message)
- func (m *NodeReplyDetail) XXX_Size() int
- func (m *NodeReplyDetail) XXX_Unmarshal(b []byte) error
- type NodeService
- type NodeServiceClient
- type NodeServiceHandler
- type NodeServiceServer
- type RemoteDownloadRequest
- func (*RemoteDownloadRequest) Descriptor() ([]byte, []int)
- func (m *RemoteDownloadRequest) GetID() string
- func (m *RemoteDownloadRequest) GetKeyURL() string
- func (m *RemoteDownloadRequest) GetObjectKey() string
- func (*RemoteDownloadRequest) ProtoMessage()
- func (m *RemoteDownloadRequest) Reset()
- func (m *RemoteDownloadRequest) String() string
- func (m *RemoteDownloadRequest) XXX_DiscardUnknown()
- func (m *RemoteDownloadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RemoteDownloadRequest) XXX_Merge(src proto.Message)
- func (m *RemoteDownloadRequest) XXX_Size() int
- func (m *RemoteDownloadRequest) XXX_Unmarshal(b []byte) error
- type StatusRequest
- func (*StatusRequest) Descriptor() ([]byte, []int)
- func (m *StatusRequest) GetId() string
- func (*StatusRequest) ProtoMessage()
- func (m *StatusRequest) Reset()
- func (m *StatusRequest) String() string
- func (m *StatusRequest) XXX_DiscardUnknown()
- func (m *StatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StatusRequest) XXX_Merge(src proto.Message)
- func (m *StatusRequest) XXX_Size() int
- func (m *StatusRequest) XXX_Unmarshal(b []byte) error
- type ValidateRequest
- func (*ValidateRequest) Descriptor() ([]byte, []int)
- func (m *ValidateRequest) GetID() string
- func (m *ValidateRequest) GetObjectKey() string
- func (m *ValidateRequest) GetValidateType() CensorValidateType
- func (*ValidateRequest) ProtoMessage()
- func (m *ValidateRequest) Reset()
- func (m *ValidateRequest) String() string
- func (m *ValidateRequest) XXX_DiscardUnknown()
- func (m *ValidateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ValidateRequest) XXX_Merge(src proto.Message)
- func (m *ValidateRequest) XXX_Size() int
- func (m *ValidateRequest) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var CensorValidateType_name = map[int32]string{
0: "JPG",
1: "Frame",
2: "Video",
}
CensorValidateType_name ...
var CensorValidateType_value = map[string]int32{
"JPG": 0,
"Frame": 1,
"Video": 2,
}
CensorValidateType_value ...
var NodeBackType_name = map[int32]string{
0: "HTTP",
1: "GRPC",
}
var NodeBackType_value = map[string]int32{
"HTTP": 0,
"GRPC": 1,
}
var NodeRemoteType_name = map[int32]string{
0: "Basic",
1: "Retry",
2: "Force",
}
var NodeRemoteType_value = map[string]int32{
"Basic": 0,
"Retry": 1,
"Force": 2,
}
Functions ¶
func RegisterCensorServiceHandler ¶
func RegisterCensorServiceHandler(s server.Server, hdlr CensorServiceHandler, opts ...server.HandlerOption) error
RegisterCensorServiceHandler ...
func RegisterCensorServiceServer ¶
func RegisterCensorServiceServer(s *grpc.Server, srv CensorServiceServer)
RegisterCensorServiceServer ...
func RegisterManagerServiceHandler ¶
func RegisterManagerServiceHandler(s server.Server, hdlr ManagerServiceHandler, opts ...server.HandlerOption) error
func RegisterManagerServiceServer ¶
func RegisterManagerServiceServer(s *grpc.Server, srv ManagerServiceServer)
func RegisterNodeServiceHandler ¶
func RegisterNodeServiceHandler(s server.Server, hdlr NodeServiceHandler, opts ...server.HandlerOption) error
func RegisterNodeServiceServer ¶
func RegisterNodeServiceServer(s *grpc.Server, srv NodeServiceServer)
Types ¶
type CensorReply ¶
type CensorReply struct { Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` Detail *CensorReplyDetail `protobuf:"bytes,3,opt,name=detail,proto3" json:"detail,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
CensorReply ...
func (*CensorReply) XXX_DiscardUnknown ¶
func (m *CensorReply) XXX_DiscardUnknown()
XXX_DiscardUnknown ...
func (*CensorReply) XXX_Marshal ¶
func (m *CensorReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
XXX_Marshal ...
func (*CensorReply) XXX_Unmarshal ¶
func (m *CensorReply) XXX_Unmarshal(b []byte) error
XXX_Unmarshal ...
type CensorReplyDetail ¶
type CensorReplyDetail struct { ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"` Json string `protobuf:"bytes,2,opt,name=json,proto3" json:"json,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
CensorReplyDetail ...
func (*CensorReplyDetail) Descriptor ¶
func (*CensorReplyDetail) Descriptor() ([]byte, []int)
Descriptor ...
func (*CensorReplyDetail) XXX_DiscardUnknown ¶
func (m *CensorReplyDetail) XXX_DiscardUnknown()
XXX_DiscardUnknown ...
func (*CensorReplyDetail) XXX_Marshal ¶
func (m *CensorReplyDetail) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
XXX_Marshal ...
func (*CensorReplyDetail) XXX_Merge ¶
func (m *CensorReplyDetail) XXX_Merge(src proto.Message)
XXX_Merge ...
func (*CensorReplyDetail) XXX_Unmarshal ¶
func (m *CensorReplyDetail) XXX_Unmarshal(b []byte) error
XXX_Unmarshal ...
type CensorService ¶
type CensorService interface {
Validate(ctx context.Context, in *ValidateRequest, opts ...client.CallOption) (*CensorReply, error)
}
CensorService ...
func NewCensorService ¶
func NewCensorService(name string, c client.Client) CensorService
NewCensorService ...
type CensorServiceClient ¶
type CensorServiceClient interface {
Validate(ctx context.Context, in *ValidateRequest, opts ...grpc.CallOption) (*CensorReply, error)
}
CensorServiceClient is the client API for CensorService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewCensorServiceClient ¶
func NewCensorServiceClient(cc *grpc.ClientConn) CensorServiceClient
NewCensorServiceClient ...
type CensorServiceHandler ¶
type CensorServiceHandler interface {
Validate(context.Context, *ValidateRequest, *CensorReply) error
}
CensorServiceHandler ...
type CensorServiceServer ¶
type CensorServiceServer interface {
Validate(context.Context, *ValidateRequest) (*CensorReply, error)
}
CensorServiceServer is the server API for CensorService service.
type CensorValidateType ¶
type CensorValidateType int32
CensorValidateType ...
const ( CensorValidateType_JPG CensorValidateType = 0 CensorValidateType_Frame CensorValidateType = 1 CensorValidateType_Video CensorValidateType = 2 )
CensorValidateType_JPG ...
func (CensorValidateType) EnumDescriptor ¶
func (CensorValidateType) EnumDescriptor() ([]byte, []int)
EnumDescriptor ...
type ManagerCensorRequest ¶
type ManagerCensorRequest struct { ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"` Detail string `protobuf:"bytes,2,opt,name=detail,proto3" json:"detail,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ManagerCensorRequest) Descriptor ¶
func (*ManagerCensorRequest) Descriptor() ([]byte, []int)
func (*ManagerCensorRequest) GetDetail ¶
func (m *ManagerCensorRequest) GetDetail() string
func (*ManagerCensorRequest) GetID ¶
func (m *ManagerCensorRequest) GetID() string
func (*ManagerCensorRequest) ProtoMessage ¶
func (*ManagerCensorRequest) ProtoMessage()
func (*ManagerCensorRequest) Reset ¶
func (m *ManagerCensorRequest) Reset()
func (*ManagerCensorRequest) String ¶
func (m *ManagerCensorRequest) String() string
func (*ManagerCensorRequest) XXX_DiscardUnknown ¶
func (m *ManagerCensorRequest) XXX_DiscardUnknown()
func (*ManagerCensorRequest) XXX_Marshal ¶
func (m *ManagerCensorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ManagerCensorRequest) XXX_Merge ¶
func (m *ManagerCensorRequest) XXX_Merge(src proto.Message)
func (*ManagerCensorRequest) XXX_Size ¶
func (m *ManagerCensorRequest) XXX_Size() int
func (*ManagerCensorRequest) XXX_Unmarshal ¶
func (m *ManagerCensorRequest) XXX_Unmarshal(b []byte) error
type ManagerNodeRequest ¶
type ManagerNodeRequest struct { ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"` Detail string `protobuf:"bytes,2,opt,name=detail,proto3" json:"detail,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ManagerNodeRequest) Descriptor ¶
func (*ManagerNodeRequest) Descriptor() ([]byte, []int)
func (*ManagerNodeRequest) GetDetail ¶
func (m *ManagerNodeRequest) GetDetail() string
func (*ManagerNodeRequest) GetID ¶
func (m *ManagerNodeRequest) GetID() string
func (*ManagerNodeRequest) ProtoMessage ¶
func (*ManagerNodeRequest) ProtoMessage()
func (*ManagerNodeRequest) Reset ¶
func (m *ManagerNodeRequest) Reset()
func (*ManagerNodeRequest) String ¶
func (m *ManagerNodeRequest) String() string
func (*ManagerNodeRequest) XXX_DiscardUnknown ¶
func (m *ManagerNodeRequest) XXX_DiscardUnknown()
func (*ManagerNodeRequest) XXX_Marshal ¶
func (m *ManagerNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ManagerNodeRequest) XXX_Merge ¶
func (m *ManagerNodeRequest) XXX_Merge(src proto.Message)
func (*ManagerNodeRequest) XXX_Size ¶
func (m *ManagerNodeRequest) XXX_Size() int
func (*ManagerNodeRequest) XXX_Unmarshal ¶
func (m *ManagerNodeRequest) XXX_Unmarshal(b []byte) error
type ManagerReply ¶
type ManagerReply struct { Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` Detail *ManagerReplyDetail `protobuf:"bytes,3,opt,name=detail,proto3" json:"detail,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ManagerReply) Descriptor ¶
func (*ManagerReply) Descriptor() ([]byte, []int)
func (*ManagerReply) GetCode ¶
func (m *ManagerReply) GetCode() int32
func (*ManagerReply) GetDetail ¶
func (m *ManagerReply) GetDetail() *ManagerReplyDetail
func (*ManagerReply) GetMessage ¶
func (m *ManagerReply) GetMessage() string
func (*ManagerReply) ProtoMessage ¶
func (*ManagerReply) ProtoMessage()
func (*ManagerReply) Reset ¶
func (m *ManagerReply) Reset()
func (*ManagerReply) String ¶
func (m *ManagerReply) String() string
func (*ManagerReply) XXX_DiscardUnknown ¶
func (m *ManagerReply) XXX_DiscardUnknown()
func (*ManagerReply) XXX_Marshal ¶
func (m *ManagerReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ManagerReply) XXX_Merge ¶
func (m *ManagerReply) XXX_Merge(src proto.Message)
func (*ManagerReply) XXX_Size ¶
func (m *ManagerReply) XXX_Size() int
func (*ManagerReply) XXX_Unmarshal ¶
func (m *ManagerReply) XXX_Unmarshal(b []byte) error
type ManagerReplyDetail ¶
type ManagerReplyDetail struct { ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"` Json string `protobuf:"bytes,2,opt,name=json,proto3" json:"json,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ManagerReplyDetail) Descriptor ¶
func (*ManagerReplyDetail) Descriptor() ([]byte, []int)
func (*ManagerReplyDetail) GetID ¶
func (m *ManagerReplyDetail) GetID() string
func (*ManagerReplyDetail) GetJson ¶
func (m *ManagerReplyDetail) GetJson() string
func (*ManagerReplyDetail) ProtoMessage ¶
func (*ManagerReplyDetail) ProtoMessage()
func (*ManagerReplyDetail) Reset ¶
func (m *ManagerReplyDetail) Reset()
func (*ManagerReplyDetail) String ¶
func (m *ManagerReplyDetail) String() string
func (*ManagerReplyDetail) XXX_DiscardUnknown ¶
func (m *ManagerReplyDetail) XXX_DiscardUnknown()
func (*ManagerReplyDetail) XXX_Marshal ¶
func (m *ManagerReplyDetail) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ManagerReplyDetail) XXX_Merge ¶
func (m *ManagerReplyDetail) XXX_Merge(src proto.Message)
func (*ManagerReplyDetail) XXX_Size ¶
func (m *ManagerReplyDetail) XXX_Size() int
func (*ManagerReplyDetail) XXX_Unmarshal ¶
func (m *ManagerReplyDetail) XXX_Unmarshal(b []byte) error
type ManagerService ¶
type ManagerService interface { NodeBack(ctx context.Context, in *ManagerNodeRequest, opts ...client.CallOption) (*ManagerReply, error) CensorBack(ctx context.Context, in *ManagerCensorRequest, opts ...client.CallOption) (*ManagerReply, error) }
func NewManagerService ¶
func NewManagerService(name string, c client.Client) ManagerService
type ManagerServiceClient ¶
type ManagerServiceClient interface { NodeBack(ctx context.Context, in *ManagerNodeRequest, opts ...grpc.CallOption) (*ManagerReply, error) CensorBack(ctx context.Context, in *ManagerCensorRequest, opts ...grpc.CallOption) (*ManagerReply, error) }
ManagerServiceClient is the client API for ManagerService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewManagerServiceClient ¶
func NewManagerServiceClient(cc *grpc.ClientConn) ManagerServiceClient
type ManagerServiceHandler ¶
type ManagerServiceHandler interface { NodeBack(context.Context, *ManagerNodeRequest, *ManagerReply) error CensorBack(context.Context, *ManagerCensorRequest, *ManagerReply) error }
type ManagerServiceServer ¶
type ManagerServiceServer interface { NodeBack(context.Context, *ManagerNodeRequest) (*ManagerReply, error) CensorBack(context.Context, *ManagerCensorRequest) (*ManagerReply, error) }
ManagerServiceServer is the server API for ManagerService service.
type NodeBackType ¶
type NodeBackType int32
const ( NodeBackType_HTTP NodeBackType = 0 NodeBackType_GRPC NodeBackType = 1 )
func (NodeBackType) EnumDescriptor ¶
func (NodeBackType) EnumDescriptor() ([]byte, []int)
func (NodeBackType) String ¶
func (x NodeBackType) String() string
type NodeRemoteType ¶
type NodeRemoteType int32
const ( NodeRemoteType_Basic NodeRemoteType = 0 NodeRemoteType_Retry NodeRemoteType = 1 NodeRemoteType_Force NodeRemoteType = 2 )
func (NodeRemoteType) EnumDescriptor ¶
func (NodeRemoteType) EnumDescriptor() ([]byte, []int)
func (NodeRemoteType) String ¶
func (x NodeRemoteType) String() string
type NodeReply ¶
type NodeReply struct { Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` Detail *NodeReplyDetail `protobuf:"bytes,3,opt,name=detail,proto3" json:"detail,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NodeReply) Descriptor ¶
func (*NodeReply) GetDetail ¶
func (m *NodeReply) GetDetail() *NodeReplyDetail
func (*NodeReply) GetMessage ¶
func (*NodeReply) ProtoMessage ¶
func (*NodeReply) ProtoMessage()
func (*NodeReply) XXX_DiscardUnknown ¶
func (m *NodeReply) XXX_DiscardUnknown()
func (*NodeReply) XXX_Marshal ¶
func (*NodeReply) XXX_Unmarshal ¶
type NodeReplyDetail ¶
type NodeReplyDetail struct { ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"` Json string `protobuf:"bytes,2,opt,name=json,proto3" json:"json,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NodeReplyDetail) Descriptor ¶
func (*NodeReplyDetail) Descriptor() ([]byte, []int)
func (*NodeReplyDetail) GetID ¶
func (m *NodeReplyDetail) GetID() string
func (*NodeReplyDetail) GetJson ¶
func (m *NodeReplyDetail) GetJson() string
func (*NodeReplyDetail) ProtoMessage ¶
func (*NodeReplyDetail) ProtoMessage()
func (*NodeReplyDetail) Reset ¶
func (m *NodeReplyDetail) Reset()
func (*NodeReplyDetail) String ¶
func (m *NodeReplyDetail) String() string
func (*NodeReplyDetail) XXX_DiscardUnknown ¶
func (m *NodeReplyDetail) XXX_DiscardUnknown()
func (*NodeReplyDetail) XXX_Marshal ¶
func (m *NodeReplyDetail) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NodeReplyDetail) XXX_Merge ¶
func (m *NodeReplyDetail) XXX_Merge(src proto.Message)
func (*NodeReplyDetail) XXX_Size ¶
func (m *NodeReplyDetail) XXX_Size() int
func (*NodeReplyDetail) XXX_Unmarshal ¶
func (m *NodeReplyDetail) XXX_Unmarshal(b []byte) error
type NodeService ¶
type NodeService interface { RemoteDownload(ctx context.Context, in *RemoteDownloadRequest, opts ...client.CallOption) (*NodeReply, error) Status(ctx context.Context, in *StatusRequest, opts ...client.CallOption) (*NodeReply, error) }
func NewNodeService ¶
func NewNodeService(name string, c client.Client) NodeService
type NodeServiceClient ¶
type NodeServiceClient interface { RemoteDownload(ctx context.Context, in *RemoteDownloadRequest, opts ...grpc.CallOption) (*NodeReply, error) Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*NodeReply, error) }
NodeServiceClient is the client API for NodeService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewNodeServiceClient ¶
func NewNodeServiceClient(cc *grpc.ClientConn) NodeServiceClient
type NodeServiceHandler ¶
type NodeServiceHandler interface { RemoteDownload(context.Context, *RemoteDownloadRequest, *NodeReply) error Status(context.Context, *StatusRequest, *NodeReply) error }
type NodeServiceServer ¶
type NodeServiceServer interface { RemoteDownload(context.Context, *RemoteDownloadRequest) (*NodeReply, error) Status(context.Context, *StatusRequest) (*NodeReply, error) }
NodeServiceServer is the server API for NodeService service.
type RemoteDownloadRequest ¶
type RemoteDownloadRequest struct { ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"` ObjectKey string `protobuf:"bytes,2,opt,name=objectKey,proto3" json:"objectKey,omitempty"` KeyURL string `protobuf:"bytes,3,opt,name=keyURL,proto3" json:"keyURL,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RemoteDownloadRequest) Descriptor ¶
func (*RemoteDownloadRequest) Descriptor() ([]byte, []int)
func (*RemoteDownloadRequest) GetID ¶
func (m *RemoteDownloadRequest) GetID() string
func (*RemoteDownloadRequest) GetKeyURL ¶
func (m *RemoteDownloadRequest) GetKeyURL() string
func (*RemoteDownloadRequest) GetObjectKey ¶
func (m *RemoteDownloadRequest) GetObjectKey() string
func (*RemoteDownloadRequest) ProtoMessage ¶
func (*RemoteDownloadRequest) ProtoMessage()
func (*RemoteDownloadRequest) Reset ¶
func (m *RemoteDownloadRequest) Reset()
func (*RemoteDownloadRequest) String ¶
func (m *RemoteDownloadRequest) String() string
func (*RemoteDownloadRequest) XXX_DiscardUnknown ¶
func (m *RemoteDownloadRequest) XXX_DiscardUnknown()
func (*RemoteDownloadRequest) XXX_Marshal ¶
func (m *RemoteDownloadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RemoteDownloadRequest) XXX_Merge ¶
func (m *RemoteDownloadRequest) XXX_Merge(src proto.Message)
func (*RemoteDownloadRequest) XXX_Size ¶
func (m *RemoteDownloadRequest) XXX_Size() int
func (*RemoteDownloadRequest) XXX_Unmarshal ¶
func (m *RemoteDownloadRequest) XXX_Unmarshal(b []byte) error
type StatusRequest ¶
type StatusRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*StatusRequest) Descriptor ¶
func (*StatusRequest) Descriptor() ([]byte, []int)
func (*StatusRequest) GetId ¶
func (m *StatusRequest) GetId() string
func (*StatusRequest) ProtoMessage ¶
func (*StatusRequest) ProtoMessage()
func (*StatusRequest) Reset ¶
func (m *StatusRequest) Reset()
func (*StatusRequest) String ¶
func (m *StatusRequest) String() string
func (*StatusRequest) XXX_DiscardUnknown ¶
func (m *StatusRequest) XXX_DiscardUnknown()
func (*StatusRequest) XXX_Marshal ¶
func (m *StatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StatusRequest) XXX_Merge ¶
func (m *StatusRequest) XXX_Merge(src proto.Message)
func (*StatusRequest) XXX_Size ¶
func (m *StatusRequest) XXX_Size() int
func (*StatusRequest) XXX_Unmarshal ¶
func (m *StatusRequest) XXX_Unmarshal(b []byte) error
type ValidateRequest ¶
type ValidateRequest struct { ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"` ObjectKey string `protobuf:"bytes,2,opt,name=objectKey,proto3" json:"objectKey,omitempty"` ValidateType CensorValidateType `protobuf:"varint,3,opt,name=validateType,proto3,enum=proto.CensorValidateType" json:"validateType,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ValidateRequest ...
func (*ValidateRequest) Descriptor ¶
func (*ValidateRequest) Descriptor() ([]byte, []int)
Descriptor ...
func (*ValidateRequest) GetObjectKey ¶
func (m *ValidateRequest) GetObjectKey() string
GetObjectKey ...
func (*ValidateRequest) GetValidateType ¶
func (m *ValidateRequest) GetValidateType() CensorValidateType
GetValidateType ...
func (*ValidateRequest) XXX_DiscardUnknown ¶
func (m *ValidateRequest) XXX_DiscardUnknown()
XXX_DiscardUnknown ...
func (*ValidateRequest) XXX_Marshal ¶
func (m *ValidateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
XXX_Marshal ...
func (*ValidateRequest) XXX_Merge ¶
func (m *ValidateRequest) XXX_Merge(src proto.Message)
XXX_Merge ...
func (*ValidateRequest) XXX_Unmarshal ¶
func (m *ValidateRequest) XXX_Unmarshal(b []byte) error
XXX_Unmarshal ...