sys

Documentation

Overview

Copyright (c) 2023, donnie <donnie4w@gmail.com> All rights reserved. Use of t source code is governed by a BSD-style license that can be found in the LICENSE file.

github.com/donnie4w/wfs

Copyright (c) 2023, donnie <donnie4w@gmail.com> All rights reserved. Use of t source code is governed by a BSD-style license that can be found in the LICENSE file.

github.com/donnie4w/wfs

Copyright (c) 2023, donnie <donnie4w@gmail.com> All rights reserved. Use of this source code is governed by a BSD-style license that can be found in the LICENSE file.

github.com/donnie4w/wfs

Index

• Constants
• Variables
• func FmtLog(v ...any)
• type ConfBean
  • func GetConfg() (conf *ConfBean)
• type ERROR
• type FragBean
• type PathBean
• type Server
• type WS
  • func NewWfsClient(server, origin, name, password string) (_r *WS, err error)
  • func (t *WS) Close() error
  • func (t *WS) Receive(procData func([]byte) bool) (err error)
  • func (t *WS) Send(bs []byte) (err error)

Constants

const (
	KB = 1 << 10
	MB = 1 << 20
	GB = 1 << 30
)

const VERSION = "1.0.2"

Variables

var (
	Serve          = hashmap.NewSortMap[int, Server]()
	Wfs            Server
	STARTTIME      = time.Now()
	UUID           int64
	Service        string
	LOGDEBUG       bool
	GOGC           int
	Pid            string
	ORIGIN         string
	DEBUGADDR      string
	WFSJSON        string
	Conf           *ConfBean
	Mode           = 1
	MaxSigma       = float64(20)
	MaxSide        = 10000
	MaxPixel       = 300000000
	CompressType   = int32(1)
	WFSDATA        = "wfsdata"
	IMAGEVIEW2     = "?imageView2"
	IMAGEVIEW      = "?imageView"
	IMAGEMODE      = "?mode"
	DefaultAccount = [2]string{"admin", "123"}
	WEBADDR        = fmt.Sprint(6<<10 + 2)
	OPADDR         = fmt.Sprint(":", 5<<10+2)
	LISTEN         = 4<<10 + 2
	SYNC           = false
	DBBUFFER       = 1 << 6 * MB
	InaccurateTime = time.Now().UnixNano()
	ConnectTimeout = 10 * time.Second
	WaitTimeout    = 10 * time.Second
	FileSize       = int64(500 * MB)
	DataMaxsize    = int64(100 * MB)
	SocketTimeout  = 10 * time.Second
	OpenSSL        = &openssl{}
	Memlimit       = int64(1 << 10)
)

var (
	KeyStoreInit func(string)
	Count        func() int64
	Seq          func() int64
	AppendData   func(string, []byte, int32) (int64, ERROR)
	GetData      func(string) []byte
	DelData      func(string) ERROR
	Add          func([]byte, []byte) error
	Del          func([]byte) error
	SearchLike   func(string) []*PathBean
	SearchLimit  func(int64, int64) []*PathBean
	Defrag       func(string) ERROR
	FragAnalysis func(string) (*FragBean, ERROR)
	Export       func(func(bean *stub.SnapshotBean) bool) error
	Import       func(*stub.SnapshotBean, bool) error
	Modify       func(string, string) ERROR
	WsClient     func(tls bool, pid, opaddr, requri, name, pwd string) (ws *WS, err error)
)

var ERR_AUTH = err(4105, "limited authority")

var ERR_DEFRAG_FORBID = err(5102, "operation files cannot be defragmented")

var ERR_DEFRAG_UNDERWAY = err(5103, "defragmentation is underway")

var ERR_EXSIT = err(4104, "has exist")

var ERR_FILEAPPEND = err(5105, "append data error")

var ERR_FILECREATE = err(5106, "create file error")

var ERR_NEWPATHEXIST = err(4107, "the new path already exists")

var ERR_NOPASS = err(4102, "verification fail")

var ERR_NOTEXSIT = err(4106, "not exist")

var ERR_OVERSIZE = err(4101, "data oversize")

var ERR_PARAMS = err(4103, "parameter error")

var ERR_STOPSERVICE = err(5104, "service has stopped")

var ERR_UNDEFINED = err(5101, "undefined error")

Functions

func FmtLog

func FmtLog(v ...any)

Types

type ConfBean

type ConfBean struct {
	FileSize           int64   `json:"filesize"`
	Opaddr             string  `json:"opaddr"`
	WebAddr            string  `json:"webaddr"`
	Listen             int     `json:"listen"`
	Admin_Ssl_crt      string  `json:"admin.ssl_certificate"`
	Admin_Ssl_crt_key  string  `json:"admin.ssl_certificate_key"`
	Ssl_crt            string  `json:"ssl_certificate"`
	Ssl_crt_key        string  `json:"ssl_certificate_key"`
	Memlimit           int64   `json:"memlimit"`
	DataMaxsize        int64   `json:"data.maxsize"`
	Init               bool    `json:"init"`
	Keystore           *string `json:"keystore"`
	Mode               *int    `json:"mode"`
	Sync               *bool   `json:"sync"`
	Compress           *int32  `json:"compress"`
	WfsData            *string `json:"data.dir"`
	SLASH              bool    `json:"prefix.slash"`
	MaxSigma           float64 `json:"maxsigma"`
	MaxSide            int     `json:"maxside"`
	MaxPixel           int     `json:"maxpixel"`
	Resample           int8    `json:"resample"`
	ImgViewingRevProxy string  `json:"imgViewingRevProxy"`
}

func GetConfg

func GetConfg() (conf *ConfBean)

type ERROR

type ERROR interface {
	WfsError() *WfsError
	Error() error
	Equal(ERROR) bool
	Code() int32
}

type FragBean

type FragBean struct {
	Node       string
	RmSize     int64
	ActualSize int64
	FileSize   int64
}

type PathBean

type PathBean struct {
	Id         int64
	Path       string
	Body       []byte
	Timestramp int64
}

type Server

type Server interface {
	Serve() (err error)
	Close() (err error)
}

type WS

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

func NewWfsClient

func NewWfsClient(server, origin, name, password string) (_r *WS, err error)

func (*WS) Close

func (t *WS) Close() error

func (*WS) Receive

func (t *WS) Receive(procData func([]byte) bool) (err error)

func (*WS) Send

func (t *WS) Send(bs []byte) (err error)