services

package
v0.0.0-...-6986f26 Latest Latest
Warning

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

Go to latest
Published: May 8, 2020 License: BSD-2-Clause Imports: 19 Imported by: 0

Documentation

Index

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) Descriptor() ([]byte, []int)

func (*File) GetContent

func (m *File) GetContent() []byte

func (*File) GetFileName

func (m *File) GetFileName() string

func (*File) ProtoMessage

func (*File) ProtoMessage()

func (*File) Reset

func (m *File) Reset()

func (*File) String

func (m *File) String() string

func (*File) XXX_DiscardUnknown

func (m *File) XXX_DiscardUnknown()

func (*File) XXX_Marshal

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

func (*File) XXX_Merge

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

func (*File) XXX_Size

func (m *File) XXX_Size() int

func (*File) XXX_Unmarshal

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

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.

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) Descriptor() ([]byte, []int)

func (*Task) GetConfig

func (m *Task) GetConfig() int32

func (*Task) GetEndTime

func (m *Task) GetEndTime() string

func (*Task) GetInterv

func (m *Task) GetInterv() int32

func (*Task) GetStartTime

func (m *Task) GetStartTime() string

func (*Task) GetTaskid

func (m *Task) GetTaskid() string

func (*Task) ProtoMessage

func (*Task) ProtoMessage()

func (*Task) Reset

func (m *Task) Reset()

func (*Task) String

func (m *Task) String() string

func (*Task) XXX_DiscardUnknown

func (m *Task) XXX_DiscardUnknown()

func (*Task) XXX_Marshal

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

func (*Task) XXX_Merge

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

func (*Task) XXX_Size

func (m *Task) XXX_Size() int

func (*Task) XXX_Unmarshal

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

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.

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) ServeResult

type UnimplementedTaskServiceServer

type UnimplementedTaskServiceServer struct {
}

UnimplementedTaskServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedTaskServiceServer) AddWhite

func (*UnimplementedTaskServiceServer) CreateTask

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) Descriptor() ([]byte, []int)

func (*Website) GetConfig

func (m *Website) GetConfig() int32

func (*Website) GetIp

func (m *Website) GetIp() string

func (*Website) GetUrl

func (m *Website) GetUrl() string

func (*Website) GetWebsiteID

func (m *Website) GetWebsiteID() string

func (*Website) ProtoMessage

func (*Website) ProtoMessage()

func (*Website) Reset

func (m *Website) Reset()

func (*Website) String

func (m *Website) String() string

func (*Website) XXX_DiscardUnknown

func (m *Website) XXX_DiscardUnknown()

func (*Website) XXX_Marshal

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

func (*Website) XXX_Merge

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

func (*Website) XXX_Size

func (m *Website) XXX_Size() int

func (*Website) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

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