utils

Documentation

Index

• func ForceColor() bool
• func GetEnvFiles(root string) ([]string, error)
• func GetRand[T any](s []T) (v T)
• func NewDiscoveryGrpcConn(ctx context.Context, conf *Backend, d registry.Discovery) (*grpc.ClientConn, error)
• func NewEtcdGrpcConn(ctx context.Context, conf *EtcdBackend) (*grpc.ClientConn, error)
• func NewSignalGrpcConn(ctx context.Context, conf *Backend) (*grpc.ClientConn, error)
• type Backend
• type EtcdBackend
• type GrpcGatewayServer
  • func NewGrpcGatewayServer(config *conf.GrpcServer) *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 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 ForceColor

func ForceColor() bool

func GetEnvFiles

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

func GetRand

func GetRand[T any](s []T) (v T)

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 NewSignalGrpcConn

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

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.GrpcServer) *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 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