dtstruct

Documentation

Overview

Copyright 2021 SANGFOR TECHNOLOGIES

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2021 SANGFOR TECHNOLOGIES

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2021 SANGFOR TECHNOLOGIES

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• type AgentHandler
• type Args
• type HttpServer
  • func (hs HttpServer) ServeHTTP(writer http.ResponseWriter, request *http.Request)

Types

type AgentHandler

type AgentHandler interface {
	RunTask(wp *dtstruct.WorkerPool, args *Args)
}

AgentHandler define method that agent adaptor need to implement

type Args

type Args struct {
	ServerAddr      string // server will receive heartbeat request
	AgtIp           string // local ip will listen on
	AgtPort         int    // local port
	CheckInterval   int    // heartbeat interval
	DisableHttp     bool   // disable http server or not
	RefreshInterval int    // refresh basic info interval
}

Args hold all args from cli when start

type HttpServer

type HttpServer struct {
	Server  *http.Server
	Limiter *rate.Limiter
	Args    *Args
	Process func(*rate.Limiter, *Args, http.ResponseWriter)
}

HttpServer now is only to facilitate restful api test, check if agent and database is available

func (HttpServer) ServeHTTP

func (hs HttpServer) ServeHTTP(writer http.ResponseWriter, request *http.Request)

ServeHTTP process http request