types

package

Go to main page

Versions in this module

v1

v1.0.9-beta.1

Mar 16, 2026

v1.0.8

Nov 26, 2025

Changes in this version

type GrpcClient

+ MaxPoolConnections int

+ func (gc *GrpcClient) GetMaxPoolConnectionsPerAddress() int

type IGrpcClient

+ GetMaxPoolConnectionsPerAddress func() int

+ type IGrpcServiceClientPool interface

+ SetConnectionPool func([]*grpc.ClientConn)

+ type IGrpcServiceClientSingle interface

+ SetConnection func(*grpc.ClientConn)

v1.0.7

Nov 18, 2025

Changes in this version

+ const MONGODB_CONNECT_TIMEOUT

+ const MONGODB_MAX_CONN_IDLE_TIME

+ const MONGODB_MAX_POOL_SIZE

+ const MONGODB_MAX_RETRIES

+ const MONGODB_MIN_POOL_SIZE

+ const MONGODB_SERVER_SELECTION_TIMEOUT

+ const MONGODB_SOCKET_TIMEOUT

+ const MYSQL_CONN_MAX_LIFETIME

+ const MYSQL_MAX_IDLE_CONNS

+ const MYSQL_MAX_OPEN_CONNS

+ const MYSQL_MAX_RETRIES

+ const REDIS_DIAL_TIMEOUT

+ const REDIS_MAX_RETRIES

+ const REDIS_MIN_IDLE_CONNS

+ const REDIS_POOL_SIZE

+ const REDIS_POOL_TIMEOUT

+ const REDIS_READ_TIMEOUT

+ const REDIS_WRITE_TIMEOUT

v1.0.6

Nov 14, 2025

v1.0.5

Nov 14, 2025

retracted

Changes in this version

+ type ISystemInfo interface

+ EnableNetworkInfo func() bool

+ EnableReplicaInfo func() bool

+ EnableStartupBanner func() bool

+ EnableVerboseNetworkInfo func() bool

v1.0.4

Nov 14, 2025

retracted

Changes in this version

type IMongoDB

+ GetConnectTimeout func() int

+ GetMaxConnIdleTime func() int

+ GetMaxPoolSize func() uint64

+ GetMaxRetries func() int

+ GetMinPoolSize func() uint64

+ GetServerSelectionTimeout func() int

+ GetSocketTimeout func() int

type IMySQL

+ GetConnMaxLifetime func() int

+ GetMaxIdleConns func() int

+ GetMaxOpenConns func() int

+ GetMaxRetries func() int

type IRedis

+ GetDialTimeout func() int

+ GetMaxRetries func() int

+ GetMinIdleConns func() int

+ GetPoolSize func() int

+ GetPoolTimeout func() int

+ GetReadTimeout func() int

+ GetWriteTimeout func() int

type MongoDB

+ func (r *MongoDB) GetConnectTimeout() int

+ func (r *MongoDB) GetMaxConnIdleTime() int

+ func (r *MongoDB) GetMaxPoolSize() uint64

+ func (r *MongoDB) GetMaxRetries() int

+ func (r *MongoDB) GetMinPoolSize() uint64

+ func (r *MongoDB) GetServerSelectionTimeout() int

+ func (r *MongoDB) GetSocketTimeout() int

type MySQL

+ func (mysql *MySQL) GetConnMaxLifetime() int

+ func (mysql *MySQL) GetMaxIdleConns() int

+ func (mysql *MySQL) GetMaxOpenConns() int

+ func (mysql *MySQL) GetMaxRetries() int

type Redis

+ func (r *Redis) GetDialTimeout() int

+ func (r *Redis) GetMaxRetries() int

+ func (r *Redis) GetMinIdleConns() int

+ func (r *Redis) GetPoolSize() int

+ func (r *Redis) GetPoolTimeout() int

+ func (r *Redis) GetReadTimeout() int

+ func (r *Redis) GetWriteTimeout() int

