goutils

Documentation

Index

• Constants
• func DecodeBase64(msg string) (string, error)
• func EncodeBase64(msg string) string
• func Errorf(format string, v ...interface{})
• func GenHelp(options []Option, desc string) string
• func GenTlsConfig(flag TlsFlag, crt, key, ca string) (*tls.Config, error)
• func GetOptions(options []Option) (map[string]string, []string)
• func ListenAndHttp(network, addr, crt, key string, handler http.Handler)
• func LoadCryptoObj(crt, key, ca string) ([]tls.Certificate, *x509.CertPool, error)
• func MD5(src string) string
• func Now() int64
• func NowNano() uint64
• func Printf(format string, v ...interface{})
• func QuicDial(network, crt, key, ca string, cfg *quic.Config, ignore bool) (quic.Connection, error)
• func QuicListenAddr(network, crt, key, ca string, cfg *quic.Config, verifyClient bool) (*quic.Listener, error)
• func Random() float64
• func RandomString(length int) string
• func ReadLineN(filename string, n int) ([]string, error)
• func SHA1(src string) string
• func ServeHttp(cfg *ListenOptions, handler http.Handler)
• func Socket(port string) (net.Listener, error)
• func TLSSocket(port string, crt string, key string) (net.Listener, error)
• type Any_t
• type Conf
  • func GetConf(filename string) (Conf, error)
  • func (conf *Conf) GetVal(key string) string
• type ListenOptions
• type Option
• type Pool_t
  • func NewPool(workerInit WorkerGenerator, size int) *Pool_t
  • func (pool *Pool_t) Count() int
  • func (pool *Pool_t) Push(foo Any_t)
  • func (pool *Pool_t) Wait() Any_t
• type RangeLink_t
  • func NewRangeLink(arr []Range_t) *RangeLink_t
  • func (this *RangeLink_t) Append(newNode *RangeNode_t)
  • func (this *RangeLink_t) Converse(start int64, end int64) *RangeLink_t
  • func (this *RangeLink_t) Front() *Range_t
  • func (this *RangeLink_t) Mount(start int64, end int64)
  • func (this *RangeLink_t) Pop()
  • func (this *RangeLink_t) Push(newNode *RangeNode_t)
  • func (this *RangeLink_t) ToArray() []Range_t
• type RangeNode_t
• type Range_t
• type Stream
  • func InitStream(sock io.ReadWriteCloser) *Stream
  • func (st *Stream) End(content string)
  • func (st *Stream) ReadLine() (string, error)
  • func (st *Stream) Send(content string)
• type TlsFlag
• type Worker
• type WorkerGenerator

Examples

• GetConf
• GetOptions
• NewRangeLink
• Printf

Constants

const (
	TLSFLAG_IGNORE = 0 // 000
	TLSFLAG_CLIENT = 1 // 001
	TLSFLAG_SERVER = 2 // 010
	TLSFLAG_VERIFY = 3 // 011
)

Functions

func DecodeBase64

func DecodeBase64(msg string) (string, error)

func EncodeBase64

func EncodeBase64(msg string) string

func Errorf

func Errorf(format string, v ...interface{})

func GenHelp

func GenHelp(options []Option, desc string) string

func GenTlsConfig

func GenTlsConfig(flag TlsFlag, crt, key, ca string) (*tls.Config, error)

func GetOptions

func GetOptions(options []Option) (map[string]string, []string)

parse commandline params

Example

package main

import (
	"fmt"
	"github.com/watsonserve/goutils"
)

func main() {
	options := []goutils.Option{
		{
			Opt:       'h',
			Option:    "help",
			HasParams: false,
		},
		{
			Opt:       'z',
			Option:    "gz",
			HasParams: false,
		},
		{
			Opt:       'C',
			Option:    "cc",
			HasParams: true,
		},
		{
			Opt:       'f',
			Option:    "file",
			HasParams: true,
		},
	}
	argMap, params := goutils.GetOptions(options)

	fmt.Println(argMap)
	fmt.Println(params)
}

func ListenAndHttp

func ListenAndHttp(network, addr, crt, key string, handler http.Handler)

func LoadCryptoObj

func LoadCryptoObj(crt, key, ca string) ([]tls.Certificate, *x509.CertPool, error)

func MD5

func MD5(src string) string

func Now

func Now() int64

func NowNano

func NowNano() uint64

func Printf

