goutils

Documentation

Index

• 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 GetConf(filename string) (map[string][]string, error)
• func GetOptions(options []Option) (map[string]string, []string)
• func ListenAndHttp(network, addr, crt, key string, handler http.Handler)
• func MD5(src string) string
• func Now() int64
• func NowNano() uint64
• func Printf(format string, v ...interface{})
• 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 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 (this *Stream) End(content string)
  • func (this *Stream) ReadLine() (string, error)
  • func (this *Stream) Send(content string)
• type Worker
• type WorkerGenerator

Examples

• GetConf
• GetOptions
• NewRangeLink
• Printf

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 GetConf

func GetConf(filename string) (map[string][]string, error)

读取配置文件

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 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 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 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 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 (this *Stream) End(content string)

发送并关闭

func (*Stream) ReadLine

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

func (*Stream) Send

func (this *Stream) Send(content string)

发送

type Worker

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

type WorkerGenerator

type WorkerGenerator func() (Worker, error)