type SqLite

+ func (s *SqLite) GetConnMaxLifetime() int

+ func (s *SqLite) GetMaxIdleConns() int

+ func (s *SqLite) GetMaxOpenConns() int

v1.0.3

Mar 2, 2025

Changes in this version

type IRabbitMQConsumer

+ GetConcurrentCall func() int

type RabbitMQConsumer

+ ConcurrentCall int

+ func (r *RabbitMQConsumer) GetConcurrentCall() int

v1.0.2

Mar 2, 2025

v1.0.1

Mar 1, 2025

Changes in this version

+ const CALLER_RABBIT_DEBUG_EXAMPLE

+ const CALLER_RABBIT_EXCHANGE_EXAMPLE

+ const CALLER_RABBIT_NAME_EXAMPLE

+ const CLIENT_GRPC_HOST

+ const CLIENT_GRPC_NAME

+ const CLIENT_GRPC_PORT

+ const CLIENT_TCP_HOST

+ const CLIENT_TCP_MODE

+ const CLIENT_TCP_NAME

+ const CLIENT_TCP_PORT

+ const LISTEN_RABBIT_DEBUG

+ const LISTEN_RABBIT_EXCHANGE

+ const LISTEN_RABBIT_EXCHANGE_TYPE

+ const LISTEN_RABBIT_NAME

+ const LISTEN_RABBIT_QUEUE

+ const LISTEN_RABBIT_ROUTING_KEY

+ const LISTEN_RABBIT_VHOST

+ const MONGODB_DATABASE

+ const MONGODB_DSN

+ const MYSQL_DB_CHARSET

+ const MYSQL_DB_DATABASE

+ const MYSQL_DB_HOST

+ const MYSQL_DB_LOC

+ const MYSQL_DB_MIGRATION

+ const MYSQL_DB_PARSE_TIME

+ const MYSQL_DB_PASSWORD

+ const MYSQL_DB_PORT

+ const MYSQL_DB_USERNAME

+ const RABBIT_HOST

+ const RABBIT_PASSWORD

+ const RABBIT_PORT

+ const RABBIT_USERNAME

+ const RABBIT_VHOST

+ const REDIS_DATABASE

+ const REDIS_HOST

+ const REDIS_PASSWORD

+ const REDIS_PORT

+ const REDIS_USERNAME

+ const RQ_HOST

+ const RQ_PASSWORD

+ const RQ_PORT

+ const RQ_USERNAME

+ const RQ_VHOST

+ const SERVER_GRPC_PORT

+ const SERVER_HTTP_MODE

+ const SERVER_HTTP_PORT

+ const SERVER_TCP_MODE

+ const SERVER_TCP_PORT

+ const SERVER_WS_MODE

+ const SERVER_WS_PORT

+ var ErrCantCreate = errors.New("cant create")

+ var ErrNotImplemented = errors.New("not implemented function")

+ type Engine interface

+ Call func(string, *Event)

+ Event func(string, func(*Event))

+ type Environment struct

+ Debug string

+ Name string

+ func (e *Environment) GetDebug() string

+ func (e *Environment) GetName() string

+ type Event struct

+ Body IRabbitBody

+ CorrelationId string

+ Data interface{}

+ Debug bool

+ Exchange string

+ Name string

+ ReplyTo IReplyTo

+ RoutingKey string

+ func (m *Event) GetBody() []byte

+ func (m *Event) GetCorrelationId() string

+ func (m *Event) GetData() interface{}

+ func (m *Event) GetDebug() bool

+ func (m *Event) GetExchange() string

+ func (m *Event) GetName() string

+ func (m *Event) GetReplyTo() IReplyTo

+ func (m *Event) GetRoutingKey() string

+ func (m *Event) NilBody() bool

+ type GrpcClient struct

+ ClientOptions []grpc.DialOption

+ Clients []IGrpcServiceClient

+ Host string

+ Name string