func Printf(format string, v ...interface{})

Example

package main

import (
	"github.com/watsonserve/goutils"
)

func main() {
	goutils.Printf("- %d -\n", 404)
}

func QuicDial

func QuicDial(network, crt, key, ca string, cfg *quic.Config, ignore bool) (quic.Connection, error)

func QuicListenAddr

func QuicListenAddr(network, crt, key, ca string, cfg *quic.Config, verifyClient bool) (*quic.Listener, error)

func Random

func Random() float64

func RandomString

func RandomString(length int) string

func ReadLineN

func ReadLineN(filename string, n int) ([]string, error)

从一个文件中读取前n行和后面所有内容

func SHA1

func SHA1(src string) string

func ServeHttp

func ServeHttp(cfg *ListenOptions, handler http.Handler)

func Socket

func Socket(port string) (net.Listener, error)

* 这里使用的是每个链接启动一个新的go程的模型 * 高并发的话，性能取决于go语言的协程能力

func TLSSocket

func TLSSocket(port string, crt string, key string) (net.Listener, error)

* 这里使用的是每个链接启动一个新的go程的模型 * 高并发的话，性能取决于go语言的协程能力

Types

type Any_t

type Any_t interface{}

type Conf

type Conf map[string][]string

func GetConf

func GetConf(filename string) (Conf, error)

read configure file

Example

package main

import (
	"fmt"
	"github.com/watsonserve/goutils"
)

func main() {
	// # test.conf
	// # this is a config file
	// foo = bar
	// foos=1
	// foos = 2
	// null
	//
	conf, err := goutils.GetConf("test.conf")
	if nil != err {
		return
	}
	fmt.Println(conf)
}

Output:
map[foo:[bar] foos:[1 2] null:[]]

func (*Conf) GetVal

func (conf *Conf) GetVal(key string) string

type ListenOptions

type ListenOptions struct {
	Unix   string
	Tcp    string
	TcpLts string
	Quic   string
	Crt    string
	Key    string
}

type Option

type Option struct {
	Name      string
	Opt       byte
	Option    string
	HasParams bool
	Desc      string
}

type Pool_t

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

func NewPool

func NewPool(workerInit WorkerGenerator, size int) *Pool_t

func (*Pool_t) Count

func (pool *Pool_t) Count() int

func (*Pool_t) Push

func (pool *Pool_t) Push(foo Any_t)

func (*Pool_t) Wait

func (pool *Pool_t) Wait() Any_t

type RangeLink_t

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

func NewRangeLink

func NewRangeLink(arr []Range_t) *RangeLink_t

Example

package main

import (
	"fmt"

	"github.com/watsonserve/goutils"
)

func main() {
	// # test.conf
	// # this is a config file
	// foo = bar
	// foos=1
	// foos = 2
	// null
	//
	link := goutils.NewRangeLink(nil)
	link.Mount(20, 80)
	fmt.Println(link.ToArray())
}

func (*RangeLink_t) Append

func (this *RangeLink_t) Append(newNode *RangeNode_t)

尾添加

func (*RangeLink_t) Converse

func (this *RangeLink_t) Converse(start int64, end int64) *RangeLink_t

取反

func (*RangeLink_t) Front

func (this *RangeLink_t) Front() *Range_t

头查看

func (*RangeLink_t) Mount

func (this *RangeLink_t) Mount(start int64, end int64)

挂载

func (*RangeLink_t) Pop

func (this *RangeLink_t) Pop()

头删除

func (*RangeLink_t) Push

func (this *RangeLink_t) Push(newNode *RangeNode_t)

头添加

func (*RangeLink_t) ToArray

func (this *RangeLink_t) ToArray() []Range_t

转成数组

type RangeNode_t

type RangeNode_t struct {
	Range_t
	Next *RangeNode_t
}

type Range_t

type Range_t struct {
	Start int64
	End   int64
}

type Stream

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

func InitStream

func InitStream(sock io.ReadWriteCloser) *Stream

func (*Stream) End

func (st *Stream) End(content string)

发送并关闭

func (*Stream) ReadLine

func (st *Stream) ReadLine() (string, error)

func (*Stream) Send

func (st *Stream) Send(content string)

发送

type TlsFlag

type TlsFlag int

type Worker

type Worker interface {
	Work(params Any_t) Any_t
	Destroy()
}

type WorkerGenerator

type WorkerGenerator func() (Worker, error)