common

package module

v0.0.0-...-fc06f08 Latest Latest Go to latest Published: Dec 30, 2020 License: MIT Imports: 25 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Goldenbean/go-common

README ¶

go-common

Documentation ¶

Index ¶

Constants
func DPanic(args ...interface{})
func DPanicf(template string, args ...interface{})
func Debug(args ...interface{})
func Debugf(template string, args ...interface{})
func Error(args ...interface{})
func Errorf(template string, args ...interface{})
func Execute(command string) (string, bool)
func Fatal(args ...interface{})
func Fatalf(template string, args ...interface{})
func Generate() uuid.UUID
func GetIP() []string
func GetTimeStamp()
func HTTPGet(url string) string
func HTTPGetBinary(url string) ([]byte, error)
func HTTPGetBinaryToFile(url string, path string) (string, bool)
func HTTPGetWithHeaders(url string, headers map[string]string) string
func HTTPPost(url string, data []byte)
func HTTPPostWithHeader(url string, data []byte, headers map[string]string) []byte
func HttpPut(url string, data []byte) (string, error)
func Info(args ...interface{})
func Infof(template string, args ...interface{})
func Marshal(obj interface{}) []byte
func Panic(args ...interface{})
func Panicf(template string, args ...interface{})
func PrintCPU()
func PrintIP()
func ReadFile(filePath string, queue chan<- string)
func Run(name string, arg ...string) string
func RunWithStdin(name string, arg ...string) string
func SignalWatch()
func SliceContains(slice []string, substr string) bool
func StartUDPServer(port int, output chan string)
func ToBeautifyJson(obj interface{}) string
func ToJson(obj interface{}) string
func Unmarshal(txt string, obj interface{})
func Warn(args ...interface{})
func Warnf(template string, args ...interface{})
func WriteFile(filePath string, outQ <-chan []string)
type KafkaProducer
- func (prod *KafkaProducer) Close() error
- func (prod *KafkaProducer) New() sarama.SyncProducer
- func (prod *KafkaProducer) Send(topic string, message string)
type MyRedis
- func NewMyRedis(addr string, password string) *MyRedis
- func (r *MyRedis) RateLimit(key string, limit RateLimitParam) (pass bool, err error)
type RateLimitParam
type Response

Constants ¶

View Source

const (
	SERVER_RECV_LEN = 65000
)

udp config

Variables ¶

This section is empty.

Functions ¶

func DPanic ¶

func DPanic(args ...interface{})

func DPanicf ¶

func DPanicf(template string, args ...interface{})

func Debug ¶

func Debug(args ...interface{})

func Debugf ¶

func Debugf(template string, args ...interface{})

func Error ¶

func Error(args ...interface{})

func Errorf ¶

func Errorf(template string, args ...interface{})

func Execute ¶

func Execute(command string) (string, bool)

Execute : run BASH Command

func Fatal ¶

func Fatal(args ...interface{})

func Fatalf ¶

func Fatalf(template string, args ...interface{})

func Generate ¶

func Generate() uuid.UUID

Generate : create UUID

func GetIP ¶

func GetIP() []string

GetIP :

func GetTimeStamp ¶

func GetTimeStamp()

GetTimeStamp : get timestamp

func HTTPGet ¶

func HTTPGet(url string) string

HTTPGet :

func HTTPGetBinary ¶

func HTTPGetBinary(url string) ([]byte, error)

HTTPGetBinary :

func HTTPGetBinaryToFile ¶

func HTTPGetBinaryToFile(url string, path string) (string, bool)

HTTPGetBinaryToFile :

func HTTPGetWithHeaders ¶

func HTTPGetWithHeaders(url string, headers map[string]string) string

HTTPGetWithHeaders :

func HTTPPost ¶

func HTTPPost(url string, data []byte)

HTTPPost :

func HTTPPostWithHeader ¶

func HTTPPostWithHeader(url string, data []byte, headers map[string]string) []byte

HTTPPostWithHeader :

func HttpPut ¶

func HttpPut(url string, data []byte) (string, error)

HTTPPut :

func Info ¶

func Info(args ...interface{})

func Infof ¶

func Infof(template string, args ...interface{})

func Marshal ¶

func Marshal(obj interface{}) []byte

func Panic ¶

func Panic(args ...interface{})

func Panicf ¶

func Panicf(template string, args ...interface{})

func PrintCPU ¶

func PrintCPU()

PrintCPU :

func PrintIP ¶

func PrintIP()

PrintIP :

func ReadFile ¶

func ReadFile(filePath string, queue chan<- string)

func Run ¶

func Run(name string, arg ...string) string

Run : Execute Commands

func RunWithStdin ¶

func RunWithStdin(name string, arg ...string) string

RunWithStdin : Execute Commands

func SignalWatch ¶

func SignalWatch()

SignalWatch :

func SliceContains ¶

func SliceContains(slice []string, substr string) bool

SliceContains : slice contains substr

func StartUDPServer ¶

func StartUDPServer(port int, output chan string)

StartUDPServer : udp server

func ToBeautifyJson ¶

func ToBeautifyJson(obj interface{}) string

func ToJson ¶

func ToJson(obj interface{}) string

func Unmarshal ¶

func Unmarshal(txt string, obj interface{})

func Warn ¶

func Warn(args ...interface{})

func Warnf ¶

func Warnf(template string, args ...interface{})

func WriteFile ¶

func WriteFile(filePath string, outQ <-chan []string)

Types ¶

type KafkaProducer ¶

type KafkaProducer struct {
	SyncProducer sarama.SyncProducer
	Brokers      []string
}

KafkaProducer : Kafka Producer

func (*KafkaProducer) Close ¶

func (prod *KafkaProducer) Close() error

func (*KafkaProducer) New ¶

func (prod *KafkaProducer) New() sarama.SyncProducer

func (*KafkaProducer) Send ¶

func (prod *KafkaProducer) Send(topic string, message string)

type MyRedis ¶

type MyRedis struct {
	Client *redis.Client
}

func NewMyRedis ¶

func NewMyRedis(addr string, password string) *MyRedis

NewMyRedis : init

func (*MyRedis) RateLimit ¶

func (r *MyRedis) RateLimit(key string, limit RateLimitParam) (pass bool, err error)

RateLimit : Rate Limit

type RateLimitParam ¶

type RateLimitParam struct {
	Threshold int64
	Period    time.Duration
}

type Response ¶

type Response struct {
	Code    int         `json:"code"`
	Message string      `json:"message"`
	Success bool        `json:"success"`
	Data    interface{} `json:"data"`
}

Response : REST response

Source Files ¶

View all Source files

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