+ Port string

+ func (gc *GrpcClient) GetClientOptions() []grpc.DialOption

+ func (gc *GrpcClient) GetClients() []IGrpcServiceClient

+ func (gc *GrpcClient) GetHost() string

+ func (gc *GrpcClient) GetName() string

+ func (gc *GrpcClient) GetPort() string

+ type GrpcConfig struct

+ Clients []IGrpcClient

+ Server IGrpcServer

+ func (g *GrpcConfig) GetClients() []IGrpcClient

+ func (g *GrpcConfig) GetServer() IGrpcServer

+ type GrpcServer struct

+ Port string

+ Router func(*grpc.Server)

+ ServerOptions []grpc.ServerOption

+ func (g *GrpcServer) GetPort() string

+ func (g *GrpcServer) GetRouter() func(*grpc.Server)

+ func (g *GrpcServer) GetServerOptions() []grpc.ServerOption

+ type HttpServer struct

+ Gzip bool

+ Middleware func(*gin.Engine)

+ Mode string

+ Port string

+ Router func(*gin.Engine)

+ func (hs *HttpServer) GetGzip() bool

+ func (hs *HttpServer) GetMiddleware() func(*gin.Engine)

+ func (hs *HttpServer) GetMode() string

+ func (hs *HttpServer) GetPort() string

+ func (hs *HttpServer) GetRouter() func(*gin.Engine)

+ type IEnvironment interface

+ GetDebug func() string

+ GetName func() string

+ type IEvent interface

+ GetBody func() []byte

+ GetCorrelationId func() string

+ GetData func() interface{}

+ GetDebug func() bool

+ GetExchange func() string

+ GetName func() string

+ GetReplyTo func() IReplyTo

+ GetRoutingKey func() string

+ type IFrameworkRabbitMQPublisher interface

+ Publish func(IEvent) error

+ type IGrpcClient interface

+ GetClientOptions func() []grpc.DialOption

+ GetClients func() []IGrpcServiceClient

+ GetHost func() string

+ GetName func() string

+ GetPort func() string

+ type IGrpcConfig interface

+ GetClients func() []IGrpcClient

+ GetServer func() IGrpcServer

+ type IGrpcServer interface

+ GetPort func() string

+ GetRouter func() func(*grpc.Server)

+ GetServerOptions func() []grpc.ServerOption

+ type IGrpcServiceClient interface

+ SetConnection func(*grpc.ClientConn)

+ type IHttpServer interface

+ GetGzip func() bool

+ GetMiddleware func() func(*gin.Engine)

+ GetMode func() string

+ GetPort func() string

+ GetRouter func() func(*gin.Engine)

+ type IMongoDB interface

+ GetDatabase func() string

+ GetDsn func() string

+ GetRepositories func() []IMongoDBRepository

+ type IMongoDBRepository interface

+ SetDriver func(*mongo.Database)

+ type IMySQL interface

+ DebugMode func() bool

+ GetCharset func() string

+ GetDatabase func() string

+ GetDisableNestedTransaction func() bool

+ GetDsn func() string

+ GetHost func() string

+ GetLoc func() string

+ GetParseTime func() string

+ GetPassword func() string

+ GetPort func() string

+ GetQueryFields func() bool

+ GetRepositories func() []IMySQLRepository

+ GetUsername func() string

+ Migration func() bool

+ type IMySQLRepository interface

+ SetDriver func(*gorm.DB, *sync.RWMutex)

+ type IRabbitBody interface

+ GetData func() interface{}

+ GetEvent func() string

+ SetData func(interface{})

+ SetEvent func(string)

+ Setup func()

+ type IRabbitMQConfig interface

+ GetServers func() []IRabbitMQServer

+ type IRabbitMQConsumer interface

+ GenerateReplyTo func() ReplyTo

+ GetBody func() IRabbitBody

+ GetDebug func() bool

+ GetExchange func() string

+ GetExchangeType func() string

