util

Documentation

Index

• func DerefInt16(v *int16) int16
• func DerefInt64(v *int64) int64
• func DerefString(s *string) string
• func DerefTime(t *time.Time) int64
• func DerefUint32(v *uint32) uint32
• func DirsExist(dirs []string) error
• func DurationSec(durationSec interface{}) time.Duration
• func FileExists(path string) bool
• func GenerateNATSAuthJWT(creds string) ([]nats.Option, error)
• func GenerateNATSAuthNKey(nkeyPath string) ([]nats.Option, error)
• func GenerateTLSConfig(caCert, clientCert, clientKey string, skipVerify bool, mTLS tls.ClientAuthType) (*tls.Config, error)
• func Gunzip(data []byte) ([]byte, error)
• func MapInterfaceToString(input map[string]interface{}) map[string]string
• func RandomString(n int) string
• func WriteError(l *logrus.Entry, errorCh chan<- *records.ErrorRecord, err error)

Functions

func DerefInt16

func DerefInt16(v *int16) int16

func DerefInt64

func DerefInt64(v *int64) int64

func DerefString

func DerefString(s *string) string

func DerefTime

func DerefTime(t *time.Time) int64

func DerefUint32

func DerefUint32(v *uint32) uint32

func DirsExist

func DirsExist(dirs []string) error

func DurationSec

func DurationSec(durationSec interface{}) time.Duration

func FileExists

func FileExists(path string) bool

func GenerateNATSAuthJWT

func GenerateNATSAuthJWT(creds string) ([]nats.Option, error)

GenerateNATSAuthJWT accepts either a path to a .creds file containing JWT credentials or the credentials directly in string format, and returns the correct nats connection authentication options

func GenerateNATSAuthNKey

func GenerateNATSAuthNKey(nkeyPath string) ([]nats.Option, error)

GenerateNATSAuthNKey accepts either a path to a file containing a Nkey seed, or the Nkey seed directly in string format, and returns the correct nats connection authentication options

func GenerateTLSConfig

func GenerateTLSConfig(caCert, clientCert, clientKey string, skipVerify bool, mTLS tls.ClientAuthType) (*tls.Config, error)

func Gunzip

func Gunzip(data []byte) ([]byte, error)

Gunzip decompresses a slice of bytes and returns a slice of decompressed bytes or an error.

func MapInterfaceToString

func MapInterfaceToString(input map[string]interface{}) map[string]string

func RandomString

func RandomString(n int) string

func WriteError

func WriteError(l *logrus.Entry, errorCh chan<- *records.ErrorRecord, err error)

WriteError is a wrapper for logging an error + writing to an error channel. Both the logger and error channel can be nil.