utils

Documentation

Index

• func DailKafka(k *conf.KafkaConfig, kafkaOpts ...logkafka.KafkaOptionFunc) (sarama.Client, error)
• func ForceColor() bool
• func ForceNewKafkaClient(k *conf.KafkaConfig) sarama.Client
• func GetEnvFiles(root string) ([]string, error)
• func GetRandString(length int) string
• func NewDiscoveryGrpcConn(ctx context.Context, conf *Backend, d registry.Discovery) (*grpc.ClientConn, error)
• func NewEtcdGrpcConn(ctx context.Context, conf *EtcdBackend) (*grpc.ClientConn, error)
• func NewKafkaClient(k *conf.KafkaConfig) (sarama.Client, error)
• func NewSignalGrpcConn(ctx context.Context, conf *Backend) (*grpc.ClientConn, error)
• func SortUUID() string
• func SortUUIDWithUUID(src uuid.UUID) string
• func TransLogrus(l *logrus.Logger) log.Logger
• func ValidateMac(mac string) (string, error)
• func WithDeviceIDRange[T constraints.Integer](start, end T) func(*gorm.DB) *gorm.DB
• func WithIDRange[T constraints.Ordered](start, end T) func(*gorm.DB) *gorm.DB
• type Backend
• type EtcdBackend
• type GrpcGatewayServer
  • func NewGrpcGatewayServer(config *conf.GrpcServerConfig) *GrpcGatewayServer
  • func (s *GrpcGatewayServer) Endpoint() (*url.URL, error)
  • func (s *GrpcGatewayServer) Endpoints() ([]*url.URL, error)
  • func (s *GrpcGatewayServer) GrpcRegistrar() grpc.ServiceRegistrar
  • func (s *GrpcGatewayServer) HttpRegistrar() *ghttp.Server
  • func (s *GrpcGatewayServer) Start(ctx context.Context) error
  • func (s *GrpcGatewayServer) Stop(ctx context.Context) error
• type Logger
  • func (l *Logger) Log(level log.Level, keyvals ...interface{}) error
• type Scope
  • func WithDeviceIDEq[T constraints.Integer](id T) Scope
  • func WithIDEq[T constraints.Ordered](id T) Scope
  • func WithOrder(order string) Scope
  • func WithPageAndPageSize(page, pageSize int) Scope
  • func WithTimestampAfter(t int64) Scope
  • func WithTimestampBefore(t int64) Scope
• type TCPHandler
• type TcpServer
  • func NewTcpServer(conf *conf.TcpServer, handler TCPHandler) *TcpServer
  • func (s *TcpServer) Endpoint() (*url.URL, error)
  • func (s *TcpServer) Start(ctx context.Context) error
  • func (s *TcpServer) Stop(ctx context.Context) error

Functions

func DailKafka

func DailKafka(k *conf.KafkaConfig, kafkaOpts ...logkafka.KafkaOptionFunc) (sarama.Client, error)

func ForceColor

func ForceColor() bool

func ForceNewKafkaClient

func ForceNewKafkaClient(k *conf.KafkaConfig) sarama.Client

func GetEnvFiles

func GetEnvFiles(root string) ([]string, error)

func GetRandString

func GetRandString(length int) string

func NewDiscoveryGrpcConn

func NewDiscoveryGrpcConn(ctx context.Context, conf *Backend, d registry.Discovery) (*grpc.ClientConn, error)

func NewEtcdGrpcConn

func NewEtcdGrpcConn(ctx context.Context, conf *EtcdBackend) (*grpc.ClientConn, error)

func NewKafkaClient

func NewKafkaClient(k *conf.KafkaConfig) (sarama.Client, error)

func NewSignalGrpcConn

func NewSignalGrpcConn(ctx context.Context, conf *Backend) (*grpc.ClientConn, error)

func SortUUID

func SortUUID() string

func SortUUIDWithUUID

func SortUUIDWithUUID(src uuid.UUID) string

func TransLogrus

func TransLogrus(l *logrus.Logger) log.Logger

func ValidateMac

func ValidateMac(mac string) (string, error)

func WithDeviceIDRange

func WithDeviceIDRange[T constraints.Integer](start, end T) func(*gorm.DB) *gorm.DB

func WithIDRange

func WithIDRange[T constraints.Ordered](start, end T) func(*gorm.DB) *gorm.DB

Types

type Backend

type Backend struct {
	Endpoint  string
	Tls       bool
	JwtSecret string
	CustomCA  string
	TimeOut   string
}

type EtcdBackend

type EtcdBackend struct {
	Backend
	ServiceName string
	Username    string
	Password    string
}

type GrpcGatewayServer

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

func NewGrpcGatewayServer

func NewGrpcGatewayServer(config *conf.GrpcServerConfig) *GrpcGatewayServer

func (*GrpcGatewayServer) Endpoint

func (s *GrpcGatewayServer) Endpoint() (*url.URL, error)

func (*GrpcGatewayServer) Endpoints

func (s *GrpcGatewayServer) Endpoints() ([]*url.URL, error)

func (*GrpcGatewayServer) GrpcRegistrar

func (s *GrpcGatewayServer) GrpcRegistrar() grpc.ServiceRegistrar

func (*GrpcGatewayServer) HttpRegistrar

func (s *GrpcGatewayServer) HttpRegistrar() *ghttp.Server

func (*GrpcGatewayServer) Start

func (s *GrpcGatewayServer) Start(ctx context.Context) error

func (*GrpcGatewayServer) Stop

func (s *GrpcGatewayServer) Stop(ctx context.Context) error

type Logger

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

func (*Logger) Log

func (l *Logger) Log(level log.Level, keyvals ...interface{}) error

type Scope

type Scope = func(*gorm.DB) *gorm.DB

func WithDeviceIDEq

func WithDeviceIDEq[T constraints.Integer](id T) Scope

func WithIDEq

func WithIDEq[T constraints.Ordered](id T) Scope

func WithOrder

func WithOrder(order string) Scope

func WithPageAndPageSize

func WithPageAndPageSize(page, pageSize int) Scope

func WithTimestampAfter

func WithTimestampAfter(t int64) Scope

func WithTimestampBefore

func WithTimestampBefore(t int64) Scope

type TCPHandler

type TCPHandler interface {
	ServeTcp(ctx context.Context, conn net.Conn) error
}

type TcpServer

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

func NewTcpServer

func NewTcpServer(conf *conf.TcpServer, handler TCPHandler) *TcpServer

func (*TcpServer) Endpoint

func (s *TcpServer) Endpoint() (*url.URL, error)

func (*TcpServer) Start

func (s *TcpServer) Start(ctx context.Context) error

func (*TcpServer) Stop

func (s *TcpServer) Stop(ctx context.Context) error