+ GetListener func() func(Engine)

+ GetName func() string

+ GetPrefetchCount func() int

+ GetPrefetchSize func() int

+ GetQueue func() string

+ GetRoutingKey func() string

+ type IRabbitMQDsn interface

+ GetHost func() string

+ GetPassword func() string

+ GetPort func() string

+ GetUsername func() string

+ GetVirtualHost func() string

+ type IRabbitMQPublisher interface

+ GetClients func() []IRabbitMQServiceClient

+ GetName func() string

+ type IRabbitMQServer interface

+ GetAutoAck func() bool

+ GetConsumers func() []IRabbitMQConsumer

+ GetHost func() string

+ GetPassword func() string

+ GetPort func() string

+ GetPublishers func() []IRabbitMQPublisher

+ GetUsername func() string

+ GetVHost func() string

+ type IRabbitMQServiceClient interface

+ SetConnection func(IFrameworkRabbitMQPublisher)

+ type IRedis interface

+ GetDatabase func() int

+ GetDsn func() string

+ GetHost func() string

+ GetPassword func() string

+ GetPort func() string

+ GetRepositories func() []IRedisRepository

+ GetUsername func() string

+ type IRedisRepository interface

+ SetDriver func(*redis.Client)

+ type IReplyTo interface

+ Get func() string

+ SetRoutingKey func(string)

+ type ITcpClient interface

+ GetClients func() []ITcpServiceClient

+ GetHost func() string

+ GetMode func() string

+ GetName func() string

+ GetPort func() string

+ type ITcpConfig interface

+ GetClients func() []ITcpClient

+ GetServers func() []ITcpServer

+ type ITcpServer interface

+ GetHandler func() ITcpServiceHandler

+ GetMode func() string

+ GetPort func() string

+ type ITcpServiceClient interface

+ OnConnect func()

+ OnDisconnect func()

+ type ITcpServiceHandler interface

+ OnConnect func()

+ OnDisconnect func()

+ type IWebSocketBody interface

+ GetAction func() string

+ GetData func() interface{}

+ SetAction func(string)

+ SetData func(interface{})

+ Setup func()

+ type IWebSocketEvent interface

+ GetBody func() []byte

+ GetConnection func() *websocket.Conn

+ GetData func() interface{}

+ GetDebug func() bool

+ GetName func() string

+ type IWebSocketEventHandler interface

+ Call func(string, IWebSocketEvent)

+ Event func(string, func(IWebSocketEvent))

+ type IWebSocketRoute interface

+ Initialize func(*gin.Engine, bool)

+ type IWebSocketServer interface

+ GetMode func() string

+ GetPort func() string

+ GetRoutes func() []IWebSocketRoute

+ type IdentityNetwork struct

+ Hostname []string

+ IPV4 []net.IP

+ IPV6 []net.IP

+ NetInterface []string

+ type IdentityService struct

+ Author string

+ Description string

+ Layer string

+ Name string

+ ServiceDns string

+ type IdentitySource struct

+ Documentation string

+ Repository string

+ type MongoDB struct

+ Database string

+ Dsn string

+ Repositories []IMongoDBRepository

+ func (r *MongoDB) GetDatabase() string

+ func (r *MongoDB) GetDsn() string

+ func (r *MongoDB) GetRepositories() []IMongoDBRepository

+ type MySQL struct

+ Charset string

+ DB *sql.DB

+ Database string

+ Debug bool

+ DisableNestedTransaction bool

+ EnableMigration bool

+ Gorm *gorm.DB

+ Host string

+ Loc string

+ ParseTime string

+ Password string

+ Port string

+ QueryFields bool

+ Repositories []IMySQLRepository

+ Username string

+ func (mysql *MySQL) DebugMode() bool

+ func (mysql *MySQL) GetCharset() string

+ func (mysql *MySQL) GetDatabase() string

+ func (mysql *MySQL) GetDisableNestedTransaction() bool

