httpd

package

v0.0.2 Latest Latest Go to latest Published: Oct 24, 2020 License: MIT Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/donkeywon/s-proxy

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewPool() *sync.Pool
type Config
- func NewConfig() Config
type HttpBodyAddInfluxdbDatabase
type HttpBodyAddInfluxdbMetric
type HttpBodyAddInfluxdbMetricRoute
type HttpBodyAddInfluxdbNode
type HttpBodyAddTask
type HttpResponse
- func GetResponseWrapper() *HttpResponse
type Service
- func New(config Config) (*Service, error)
type Statistics

Constants ¶

View Source

const (
	DefaultAddr              = ":1409"
	DefaultWriteTimeout      = util.Duration(1000 * time.Millisecond)
	DefaultReadTimeout       = util.Duration(1000 * time.Millisecond)
	DefaultReadHeaderTimeout = util.Duration(1000 * time.Millisecond)
	DefaultIdleTimeout       = util.Duration(1000 * time.Millisecond)
	DefaultCloseTimeout      = util.Duration(5 * time.Second)
	DefaultMonitorInterval   = util.Duration(10 * time.Second)
)

Variables ¶

This section is empty.

Functions ¶

func NewPool ¶

func NewPool() *sync.Pool

Types ¶

type Config ¶

type Config struct {
	Addr              string        `yaml:"Addr,omitempty" mapstructure:"Addr,omitempty"`
	WriteTimeout      util.Duration `yaml:"WriteTimeout,omitempty" mapstructure:"WriteTimeout,omitempty"`
	ReadTimeout       util.Duration `yaml:"ReadTimeout,omitempty" mapstructure:"ReadTimeout,omitempty"`
	ReadHeaderTimeout util.Duration `yaml:"ReadHeaderTimeout,omitempty" mapstructure:"ReadHeaderTimeout,omitempty"`
	IdleTimeout       util.Duration `yaml:"IdleTimeout,omitempty" mapstructure:"IdleTimeout,omitempty"`
	CloseTimeout      util.Duration `yaml:"CloseTimeout,omitempty" mapstructure:"CloseTimeout,omitempty"`
	MonitorInterval   util.Duration `yaml:"MonitorInterval,omitempty" mapstructure:"MonitorInterval,omitempty"`
}

func NewConfig ¶

func NewConfig() Config

type HttpBodyAddInfluxdbDatabase ¶

type HttpBodyAddInfluxdbDatabase struct {
	NodeId   int64  `json:"node_id"`
	Database string `json:"database" validate:"min=1,max=63"`
}

type HttpBodyAddInfluxdbMetric ¶

type HttpBodyAddInfluxdbMetric struct {
	Name        string `json:"name" validate:"min=1,max=63"`
	SeriesLimit int    `json:"series_limit"`
}

type HttpBodyAddInfluxdbMetricRoute ¶

type HttpBodyAddInfluxdbMetricRoute struct {
	MetricId int64 `json:"metric_id"`
	NodeDBId int64 `json:"node_db_id"`
}

type HttpBodyAddInfluxdbNode ¶

type HttpBodyAddInfluxdbNode struct {
	IP       string `json:"ip" validate:"ip"`
	HttpPort int    `json:"http_port" validate:"min=1,max=65535"`
	UdpPort  int    `json:"udp_port" validate:"min=1,max=65535"`
	DataPath string `json:"data_path" validate:"min=1,max=127"`
}

type HttpBodyAddTask ¶

type HttpBodyAddTask struct {
	Name    string `json:"name" validate:"min=1,max=63"`
	Type    int    `json:"type"`
	Content string `json:"content" validate:"min=1,max=2048"`
}

type HttpResponse ¶

type HttpResponse struct {
	// contains filtered or unexported fields
}

func GetResponseWrapper ¶

func GetResponseWrapper() *HttpResponse

func (*HttpResponse) Free ¶

func (hr *HttpResponse) Free()

func (*HttpResponse) GetResponse ¶

func (hr *HttpResponse) GetResponse() *response

func (*HttpResponse) SetData ¶

func (hr *HttpResponse) SetData(d interface{})

func (*HttpResponse) SetMessage ¶

func (hr *HttpResponse) SetMessage(m string)

func (*HttpResponse) SetSuccess ¶

func (hr *HttpResponse) SetSuccess(s bool)

type Service ¶

type Service struct {
	Config Config

	Closing chan struct{}
	Closed  chan struct{}

	Logger *zap.Logger
	// contains filtered or unexported fields
}

func New ¶

func New(config Config) (*Service, error)

func (*Service) AddInfluxdbDatabase ¶

func (s *Service) AddInfluxdbDatabase(w http.ResponseWriter, r *http.Request)

func (*Service) AddInfluxdbMetric ¶

func (s *Service) AddInfluxdbMetric(w http.ResponseWriter, r *http.Request)

func (*Service) AddInfluxdbMetricRoute ¶

func (s *Service) AddInfluxdbMetricRoute(w http.ResponseWriter, r *http.Request)

func (*Service) AddInfluxdbNode ¶

func (s *Service) AddInfluxdbNode(w http.ResponseWriter, r *http.Request)

func (*Service) AddTask ¶

func (s *Service) AddTask(w http.ResponseWriter, r *http.Request)

func (*Service) Close ¶

func (s *Service) Close() error

func (*Service) Open ¶

func (s *Service) Open() error

func (*Service) SendToInfluxdb ¶

func (s *Service) SendToInfluxdb(w http.ResponseWriter, r *http.Request)

func (*Service) SendToKafka ¶

func (s *Service) SendToKafka(w http.ResponseWriter, r *http.Request)

func (*Service) SetInfluxdbService ¶

func (s *Service) SetInfluxdbService(is *influxdb.Service)

func (*Service) SetKafkaService ¶

func (s *Service) SetKafkaService(ks *kafka.Service)

func (*Service) WithLogger ¶

func (s *Service) WithLogger(logger *zap.Logger)

type Statistics ¶

type Statistics struct {
	KafkaReceived        uint64
	KafkaReceivedFail    uint64
	KafkaSendSuccess     uint64
	KafkaSendFail        uint64
	InfluxdbReceived     uint64
	InfluxdbReceivedFail uint64
	InfluxdbSendSuccess  uint64
	InfluxdbSendFail     uint64
}

Source Files ¶

View all Source files

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