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[T constraints.Integer](page, pageSize T) Scope
  • func WithTimestampAfter(t int64) Scope
  • func WithTimestampBefore(t int64) Scope
  • func WithUserIDEq(id string) 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[T constraints.Integer](page, pageSize T) Scope

func WithTimestampAfter

func WithTimestampAfter(t int64) Scope

func WithTimestampBefore

func WithTimestampBefore(t int64) Scope

func WithUserIDEq

func WithUserIDEq(id string) 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