+ func (mysql *MySQL) GetDsn() string

+ func (mysql *MySQL) GetHost() string

+ func (mysql *MySQL) GetLoc() string

+ func (mysql *MySQL) GetParseTime() string

+ func (mysql *MySQL) GetPassword() string

+ func (mysql *MySQL) GetPort() string

+ func (mysql *MySQL) GetQueryFields() bool

+ func (mysql *MySQL) GetRepositories() []IMySQLRepository

+ func (mysql *MySQL) GetUsername() string

+ func (mysql *MySQL) Migration() bool

+ type RabbitBody struct

+ Data interface{}

+ Event string

+ Payload interface{}

+ func (rb *RabbitBody) GetData() interface{}

+ func (rb *RabbitBody) GetEvent() string

+ func (rb *RabbitBody) SetData(data interface{})

+ func (rb *RabbitBody) SetEvent(event string)

+ func (rb *RabbitBody) Setup()

+ type RabbitMQConfig struct

+ Servers []IRabbitMQServer

+ func (r *RabbitMQConfig) GetServers() []IRabbitMQServer

+ type RabbitMQConsumer struct

+ CustomPayload IRabbitBody

+ Debug string

+ Exchange string

+ ExchangeType string

+ Listener func(Engine)

+ Name string

+ PrefetchCount int

+ PrefetchSize int

+ Queue string

+ RoutingKey string

+ func (r *RabbitMQConsumer) GenerateReplyTo() (replyTo ReplyTo)

+ func (r *RabbitMQConsumer) GetBody() IRabbitBody

+ func (r *RabbitMQConsumer) GetDebug() bool

+ func (r *RabbitMQConsumer) GetExchange() string

+ func (r *RabbitMQConsumer) GetExchangeType() string

+ func (r *RabbitMQConsumer) GetListener() func(Engine)

+ func (r *RabbitMQConsumer) GetName() string

+ func (r *RabbitMQConsumer) GetPrefetchCount() int

+ func (r *RabbitMQConsumer) GetPrefetchSize() int

+ func (r *RabbitMQConsumer) GetQueue() string

+ func (r *RabbitMQConsumer) GetRoutingKey() string

+ type RabbitMQDsn struct

+ Host string

+ Password string

+ Port string

+ Username string

+ VirtualHost string

+ func (rtm *RabbitMQDsn) GetHost() string

+ func (rtm *RabbitMQDsn) GetPassword() string

+ func (rtm *RabbitMQDsn) GetPort() string

+ func (rtm *RabbitMQDsn) GetUsername() string

+ func (rtm *RabbitMQDsn) GetVirtualHost() string

+ type RabbitMQPublisher struct

+ Clients []IRabbitMQServiceClient

+ Name string

+ func (r *RabbitMQPublisher) GetClients() []IRabbitMQServiceClient

+ func (r *RabbitMQPublisher) GetName() string

+ type RabbitMQServer struct

+ AutoAck bool

+ Consumers []IRabbitMQConsumer

+ Host string

+ Password string

+ Port string

+ Publishers []IRabbitMQPublisher

+ Username string

+ VirtualHost string

+ func (r *RabbitMQServer) GetAutoAck() bool

+ func (r *RabbitMQServer) GetConsumers() []IRabbitMQConsumer

+ func (r *RabbitMQServer) GetHost() string

+ func (r *RabbitMQServer) GetPassword() string

+ func (r *RabbitMQServer) GetPort() string

+ func (r *RabbitMQServer) GetPublishers() []IRabbitMQPublisher

+ func (r *RabbitMQServer) GetUsername() string

+ func (r *RabbitMQServer) GetVHost() string

+ type Redis struct

+ Database int

+ Debug bool

+ Host string

+ Password string

+ Port string

+ Repositories []IRedisRepository

+ Username string

+ func (r *Redis) DebugMode() bool

+ func (r *Redis) GetDatabase() int

