utils

Documentation

Index

• func CheckPasswordHash(password, hash string) bool
• func ControlSystemService(args []string, action string, run func()) error
• func CreateSystemService(args []string, run func()) (service.Service, error)
• func EncodeBase64(data string) string
• func GetIntValueFromStr(c context.Context, key string) (int, bool)
• func GetJwtToken(secretKey string, iat, seconds int64, payload string) (string, error)
• func GetJwtTokenFromMap(secretKey string, iat, seconds int64, payload map[string]string) (string, error)
• func GetValue[T any](c context.Context, key string) (T, bool)
• func HashPassword(password string) (string, error)
• func InstallToSystemPath(installPath string) error
• func IsInteger(str string) bool
• func IsSameDay(first time.Time, second time.Time) bool
• func LoadClientConfig(content []byte, strict bool) (*v1.ClientCommonConfig, []v1.ProxyConfigurer, []v1.VisitorConfigurer, error)
• func LoadClientConfigNormal(content []byte, strict bool) (*v1.ClientConfig, error)
• func LoadConfigureFromContent(content []byte, c any, strict bool) error
• func LoadContentWithTemplate(content []byte, values *config.Values) ([]byte, error)
• func LoadServerConfig(content []byte, strict bool) (*v1.ServerConfig, error)
• func MD5[T []byte | string](input T) string
• func NewBaseFRPClientConfig(serverAddr string, serverPort int, token string) *v1.ClientCommonConfig
• func NewBaseFRPClientUserAuthConfig(serverAddr string, serverPort int, user, token string) *v1.ClientCommonConfig
• func NewBaseFRPServerConfig(port int, token string) *v1.ServerConfig
• func NewBaseFRPServerUserAuthConfig(port int, opts []v1.HTTPPluginOptions) *v1.ServerConfig
• func ParseToken(secretKey, tokenStr string) (u jwt.MapClaims, err error)
• func PemBlockForPrivKey(priv interface{}) *pem.Block
• func PublicKey(priv interface{}) interface{}
• func SHA1(input string) string
• func Str2Int64(str string) int64
• func Str2Int64Default(str string, intVal int64) int64
• func TLSClientCert(caPem []byte) (credentials.TransportCredentials, error)
• func TLSClientCertNoValidate(caPem []byte) (credentials.TransportCredentials, error)
• func TLSServerCert(certPem, keyPem []byte) (credentials.TransportCredentials, error)
• func ToStr(any interface{}) string
• func TransformProxyConfigurerToMap(origin v1.ProxyConfigurer) (key string, r v1.ProxyConfigurer)
• func TransformVisitorConfigurerToMap(origin v1.VisitorConfigurer) (key string, r v1.VisitorConfigurer)
• func ValidateJwtToken(secretKey, token string) (bool, error)
• type SyncMap
  • func (s *SyncMap[K, V]) Clone() SyncMap[K, V]
  • func (s *SyncMap[K, V]) Delete(key K)
  • func (s *SyncMap[K, V]) Grow(size int)
  • func (s *SyncMap[K, V]) Keys() []K
  • func (s *SyncMap[K, V]) Len() (l int)
  • func (s *SyncMap[K, V]) Load(key K) (value V, loaded bool)
  • func (s *SyncMap[K, V]) LoadAndDelete(key K) (value V, loaded bool)
  • func (s *SyncMap[K, V]) LoadOrStore(key K, value V) (actual V, loaded bool)
  • func (s *SyncMap[K, V]) Range(f func(key K, value V) (shouldContinue bool))
  • func (s *SyncMap[K, V]) Store(key K, value V)
  • func (s *SyncMap[K, V]) Values() []V
• type SystemService
  • func (ss *SystemService) Start(s service.Service) error
  • func (ss *SystemService) Stop(s service.Service) error

Functions

func CheckPasswordHash

func CheckPasswordHash(password, hash string) bool

func ControlSystemService

func ControlSystemService(args []string, action string, run func()) error

func CreateSystemService

func CreateSystemService(args []string, run func()) (service.Service, error)

func EncodeBase64

func EncodeBase64(data string) string

func GetIntValueFromStr

func GetIntValueFromStr(c context.Context, key string) (int, bool)

func GetJwtToken

func GetJwtToken(secretKey string, iat, seconds int64, payload string) (string, error)

@secretKey: JWT 加解密密钥 @iat: 时间戳 @seconds: 过期时间，单位秒 @payload: 数据载体

func GetJwtTokenFromMap

func GetJwtTokenFromMap(secretKey string, iat, seconds int64, payload map[string]string) (string, error)

@secretKey: JWT 加解密密钥 @iat: 时间戳 @seconds: 过期时间，单位秒 @payload: 数据载体

func GetValue

func GetValue[T any](c context.Context, key string) (T, bool)

func HashPassword

func HashPassword(password string) (string, error)

func InstallToSystemPath

func InstallToSystemPath(installPath string) error

func IsInteger

func IsInteger(str string) bool

func IsSameDay

func IsSameDay(first time.Time, second time.Time) bool

func LoadClientConfig

func LoadClientConfig(content []byte, strict bool) (
	*v1.ClientCommonConfig,
	[]v1.ProxyConfigurer,
	[]v1.VisitorConfigurer,
	error,
)

