test

package

v0.0.0-...-5c10c71 Latest Latest Go to latest Published: Sep 12, 2025 License: GPL-3.0 Imports: 29 Imported by: 0

Details

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

Repository

github.com/kentik/libkflow

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func Print(out io.Writer, i int, flow chf.CHF, dev *api.Device)
func RandStr(n int) string
type Server
- func NewClientServer() (*api.Client, *Server, *api.Device, error)
- func NewServer(host string, port int, tls, quiet bool, email, token string, dev *api.Device) (*Server, error)

Constants ¶

View Source

const (
	API  = "/api/internal"
	FLOW = "/chf"
	TSDB = "/tsdb"
	DNS  = "/dns"
)

Variables ¶

This section is empty.

Functions ¶

func Print ¶

func Print(out io.Writer, i int, flow chf.CHF, dev *api.Device)

func RandStr ¶

func RandStr(n int) string

Types ¶

type Server ¶

type Server struct {
	Host   net.IP
	Port   int
	Email  string
	Token  string
	Device *api.Device
	Log    *log.Logger

	HttpServer *http.Server
	// contains filtered or unexported fields
}

func NewClientServer ¶

func NewClientServer() (*api.Client, *Server, *api.Device, error)

func NewServer ¶

func NewServer(host string, port int, tls, quiet bool, email, token string, dev *api.Device) (*Server, error)

func (*Server) Dns ¶

func (s *Server) Dns() <-chan *api.DNSResponse

func (*Server) Flows ¶

func (s *Server) Flows() <-chan chf.PackedCHF

func (*Server) RunHttpServer ¶

func (s *Server) RunHttpServer() error

func (*Server) StopHttpServer ¶

func (s *Server) StopHttpServer(ctx context.Context) error

func (*Server) URL ¶

func (s *Server) URL(path string) *url.URL

Source Files ¶

View all Source files

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