+ func (r *Redis) GetDsn() string

+ func (r *Redis) GetHost() string

+ func (r *Redis) GetPassword() string

+ func (r *Redis) GetPort() string

+ func (r *Redis) GetRepositories() []IRedisRepository

+ func (r *Redis) GetUsername() string

+ type Replica struct

+ IPV4 []net.IP

+ IPV6 []net.IP

+ type ReplyTo struct

+ Exchange string

+ RoutingKey string

+ func (r *ReplyTo) Get() string

+ func (r *ReplyTo) GetJson() string

+ func (r *ReplyTo) SetRoutingKey(routingKey string)

+ type Repository struct

+ Con *sql.DB

+ DB *gorm.DB

+ DbName string

+ Mu *sync.RWMutex

+ Table string

+ func (tbl *Repository) DatabaseName() string

+ func (tbl *Repository) SetDriver(db *gorm.DB, mu *sync.RWMutex)

+ func (tbl *Repository) TableName() string

+ type Response struct

+ Code int

+ Message string

+ Status string

+ type SqLite struct

+ DBPath string

+ Debug bool

+ DisableNestedTransaction bool

+ EnableMigration bool

+ QueryFields bool

+ Repositories []IMySQLRepository

+ type TcpClient struct

+ Clients []ITcpServiceClient

+ Host string

+ Mode string

+ Name string

+ Port string

+ func (tcp *TcpClient) GetClients() []ITcpServiceClient

+ func (tcp *TcpClient) GetHost() string

+ func (tcp *TcpClient) GetMode() string

+ func (tcp *TcpClient) GetName() string

+ func (tcp *TcpClient) GetPort() string

+ type TcpConfig struct

+ Clients []ITcpClient

+ Servers []ITcpServer

+ func (tcp *TcpConfig) GetClients() []ITcpClient

+ func (tcp *TcpConfig) GetServers() []ITcpServer

+ type TcpServer struct

+ Handler ITcpServiceHandler

+ Mode string

+ Port string

+ func (tcp *TcpServer) GetHandler() ITcpServiceHandler

+ func (ts *TcpServer) GetMode() string

+ func (ts *TcpServer) GetPort() string

+ type WebSocketBody struct

+ Action string

+ Data interface{}

+ func (wsb *WebSocketBody) GetAction() string

+ func (wsb *WebSocketBody) GetData() interface{}

+ func (wsb *WebSocketBody) SetAction(action string)

+ func (wsb *WebSocketBody) SetData(data interface{})

+ func (wsb *WebSocketBody) Setup()

+ type WebSocketEvent struct

+ Body IWebSocketBody

+ Connection *websocket.Conn

+ Data interface{}

+ Debug bool

+ Name string

+ func (m *WebSocketEvent) GetBody() []byte

+ func (m *WebSocketEvent) GetConnection() *websocket.Conn

+ func (m *WebSocketEvent) GetData() interface{}

+ func (m *WebSocketEvent) GetDebug() bool

+ func (m *WebSocketEvent) GetName() string

+ func (m *WebSocketEvent) NilBody() bool

+ type WebSocketEventHandler struct

+ Debug bool

+ func (me *WebSocketEventHandler) Call(name string, event IWebSocketEvent)

+ func (me *WebSocketEventHandler) Event(name string, handler func(IWebSocketEvent))

+ type WebSocketRoute struct

+ CustomPayload IWebSocketBody

+ Handlers func(IWebSocketEventHandler)

+ Path string

+ func (wsr *WebSocketRoute) Initialize(server *gin.Engine, debug bool)

+ func (wsr *WebSocketRoute) SetupHandler()

+ type WebSocketServer struct

+ Mode string

+ Port string

+ Routes []IWebSocketRoute

+ func (wss *WebSocketServer) GetMode() string

+ func (wss *WebSocketServer) GetPort() string

+ func (wss *WebSocketServer) GetRoutes() []IWebSocketRoute

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL