Documentation ¶
Index ¶
- func RegisterResultServiceServer(s *grpc.Server, srv ResultServiceServer)
- func RegisterTaskServiceServer(s *grpc.Server, srv TaskServiceServer)
- type AddWhiteRequest
- func (*AddWhiteRequest) Descriptor() ([]byte, []int)
- func (m *AddWhiteRequest) GetList() []string
- func (m *AddWhiteRequest) GetWebsiteID() string
- func (*AddWhiteRequest) ProtoMessage()
- func (m *AddWhiteRequest) Reset()
- func (m *AddWhiteRequest) String() string
- func (m *AddWhiteRequest) XXX_DiscardUnknown()
- func (m *AddWhiteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AddWhiteRequest) XXX_Merge(src proto.Message)
- func (m *AddWhiteRequest) XXX_Size() int
- func (m *AddWhiteRequest) XXX_Unmarshal(b []byte) error
- type CreateTaskRequest
- func (*CreateTaskRequest) Descriptor() ([]byte, []int)
- func (m *CreateTaskRequest) GetNodes() string
- func (m *CreateTaskRequest) GetTask() *Task
- func (m *CreateTaskRequest) GetWebsites() []*Website
- func (*CreateTaskRequest) ProtoMessage()
- func (m *CreateTaskRequest) Reset()
- func (m *CreateTaskRequest) String() string
- func (m *CreateTaskRequest) XXX_DiscardUnknown()
- func (m *CreateTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateTaskRequest) XXX_Merge(src proto.Message)
- func (m *CreateTaskRequest) XXX_Size() int
- func (m *CreateTaskRequest) XXX_Unmarshal(b []byte) error
- type File
- func (*File) Descriptor() ([]byte, []int)
- func (m *File) GetContent() []byte
- func (m *File) GetFileName() string
- func (*File) ProtoMessage()
- func (m *File) Reset()
- func (m *File) String() string
- func (m *File) XXX_DiscardUnknown()
- func (m *File) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *File) XXX_Merge(src proto.Message)
- func (m *File) XXX_Size() int
- func (m *File) XXX_Unmarshal(b []byte) error
- type FileRequest
- func (*FileRequest) Descriptor() ([]byte, []int)
- func (m *FileRequest) GetFileList() []*File
- func (m *FileRequest) GetSiteID() string
- func (*FileRequest) ProtoMessage()
- func (m *FileRequest) Reset()
- func (m *FileRequest) String() string
- func (m *FileRequest) XXX_DiscardUnknown()
- func (m *FileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FileRequest) XXX_Merge(src proto.Message)
- func (m *FileRequest) XXX_Size() int
- func (m *FileRequest) XXX_Unmarshal(b []byte) error
- type FileResponse
- func (*FileResponse) Descriptor() ([]byte, []int)
- func (m *FileResponse) GetMsg() string
- func (m *FileResponse) GetResult() int32
- func (*FileResponse) ProtoMessage()
- func (m *FileResponse) Reset()
- func (m *FileResponse) String() string
- func (m *FileResponse) XXX_DiscardUnknown()
- func (m *FileResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FileResponse) XXX_Merge(src proto.Message)
- func (m *FileResponse) XXX_Size() int
- func (m *FileResponse) XXX_Unmarshal(b []byte) error
- type GeneralResponse
- func (*GeneralResponse) Descriptor() ([]byte, []int)
- func (m *GeneralResponse) GetMsg() string
- func (m *GeneralResponse) GetResult() int32
- func (*GeneralResponse) ProtoMessage()
- func (m *GeneralResponse) Reset()
- func (m *GeneralResponse) String() string
- func (m *GeneralResponse) XXX_DiscardUnknown()
- func (m *GeneralResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GeneralResponse) XXX_Merge(src proto.Message)
- func (m *GeneralResponse) XXX_Size() int
- func (m *GeneralResponse) XXX_Unmarshal(b []byte) error
- type MonitorResult
- func (*MonitorResult) Descriptor() ([]byte, []int)
- func (m *MonitorResult) GetClientName() string
- func (m *MonitorResult) GetCreateTime() int64
- func (m *MonitorResult) GetDnsTime() int32
- func (m *MonitorResult) GetIpAddr() string
- func (m *MonitorResult) GetLoadTime() int32
- func (m *MonitorResult) GetPort() int32
- func (m *MonitorResult) GetResources() string
- func (m *MonitorResult) GetRespUrl() string
- func (m *MonitorResult) GetResponseTime() int32
- func (m *MonitorResult) GetResult() int32
- func (m *MonitorResult) GetSiteID() string
- func (m *MonitorResult) GetStatusCode() int32
- func (m *MonitorResult) GetTaskID() string
- func (*MonitorResult) ProtoMessage()
- func (m *MonitorResult) Reset()
- func (m *MonitorResult) String() string
- func (m *MonitorResult) XXX_DiscardUnknown()
- func (m *MonitorResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MonitorResult) XXX_Merge(src proto.Message)
- func (m *MonitorResult) XXX_Size() int
- func (m *MonitorResult) XXX_Unmarshal(b []byte) error
- type MonitorResultRequest
- func (*MonitorResultRequest) Descriptor() ([]byte, []int)
- func (m *MonitorResultRequest) GetNodeName() string
- func (m *MonitorResultRequest) GetResult() []*MonitorResult
- func (*MonitorResultRequest) ProtoMessage()
- func (m *MonitorResultRequest) Reset()
- func (m *MonitorResultRequest) String() string
- func (m *MonitorResultRequest) XXX_DiscardUnknown()
- func (m *MonitorResultRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MonitorResultRequest) XXX_Merge(src proto.Message)
- func (m *MonitorResultRequest) XXX_Size() int
- func (m *MonitorResultRequest) XXX_Unmarshal(b []byte) error
- type MonitorResultResponse
- func (*MonitorResultResponse) Descriptor() ([]byte, []int)
- func (m *MonitorResultResponse) GetMsg() string
- func (m *MonitorResultResponse) GetResult() int32
- func (*MonitorResultResponse) ProtoMessage()
- func (m *MonitorResultResponse) Reset()
- func (m *MonitorResultResponse) String() string
- func (m *MonitorResultResponse) XXX_DiscardUnknown()
- func (m *MonitorResultResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MonitorResultResponse) XXX_Merge(src proto.Message)
- func (m *MonitorResultResponse) XXX_Size() int
- func (m *MonitorResultResponse) XXX_Unmarshal(b []byte) error
- type ResultService
- type ResultServiceClient
- type ResultServiceServer
- type ResultService_ServeFileClient
- type ResultService_ServeFileServer
- type Task
- func (*Task) Descriptor() ([]byte, []int)
- func (m *Task) GetConfig() int32
- func (m *Task) GetEndTime() string
- func (m *Task) GetInterv() int32
- func (m *Task) GetStartTime() string
- func (m *Task) GetTaskid() string
- func (*Task) ProtoMessage()
- func (m *Task) Reset()
- func (m *Task) String() string
- func (m *Task) XXX_DiscardUnknown()
- func (m *Task) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Task) XXX_Merge(src proto.Message)
- func (m *Task) XXX_Size() int
- func (m *Task) XXX_Unmarshal(b []byte) error
- type TaskService
- type TaskServiceClient
- type TaskServiceServer
- type UnimplementedResultServiceServer
- type UnimplementedTaskServiceServer
- type Website
- func (*Website) Descriptor() ([]byte, []int)
- func (m *Website) GetConfig() int32
- func (m *Website) GetIp() string
- func (m *Website) GetUrl() string
- func (m *Website) GetWebsiteID() string
- func (*Website) ProtoMessage()
- func (m *Website) Reset()
- func (m *Website) String() string
- func (m *Website) XXX_DiscardUnknown()
- func (m *Website) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Website) XXX_Merge(src proto.Message)
- func (m *Website) XXX_Size() int
- func (m *Website) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterResultServiceServer ¶
func RegisterResultServiceServer(s *grpc.Server, srv ResultServiceServer)
func RegisterTaskServiceServer ¶
func RegisterTaskServiceServer(s *grpc.Server, srv TaskServiceServer)
Types ¶
type AddWhiteRequest ¶
type AddWhiteRequest struct { WebsiteID string `protobuf:"bytes,1,opt,name=WebsiteID,proto3" json:"WebsiteID,omitempty"` List []string `protobuf:"bytes,2,rep,name=List,proto3" json:"List,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AddWhiteRequest) Descriptor ¶
func (*AddWhiteRequest) Descriptor() ([]byte, []int)
func (*AddWhiteRequest) GetList ¶
func (m *AddWhiteRequest) GetList() []string
func (*AddWhiteRequest) GetWebsiteID ¶
func (m *AddWhiteRequest) GetWebsiteID() string
func (*AddWhiteRequest) ProtoMessage ¶
func (*AddWhiteRequest) ProtoMessage()
func (*AddWhiteRequest) Reset ¶
func (m *AddWhiteRequest) Reset()
func (*AddWhiteRequest) String ¶
func (m *AddWhiteRequest) String() string
func (*AddWhiteRequest) XXX_DiscardUnknown ¶
func (m *AddWhiteRequest) XXX_DiscardUnknown()
func (*AddWhiteRequest) XXX_Marshal ¶
func (m *AddWhiteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AddWhiteRequest) XXX_Merge ¶
func (m *AddWhiteRequest) XXX_Merge(src proto.Message)
func (*AddWhiteRequest) XXX_Size ¶
func (m *AddWhiteRequest) XXX_Size() int
func (*AddWhiteRequest) XXX_Unmarshal ¶
func (m *AddWhiteRequest) XXX_Unmarshal(b []byte) error
type CreateTaskRequest ¶
type CreateTaskRequest struct { Task *Task `protobuf:"bytes,1,opt,name=Task,proto3" json:"Task,omitempty"` // 网站列表 Websites []*Website `protobuf:"bytes,2,rep,name=Websites,proto3" json:"Websites,omitempty"` //监测节点 --SH,GZ,CD,BJ Nodes string `protobuf:"bytes,3,opt,name=Nodes,proto3" json:"Nodes,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
创建任务
func (*CreateTaskRequest) Descriptor ¶
func (*CreateTaskRequest) Descriptor() ([]byte, []int)
func (*CreateTaskRequest) GetNodes ¶
func (m *CreateTaskRequest) GetNodes() string
func (*CreateTaskRequest) GetTask ¶
func (m *CreateTaskRequest) GetTask() *Task
func (*CreateTaskRequest) GetWebsites ¶
func (m *CreateTaskRequest) GetWebsites() []*Website
func (*CreateTaskRequest) ProtoMessage ¶
func (*CreateTaskRequest) ProtoMessage()
func (*CreateTaskRequest) Reset ¶
func (m *CreateTaskRequest) Reset()
func (*CreateTaskRequest) String ¶
func (m *CreateTaskRequest) String() string
func (*CreateTaskRequest) XXX_DiscardUnknown ¶
func (m *CreateTaskRequest) XXX_DiscardUnknown()
func (*CreateTaskRequest) XXX_Marshal ¶
func (m *CreateTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateTaskRequest) XXX_Merge ¶
func (m *CreateTaskRequest) XXX_Merge(src proto.Message)
func (*CreateTaskRequest) XXX_Size ¶
func (m *CreateTaskRequest) XXX_Size() int
func (*CreateTaskRequest) XXX_Unmarshal ¶
func (m *CreateTaskRequest) XXX_Unmarshal(b []byte) error
type File ¶
type File struct { FileName string `protobuf:"bytes,1,opt,name=FileName,proto3" json:"FileName,omitempty"` Content []byte `protobuf:"bytes,2,opt,name=Content,proto3" json:"Content,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*File) Descriptor ¶
func (*File) GetContent ¶
func (*File) GetFileName ¶
func (*File) ProtoMessage ¶
func (*File) ProtoMessage()
func (*File) XXX_DiscardUnknown ¶
func (m *File) XXX_DiscardUnknown()
func (*File) XXX_Unmarshal ¶
type FileRequest ¶
type FileRequest struct { SiteID string `protobuf:"bytes,1,opt,name=SiteID,proto3" json:"SiteID,omitempty"` FileList []*File `protobuf:"bytes,2,rep,name=FileList,proto3" json:"FileList,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FileRequest) Descriptor ¶
func (*FileRequest) Descriptor() ([]byte, []int)
func (*FileRequest) GetFileList ¶
func (m *FileRequest) GetFileList() []*File
func (*FileRequest) GetSiteID ¶
func (m *FileRequest) GetSiteID() string
func (*FileRequest) ProtoMessage ¶
func (*FileRequest) ProtoMessage()
func (*FileRequest) Reset ¶
func (m *FileRequest) Reset()
func (*FileRequest) String ¶
func (m *FileRequest) String() string
func (*FileRequest) XXX_DiscardUnknown ¶
func (m *FileRequest) XXX_DiscardUnknown()
func (*FileRequest) XXX_Marshal ¶
func (m *FileRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FileRequest) XXX_Merge ¶
func (m *FileRequest) XXX_Merge(src proto.Message)
func (*FileRequest) XXX_Size ¶
func (m *FileRequest) XXX_Size() int
func (*FileRequest) XXX_Unmarshal ¶
func (m *FileRequest) XXX_Unmarshal(b []byte) error
type FileResponse ¶
type FileResponse struct { Result int32 `protobuf:"zigzag32,1,opt,name=Result,proto3" json:"Result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*FileResponse) Descriptor ¶
func (*FileResponse) Descriptor() ([]byte, []int)
func (*FileResponse) GetMsg ¶
func (m *FileResponse) GetMsg() string
func (*FileResponse) GetResult ¶
func (m *FileResponse) GetResult() int32
func (*FileResponse) ProtoMessage ¶
func (*FileResponse) ProtoMessage()
func (*FileResponse) Reset ¶
func (m *FileResponse) Reset()
func (*FileResponse) String ¶
func (m *FileResponse) String() string
func (*FileResponse) XXX_DiscardUnknown ¶
func (m *FileResponse) XXX_DiscardUnknown()
func (*FileResponse) XXX_Marshal ¶
func (m *FileResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FileResponse) XXX_Merge ¶
func (m *FileResponse) XXX_Merge(src proto.Message)
func (*FileResponse) XXX_Size ¶
func (m *FileResponse) XXX_Size() int
func (*FileResponse) XXX_Unmarshal ¶
func (m *FileResponse) XXX_Unmarshal(b []byte) error
type GeneralResponse ¶
type GeneralResponse struct { Result int32 `protobuf:"zigzag32,1,opt,name=Result,proto3" json:"Result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GeneralResponse) Descriptor ¶
func (*GeneralResponse) Descriptor() ([]byte, []int)
func (*GeneralResponse) GetMsg ¶
func (m *GeneralResponse) GetMsg() string
func (*GeneralResponse) GetResult ¶
func (m *GeneralResponse) GetResult() int32
func (*GeneralResponse) ProtoMessage ¶
func (*GeneralResponse) ProtoMessage()
func (*GeneralResponse) Reset ¶
func (m *GeneralResponse) Reset()
func (*GeneralResponse) String ¶
func (m *GeneralResponse) String() string
func (*GeneralResponse) XXX_DiscardUnknown ¶
func (m *GeneralResponse) XXX_DiscardUnknown()
func (*GeneralResponse) XXX_Marshal ¶
func (m *GeneralResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GeneralResponse) XXX_Merge ¶
func (m *GeneralResponse) XXX_Merge(src proto.Message)
func (*GeneralResponse) XXX_Size ¶
func (m *GeneralResponse) XXX_Size() int
func (*GeneralResponse) XXX_Unmarshal ¶
func (m *GeneralResponse) XXX_Unmarshal(b []byte) error
type MonitorResult ¶
type MonitorResult struct { TaskID string `protobuf:"bytes,1,opt,name=TaskID,proto3" json:"TaskID,omitempty"` SiteID string `protobuf:"bytes,2,opt,name=SiteID,proto3" json:"SiteID,omitempty"` ClientName string `protobuf:"bytes,3,opt,name=ClientName,proto3" json:"ClientName,omitempty"` IpAddr string `protobuf:"bytes,4,opt,name=IpAddr,proto3" json:"IpAddr,omitempty"` Port int32 `protobuf:"varint,5,opt,name=Port,proto3" json:"Port,omitempty"` DnsTime int32 `protobuf:"varint,6,opt,name=DnsTime,proto3" json:"DnsTime,omitempty"` LoadTime int32 `protobuf:"varint,7,opt,name=LoadTime,proto3" json:"LoadTime,omitempty"` ResponseTime int32 `protobuf:"varint,8,opt,name=ResponseTime,proto3" json:"ResponseTime,omitempty"` StatusCode int32 `protobuf:"varint,9,opt,name=StatusCode,proto3" json:"StatusCode,omitempty"` Result int32 `protobuf:"varint,10,opt,name=Result,proto3" json:"Result,omitempty"` RespUrl string `protobuf:"bytes,11,opt,name=RespUrl,proto3" json:"RespUrl,omitempty"` CreateTime int64 `protobuf:"varint,12,opt,name=CreateTime,proto3" json:"CreateTime,omitempty"` Resources string `protobuf:"bytes,13,opt,name=Resources,proto3" json:"Resources,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MonitorResult) Descriptor ¶
func (*MonitorResult) Descriptor() ([]byte, []int)
func (*MonitorResult) GetClientName ¶
func (m *MonitorResult) GetClientName() string
func (*MonitorResult) GetCreateTime ¶
func (m *MonitorResult) GetCreateTime() int64
func (*MonitorResult) GetDnsTime ¶
func (m *MonitorResult) GetDnsTime() int32
func (*MonitorResult) GetIpAddr ¶
func (m *MonitorResult) GetIpAddr() string
func (*MonitorResult) GetLoadTime ¶
func (m *MonitorResult) GetLoadTime() int32
func (*MonitorResult) GetPort ¶
func (m *MonitorResult) GetPort() int32
func (*MonitorResult) GetResources ¶
func (m *MonitorResult) GetResources() string
func (*MonitorResult) GetRespUrl ¶
func (m *MonitorResult) GetRespUrl() string
func (*MonitorResult) GetResponseTime ¶
func (m *MonitorResult) GetResponseTime() int32
func (*MonitorResult) GetResult ¶
func (m *MonitorResult) GetResult() int32
func (*MonitorResult) GetSiteID ¶
func (m *MonitorResult) GetSiteID() string
func (*MonitorResult) GetStatusCode ¶
func (m *MonitorResult) GetStatusCode() int32
func (*MonitorResult) GetTaskID ¶
func (m *MonitorResult) GetTaskID() string
func (*MonitorResult) ProtoMessage ¶
func (*MonitorResult) ProtoMessage()
func (*MonitorResult) Reset ¶
func (m *MonitorResult) Reset()
func (*MonitorResult) String ¶
func (m *MonitorResult) String() string
func (*MonitorResult) XXX_DiscardUnknown ¶
func (m *MonitorResult) XXX_DiscardUnknown()
func (*MonitorResult) XXX_Marshal ¶
func (m *MonitorResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MonitorResult) XXX_Merge ¶
func (m *MonitorResult) XXX_Merge(src proto.Message)
func (*MonitorResult) XXX_Size ¶
func (m *MonitorResult) XXX_Size() int
func (*MonitorResult) XXX_Unmarshal ¶
func (m *MonitorResult) XXX_Unmarshal(b []byte) error
type MonitorResultRequest ¶
type MonitorResultRequest struct { NodeName string `protobuf:"bytes,1,opt,name=NodeName,proto3" json:"NodeName,omitempty"` Result []*MonitorResult `protobuf:"bytes,2,rep,name=Result,proto3" json:"Result,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
监测结果对象
func (*MonitorResultRequest) Descriptor ¶
func (*MonitorResultRequest) Descriptor() ([]byte, []int)
func (*MonitorResultRequest) GetNodeName ¶
func (m *MonitorResultRequest) GetNodeName() string
func (*MonitorResultRequest) GetResult ¶
func (m *MonitorResultRequest) GetResult() []*MonitorResult
func (*MonitorResultRequest) ProtoMessage ¶
func (*MonitorResultRequest) ProtoMessage()
func (*MonitorResultRequest) Reset ¶
func (m *MonitorResultRequest) Reset()
func (*MonitorResultRequest) String ¶
func (m *MonitorResultRequest) String() string
func (*MonitorResultRequest) XXX_DiscardUnknown ¶
func (m *MonitorResultRequest) XXX_DiscardUnknown()
func (*MonitorResultRequest) XXX_Marshal ¶
func (m *MonitorResultRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MonitorResultRequest) XXX_Merge ¶
func (m *MonitorResultRequest) XXX_Merge(src proto.Message)
func (*MonitorResultRequest) XXX_Size ¶
func (m *MonitorResultRequest) XXX_Size() int
func (*MonitorResultRequest) XXX_Unmarshal ¶
func (m *MonitorResultRequest) XXX_Unmarshal(b []byte) error
type MonitorResultResponse ¶
type MonitorResultResponse struct { Result int32 `protobuf:"zigzag32,1,opt,name=Result,proto3" json:"Result,omitempty"` Msg string `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*MonitorResultResponse) Descriptor ¶
func (*MonitorResultResponse) Descriptor() ([]byte, []int)
func (*MonitorResultResponse) GetMsg ¶
func (m *MonitorResultResponse) GetMsg() string
func (*MonitorResultResponse) GetResult ¶
func (m *MonitorResultResponse) GetResult() int32
func (*MonitorResultResponse) ProtoMessage ¶
func (*MonitorResultResponse) ProtoMessage()
func (*MonitorResultResponse) Reset ¶
func (m *MonitorResultResponse) Reset()
func (*MonitorResultResponse) String ¶
func (m *MonitorResultResponse) String() string
func (*MonitorResultResponse) XXX_DiscardUnknown ¶
func (m *MonitorResultResponse) XXX_DiscardUnknown()
func (*MonitorResultResponse) XXX_Marshal ¶
func (m *MonitorResultResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MonitorResultResponse) XXX_Merge ¶
func (m *MonitorResultResponse) XXX_Merge(src proto.Message)
func (*MonitorResultResponse) XXX_Size ¶
func (m *MonitorResultResponse) XXX_Size() int
func (*MonitorResultResponse) XXX_Unmarshal ¶
func (m *MonitorResultResponse) XXX_Unmarshal(b []byte) error
type ResultService ¶
type ResultService struct { }
func (*ResultService) ServeFile ¶
func (this *ResultService) ServeFile(srv ResultService_ServeFileServer) error
func (*ResultService) ServeResult ¶
func (this *ResultService) ServeResult(ctx context.Context, request *MonitorResultRequest) (resp *MonitorResultResponse, err error)
type ResultServiceClient ¶
type ResultServiceClient interface { ServeResult(ctx context.Context, in *MonitorResultRequest, opts ...grpc.CallOption) (*MonitorResultResponse, error) ServeFile(ctx context.Context, opts ...grpc.CallOption) (ResultService_ServeFileClient, error) }
ResultServiceClient is the client API for ResultService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewResultServiceClient ¶
func NewResultServiceClient(cc grpc.ClientConnInterface) ResultServiceClient
type ResultServiceServer ¶
type ResultServiceServer interface { ServeResult(context.Context, *MonitorResultRequest) (*MonitorResultResponse, error) ServeFile(ResultService_ServeFileServer) error }
ResultServiceServer is the server API for ResultService service.
type ResultService_ServeFileClient ¶
type ResultService_ServeFileClient interface { Send(*FileRequest) error CloseAndRecv() (*FileResponse, error) grpc.ClientStream }
type ResultService_ServeFileServer ¶
type ResultService_ServeFileServer interface { SendAndClose(*FileResponse) error Recv() (*FileRequest, error) grpc.ServerStream }
type Task ¶
type Task struct { Taskid string `protobuf:"bytes,1,opt,name=Taskid,proto3" json:"Taskid,omitempty"` StartTime string `protobuf:"bytes,2,opt,name=StartTime,proto3" json:"StartTime,omitempty"` EndTime string `protobuf:"bytes,3,opt,name=EndTime,proto3" json:"EndTime,omitempty"` // 配置信息 Config int32 `protobuf:"varint,4,opt,name=Config,proto3" json:"Config,omitempty"` Interv int32 `protobuf:"varint,5,opt,name=Interv,proto3" json:"Interv,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
任务对象
func (*Task) Descriptor ¶
func (*Task) GetEndTime ¶
func (*Task) GetStartTime ¶
func (*Task) ProtoMessage ¶
func (*Task) ProtoMessage()
func (*Task) XXX_DiscardUnknown ¶
func (m *Task) XXX_DiscardUnknown()
func (*Task) XXX_Unmarshal ¶
type TaskService ¶
type TaskService struct { }
func (*TaskService) AddWhite ¶
func (self *TaskService) AddWhite(ctx context.Context, request *AddWhiteRequest) (resp *GeneralResponse, errr error)
func (*TaskService) CreateTask ¶
func (self *TaskService) CreateTask(ctx context.Context, request *CreateTaskRequest) (resp *GeneralResponse, errr error)
type TaskServiceClient ¶
type TaskServiceClient interface { CreateTask(ctx context.Context, in *CreateTaskRequest, opts ...grpc.CallOption) (*GeneralResponse, error) //参数1为网站ID,2为字符串 AddWhite(ctx context.Context, in *AddWhiteRequest, opts ...grpc.CallOption) (*GeneralResponse, error) }
TaskServiceClient is the client API for TaskService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewTaskServiceClient ¶
func NewTaskServiceClient(cc grpc.ClientConnInterface) TaskServiceClient
type TaskServiceServer ¶
type TaskServiceServer interface { CreateTask(context.Context, *CreateTaskRequest) (*GeneralResponse, error) //参数1为网站ID,2为字符串 AddWhite(context.Context, *AddWhiteRequest) (*GeneralResponse, error) }
TaskServiceServer is the server API for TaskService service.
type UnimplementedResultServiceServer ¶
type UnimplementedResultServiceServer struct { }
UnimplementedResultServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedResultServiceServer) ServeFile ¶
func (*UnimplementedResultServiceServer) ServeFile(srv ResultService_ServeFileServer) error
func (*UnimplementedResultServiceServer) ServeResult ¶
func (*UnimplementedResultServiceServer) ServeResult(ctx context.Context, req *MonitorResultRequest) (*MonitorResultResponse, error)
type UnimplementedTaskServiceServer ¶
type UnimplementedTaskServiceServer struct { }
UnimplementedTaskServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedTaskServiceServer) AddWhite ¶
func (*UnimplementedTaskServiceServer) AddWhite(ctx context.Context, req *AddWhiteRequest) (*GeneralResponse, error)
func (*UnimplementedTaskServiceServer) CreateTask ¶
func (*UnimplementedTaskServiceServer) CreateTask(ctx context.Context, req *CreateTaskRequest) (*GeneralResponse, error)
type Website ¶
type Website struct { WebsiteID string `protobuf:"bytes,1,opt,name=WebsiteID,proto3" json:"WebsiteID,omitempty"` Url string `protobuf:"bytes,2,opt,name=Url,proto3" json:"Url,omitempty"` Ip string `protobuf:"bytes,3,opt,name=Ip,proto3" json:"Ip,omitempty"` // 额外配置信息 Config int32 `protobuf:"varint,4,opt,name=Config,proto3" json:"Config,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
网站对象
func (*Website) Descriptor ¶
func (*Website) GetWebsiteID ¶
func (*Website) ProtoMessage ¶
func (*Website) ProtoMessage()
func (*Website) XXX_DiscardUnknown ¶
func (m *Website) XXX_DiscardUnknown()