Documentation ¶
Index ¶
- Constants
- Variables
- type ArpcClientRegistry
- type ArpcServerRegistry
- type BotRegistry
- type CacheRegistry
- type CasBinRegistry
- type ConfigRegistry
- type CrontabRegistry
- type ErlangNodeRegistry
- type GrpcRegistry
- type JwtRegistry
- type LanguageRegistry
- type LockerRegistry
- type MemoryServiceRegistry
- type MetricsRegistry
- type QueueRegistry
- type RabbitMqServiceRegistry
- func (r *RabbitMqServiceRegistry) Get(name string) (t T)
- func (r *RabbitMqServiceRegistry) GetAll() (m map[string]T)
- func (r *RabbitMqServiceRegistry) IsRegistered(name string) bool
- func (r *RabbitMqServiceRegistry) Register(name string, v T) error
- func (r *RabbitMqServiceRegistry) Unregister(name string)
- type RiakRegistry
- type RocketMqServiceRegistry
- func (r *RocketMqServiceRegistry) Get(name string) (t T)
- func (r *RocketMqServiceRegistry) GetAll() (m map[string]T)
- func (r *RocketMqServiceRegistry) IsRegistered(name string) bool
- func (r *RocketMqServiceRegistry) Register(name string, v T) error
- func (r *RocketMqServiceRegistry) Unregister(name string)
- type SenderRegistry
- type ServerRegistry
- type StateRegistry
- type TaskServiceRegistry
- type TusRegistry
- type WebSocketRegistry
Constants ¶
View Source
const (
Default = "default"
)
Variables ¶
View Source
var (
ErrDup = errors.New("registry: duplicate object")
)
Functions ¶
This section is empty.
Types ¶
type ArpcClientRegistry ¶ added in v2.0.89
type ArpcClientRegistry struct {
// contains filtered or unexported fields
}
func (*ArpcClientRegistry) Get ¶ added in v2.0.89
func (r *ArpcClientRegistry) Get(name string) (t T)
func (*ArpcClientRegistry) GetAll ¶ added in v2.0.89
func (r *ArpcClientRegistry) GetAll() (m map[string]T)
func (*ArpcClientRegistry) IsRegistered ¶ added in v2.0.89
func (*ArpcClientRegistry) Unregister ¶ added in v2.0.89
func (r *ArpcClientRegistry) Unregister(name string)
type ArpcServerRegistry ¶ added in v2.0.89
type ArpcServerRegistry struct {
// contains filtered or unexported fields
}
func (*ArpcServerRegistry) Get ¶ added in v2.0.89
func (r *ArpcServerRegistry) Get(name string) (t T)
func (*ArpcServerRegistry) GetAll ¶ added in v2.0.89
func (r *ArpcServerRegistry) GetAll() (m map[string]T)
func (*ArpcServerRegistry) IsRegistered ¶ added in v2.0.89
func (*ArpcServerRegistry) Unregister ¶ added in v2.0.89
func (r *ArpcServerRegistry) Unregister(name string)
type BotRegistry ¶
type BotRegistry struct {
// contains filtered or unexported fields
}
func (*BotRegistry) IsRegistered ¶
func (*BotRegistry) Unregister ¶
func (r *BotRegistry) Unregister(name string)
type CacheRegistry ¶
type CacheRegistry struct {
// contains filtered or unexported fields
}
func (*CacheRegistry) IsRegistered ¶
func (*CacheRegistry) Unregister ¶
func (r *CacheRegistry) Unregister(name string)
type CasBinRegistry ¶
type CasBinRegistry struct {
// contains filtered or unexported fields
}
func (*CasBinRegistry) IsRegistered ¶
func (*CasBinRegistry) Unregister ¶
func (r *CasBinRegistry) Unregister(name string)
type ConfigRegistry ¶
type ConfigRegistry struct {
// contains filtered or unexported fields
}
func (*ConfigRegistry) IsRegistered ¶
func (*ConfigRegistry) Unregister ¶
func (r *ConfigRegistry) Unregister(name string)
type CrontabRegistry ¶
type CrontabRegistry struct {
// contains filtered or unexported fields
}
func (*CrontabRegistry) IsRegistered ¶
func (*CrontabRegistry) Unregister ¶
func (r *CrontabRegistry) Unregister(name string)
type ErlangNodeRegistry ¶ added in v2.0.36
type ErlangNodeRegistry struct {
// contains filtered or unexported fields
}
func (*ErlangNodeRegistry) Get ¶ added in v2.0.36
func (r *ErlangNodeRegistry) Get(name string) (t T)
func (*ErlangNodeRegistry) GetAll ¶ added in v2.0.36
func (r *ErlangNodeRegistry) GetAll() (m map[string]T)
func (*ErlangNodeRegistry) IsRegistered ¶ added in v2.0.36
func (*ErlangNodeRegistry) Unregister ¶ added in v2.0.36
func (r *ErlangNodeRegistry) Unregister(name string)
type GrpcRegistry ¶ added in v2.0.79
type GrpcRegistry struct {
// contains filtered or unexported fields
}
func (*GrpcRegistry) IsRegistered ¶ added in v2.0.79
func (*GrpcRegistry) Unregister ¶ added in v2.0.79
func (r *GrpcRegistry) Unregister(name string)
type JwtRegistry ¶
type JwtRegistry struct {
// contains filtered or unexported fields
}
func (*JwtRegistry) IsRegistered ¶
func (*JwtRegistry) Unregister ¶
func (r *JwtRegistry) Unregister(name string)
type LanguageRegistry ¶
type LanguageRegistry struct {
// contains filtered or unexported fields
}
func (*LanguageRegistry) IsRegistered ¶
func (*LanguageRegistry) Unregister ¶
func (r *LanguageRegistry) Unregister(name string)
type LockerRegistry ¶
type LockerRegistry struct {
// contains filtered or unexported fields
}
func (*LockerRegistry) IsRegistered ¶
func (*LockerRegistry) Unregister ¶
func (r *LockerRegistry) Unregister(name string)
type MemoryServiceRegistry ¶
type MemoryServiceRegistry struct {
// contains filtered or unexported fields
}
func (*MemoryServiceRegistry) IsRegistered ¶
func (*MemoryServiceRegistry) Unregister ¶
func (r *MemoryServiceRegistry) Unregister(name string)
type MetricsRegistry ¶
type MetricsRegistry struct {
// contains filtered or unexported fields
}
func (*MetricsRegistry) IsRegistered ¶
func (*MetricsRegistry) Unregister ¶
func (r *MetricsRegistry) Unregister(name string)
type QueueRegistry ¶
type QueueRegistry struct {
// contains filtered or unexported fields
}
func (*QueueRegistry) IsRegistered ¶
func (*QueueRegistry) Unregister ¶
func (r *QueueRegistry) Unregister(name string)
type RabbitMqServiceRegistry ¶
type RabbitMqServiceRegistry struct {
// contains filtered or unexported fields
}
func (*RabbitMqServiceRegistry) GetAll ¶
func (r *RabbitMqServiceRegistry) GetAll() (m map[string]T)
func (*RabbitMqServiceRegistry) IsRegistered ¶
func (*RabbitMqServiceRegistry) Unregister ¶
func (r *RabbitMqServiceRegistry) Unregister(name string)
type RiakRegistry ¶ added in v2.0.24
type RiakRegistry struct {
// contains filtered or unexported fields
}
func (*RiakRegistry) IsRegistered ¶ added in v2.0.24
func (*RiakRegistry) Unregister ¶ added in v2.0.24
func (r *RiakRegistry) Unregister(name string)
type RocketMqServiceRegistry ¶
type RocketMqServiceRegistry struct {
// contains filtered or unexported fields
}
func (*RocketMqServiceRegistry) GetAll ¶
func (r *RocketMqServiceRegistry) GetAll() (m map[string]T)
func (*RocketMqServiceRegistry) IsRegistered ¶
func (*RocketMqServiceRegistry) Unregister ¶
func (r *RocketMqServiceRegistry) Unregister(name string)
type SenderRegistry ¶ added in v2.0.51
type SenderRegistry struct {
// contains filtered or unexported fields
}
func (*SenderRegistry) IsRegistered ¶ added in v2.0.51
func (*SenderRegistry) Unregister ¶ added in v2.0.51
func (r *SenderRegistry) Unregister(name string)
type ServerRegistry ¶
type ServerRegistry struct {
// contains filtered or unexported fields
}
func (*ServerRegistry) IsRegistered ¶
func (*ServerRegistry) Unregister ¶
func (r *ServerRegistry) Unregister(name string)
type StateRegistry ¶ added in v2.0.46
type StateRegistry struct {
// contains filtered or unexported fields
}
func (*StateRegistry) IsRegistered ¶ added in v2.0.46
func (*StateRegistry) Unregister ¶ added in v2.0.46
func (r *StateRegistry) Unregister(name string)
type TaskServiceRegistry ¶
type TaskServiceRegistry struct {
// contains filtered or unexported fields
}
func (*TaskServiceRegistry) IsRegistered ¶
func (*TaskServiceRegistry) Unregister ¶
func (r *TaskServiceRegistry) Unregister(name string)
type TusRegistry ¶
type TusRegistry struct {
// contains filtered or unexported fields
}
func (*TusRegistry) IsRegistered ¶
func (*TusRegistry) Unregister ¶
func (r *TusRegistry) Unregister(name string)
type WebSocketRegistry ¶
type WebSocketRegistry struct {
// contains filtered or unexported fields
}
func (*WebSocketRegistry) IsRegistered ¶
func (*WebSocketRegistry) Unregister ¶
func (r *WebSocketRegistry) Unregister(name string)
Source Files ¶
- registry.go
- registry_arpc.go
- registry_bot.go
- registry_cache.go
- registry_casbin.go
- registry_config.go
- registry_crontab.go
- registry_erlang_node.go
- registry_grpc.go
- registry_jwt.go
- registry_language.go
- registry_locker.go
- registry_memory_service.go
- registry_metrics.go
- registry_multi_send.go
- registry_queue.go
- registry_rabbitmq_service.go
- registry_riak.go
- registry_rocketmq_service.go
- registry_server.go
- registry_state.go
- registry_task_service.go
- registry_tus_uploader.go
- registry_websocket.go
Click to show internal directories.
Click to hide internal directories.