func LoadClientConfigNormal

func LoadClientConfigNormal(content []byte, strict bool) (*v1.ClientConfig, error)

func LoadConfigureFromContent

func LoadConfigureFromContent(content []byte, c any, strict bool) error

func LoadContentWithTemplate

func LoadContentWithTemplate(content []byte, values *config.Values) ([]byte, error)

func LoadServerConfig

func LoadServerConfig(content []byte, strict bool) (*v1.ServerConfig, error)

func MD5

func MD5[T []byte | string](input T) string

func NewBaseFRPClientConfig

func NewBaseFRPClientConfig(serverAddr string, serverPort int, token string) *v1.ClientCommonConfig

func NewBaseFRPClientUserAuthConfig

func NewBaseFRPClientUserAuthConfig(serverAddr string, serverPort int, user, token string) *v1.ClientCommonConfig

func NewBaseFRPServerConfig

func NewBaseFRPServerConfig(port int, token string) *v1.ServerConfig

func NewBaseFRPServerUserAuthConfig

func NewBaseFRPServerUserAuthConfig(port int, opts []v1.HTTPPluginOptions) *v1.ServerConfig

func ParseToken

func ParseToken(secretKey, tokenStr string) (u jwt.MapClaims, err error)

func PemBlockForPrivKey

func PemBlockForPrivKey(priv interface{}) *pem.Block

func PublicKey

func PublicKey(priv interface{}) interface{}

func SHA1

func SHA1(input string) string

func Str2Int64

func Str2Int64(str string) int64

func Str2Int64Default

func Str2Int64Default(str string, intVal int64) int64

func TLSClientCert

func TLSClientCert(caPem []byte) (credentials.TransportCredentials, error)

func TLSClientCertNoValidate

func TLSClientCertNoValidate(caPem []byte) (credentials.TransportCredentials, error)

func TLSServerCert

func TLSServerCert(certPem, keyPem []byte) (credentials.TransportCredentials, error)

func ToStr

func ToStr(any interface{}) string

func TransformProxyConfigurerToMap

func TransformProxyConfigurerToMap(origin v1.ProxyConfigurer) (key string, r v1.ProxyConfigurer)

func TransformVisitorConfigurerToMap

func TransformVisitorConfigurerToMap(origin v1.VisitorConfigurer) (key string, r v1.VisitorConfigurer)

func ValidateJwtToken

func ValidateJwtToken(secretKey, token string) (bool, error)

@secretKey: JWT 加解密密钥 @token: JWT Token 的字符串

Types

type SyncMap

type SyncMap[K comparable, V any] struct {
	// contains filtered or unexported fields
}

SyncMap is like a Go sync.Map but type-safe using generics.

The zero SyncMap is empty and ready for use. A SyncMap must not be copied after first use.

func (*SyncMap[K, V]) Clone

func (s *SyncMap[K, V]) Clone() SyncMap[K, V]

Clone returns a copy (clone) of current SyncMap.

func (*SyncMap[K, V]) Delete

func (s *SyncMap[K, V]) Delete(key K)

Delete deletes the value for a key.

func (*SyncMap[K, V]) Grow

func (s *SyncMap[K, V]) Grow(size int)

Grow grows the map to the given size. It can be called before the first write operation used.

func (*SyncMap[K, V]) Keys

func (s *SyncMap[K, V]) Keys() []K

Keys return slice with all map keys.

func (*SyncMap[K, V]) Len

func (s *SyncMap[K, V]) Len() (l int)

Len returns the count of values in the map.

func (*SyncMap[K, V]) Load

func (s *SyncMap[K, V]) Load(key K) (value V, loaded bool)

Load returns the value stored in the map for a key, or nil if no value is present. The ok result indicates whether value was found in the map.

func (*SyncMap[K, V]) LoadAndDelete

func (s *SyncMap[K, V]) LoadAndDelete(key K) (value V, loaded bool)

LoadAndDelete deletes the value for a key, returning the previous value if any. The loaded result reports whether the key was present.

func (*SyncMap[K, V]) LoadOrStore

func (s *SyncMap[K, V]) LoadOrStore(key K, value V) (actual V, loaded bool)

LoadOrStore returns the existing value for the key if present. Otherwise, it stores and returns the given value. The loaded result is true if the value was loaded, false if stored.

func (*SyncMap[K, V]) Range

func (s *SyncMap[K, V]) Range(f func(key K, value V) (shouldContinue bool))

Range calls f sequentially for each key and value present in the map. If f returns false, range stops the iteration.

Range does not necessarily correspond to any consistent snapshot of the Map's contents: no key will be visited more than once. Range does not block other methods on the receiver; even f itself may call any method on m.

func (*SyncMap[K, V]) Store

func (s *SyncMap[K, V]) Store(key K, value V)

Store sets the value for a key.

func (*SyncMap[K, V]) Values

func (s *SyncMap[K, V]) Values() []V

Values return slice with all map values.

type SystemService

type SystemService struct {
	service.Service
	// contains filtered or unexported fields
}

func (*SystemService) Start

func (ss *SystemService) Start(s service.Service) error

func (*SystemService) Stop

func (ss *SystemService) Stop(s service.Service) error