Versions in this module Expand all Collapse all v1 v1.0.1 Jun 2, 2024 v1.0.0 Jun 2, 2024 Changes in this version + var File_conf_v1_kratos_conf_bootstrap_proto protoreflect.FileDescriptor + var File_conf_v1_kratos_conf_client_proto protoreflect.FileDescriptor + var File_conf_v1_kratos_conf_config_proto protoreflect.FileDescriptor + var File_conf_v1_kratos_conf_data_proto protoreflect.FileDescriptor + var File_conf_v1_kratos_conf_logger_proto protoreflect.FileDescriptor + var File_conf_v1_kratos_conf_middleware_proto protoreflect.FileDescriptor + var File_conf_v1_kratos_conf_notify_proto protoreflect.FileDescriptor + var File_conf_v1_kratos_conf_oss_proto protoreflect.FileDescriptor + var File_conf_v1_kratos_conf_registry_proto protoreflect.FileDescriptor + var File_conf_v1_kratos_conf_server_proto protoreflect.FileDescriptor + var File_conf_v1_kratos_conf_tracer_proto protoreflect.FileDescriptor + type Bootstrap struct + Client *Client + Config *RemoteConfig + Data *Data + Logger *Logger + Notify *Notification + Oss *OSS + Registry *Registry + Server *Server + Trace *Tracer + func (*Bootstrap) Descriptor() ([]byte, []int) + func (*Bootstrap) ProtoMessage() + func (x *Bootstrap) GetClient() *Client + func (x *Bootstrap) GetConfig() *RemoteConfig + func (x *Bootstrap) GetData() *Data + func (x *Bootstrap) GetLogger() *Logger + func (x *Bootstrap) GetNotify() *Notification + func (x *Bootstrap) GetOss() *OSS + func (x *Bootstrap) GetRegistry() *Registry + func (x *Bootstrap) GetServer() *Server + func (x *Bootstrap) GetTrace() *Tracer + func (x *Bootstrap) ProtoReflect() protoreflect.Message + func (x *Bootstrap) Reset() + func (x *Bootstrap) String() string + type Client struct + Grpc *Client_GRPC + Rest *Client_REST + func (*Client) Descriptor() ([]byte, []int) + func (*Client) ProtoMessage() + func (x *Client) GetGrpc() *Client_GRPC + func (x *Client) GetRest() *Client_REST + func (x *Client) ProtoReflect() protoreflect.Message + func (x *Client) Reset() + func (x *Client) String() string + type Client_GRPC struct + Middleware *Middleware + Timeout *durationpb.Duration + func (*Client_GRPC) Descriptor() ([]byte, []int) + func (*Client_GRPC) ProtoMessage() + func (x *Client_GRPC) GetMiddleware() *Middleware + func (x *Client_GRPC) GetTimeout() *durationpb.Duration + func (x *Client_GRPC) ProtoReflect() protoreflect.Message + func (x *Client_GRPC) Reset() + func (x *Client_GRPC) String() string + type Client_REST struct + Middleware *Middleware + Timeout *durationpb.Duration + func (*Client_REST) Descriptor() ([]byte, []int) + func (*Client_REST) ProtoMessage() + func (x *Client_REST) GetMiddleware() *Middleware + func (x *Client_REST) GetTimeout() *durationpb.Duration + func (x *Client_REST) ProtoReflect() protoreflect.Message + func (x *Client_REST) Reset() + func (x *Client_REST) String() string + type Data struct + Cassandra *Data_Cassandra + Clickhouse *Data_ClickHouse + Database *Data_Database + Doris *Data_Doris + ElasticSearch *Data_ElasticSearch + Influxdb *Data_InfluxDB + Kafka *Data_Kafka + Mongodb *Data_MongoDB + Redis *Data_Redis + func (*Data) Descriptor() ([]byte, []int) + func (*Data) ProtoMessage() + func (x *Data) GetCassandra() *Data_Cassandra + func (x *Data) GetClickhouse() *Data_ClickHouse + func (x *Data) GetDatabase() *Data_Database + func (x *Data) GetDoris() *Data_Doris + func (x *Data) GetElasticSearch() *Data_ElasticSearch + func (x *Data) GetInfluxdb() *Data_InfluxDB + func (x *Data) GetKafka() *Data_Kafka + func (x *Data) GetMongodb() *Data_MongoDB + func (x *Data) GetRedis() *Data_Redis + func (x *Data) ProtoReflect() protoreflect.Message + func (x *Data) Reset() + func (x *Data) String() string + type Data_Cassandra struct + Address string + ConnectTimeout *durationpb.Duration + Consistency uint32 + DisableInitialHostLookup bool + IgnorePeerAddr bool + Keyspace string + Password string + Timeout *durationpb.Duration + Username string + func (*Data_Cassandra) Descriptor() ([]byte, []int) + func (*Data_Cassandra) ProtoMessage() + func (x *Data_Cassandra) GetAddress() string + func (x *Data_Cassandra) GetConnectTimeout() *durationpb.Duration + func (x *Data_Cassandra) GetConsistency() uint32 + func (x *Data_Cassandra) GetDisableInitialHostLookup() bool + func (x *Data_Cassandra) GetIgnorePeerAddr() bool + func (x *Data_Cassandra) GetKeyspace() string + func (x *Data_Cassandra) GetPassword() string + func (x *Data_Cassandra) GetTimeout() *durationpb.Duration + func (x *Data_Cassandra) GetUsername() string + func (x *Data_Cassandra) ProtoReflect() protoreflect.Message + func (x *Data_Cassandra) Reset() + func (x *Data_Cassandra) String() string + type Data_ClickHouse struct + Address string + BlockBufferSize int32 + CompressionMethod string + ConnMaxLifeTime *durationpb.Duration + ConnOpenStrategy string + ConnectionMaxLifetime *durationpb.Duration + Database string + Debug bool + DialTimeout *durationpb.Duration + MaxCompressionBuffer int32 + MaxExecutionTime int32 + MaxIdleConnections int32 + MaxIdleConns int32 + MaxOpenConnections int32 + MaxOpenConns int32 + Password string + Protocol string + Username string + func (*Data_ClickHouse) Descriptor() ([]byte, []int) + func (*Data_ClickHouse) ProtoMessage() + func (x *Data_ClickHouse) GetAddress() string + func (x *Data_ClickHouse) GetBlockBufferSize() int32 + func (x *Data_ClickHouse) GetCompressionMethod() string + func (x *Data_ClickHouse) GetConnMaxLifeTime() *durationpb.Duration + func (x *Data_ClickHouse) GetConnOpenStrategy() string + func (x *Data_ClickHouse) GetConnectionMaxLifetime() *durationpb.Duration + func (x *Data_ClickHouse) GetDatabase() string + func (x *Data_ClickHouse) GetDebug() bool + func (x *Data_ClickHouse) GetDialTimeout() *durationpb.Duration + func (x *Data_ClickHouse) GetMaxCompressionBuffer() int32 + func (x *Data_ClickHouse) GetMaxExecutionTime() int32 + func (x *Data_ClickHouse) GetMaxIdleConnections() int32 + func (x *Data_ClickHouse) GetMaxIdleConns() int32 + func (x *Data_ClickHouse) GetMaxOpenConnections() int32 + func (x *Data_ClickHouse) GetMaxOpenConns() int32 + func (x *Data_ClickHouse) GetPassword() string + func (x *Data_ClickHouse) GetProtocol() string + func (x *Data_ClickHouse) GetUsername() string + func (x *Data_ClickHouse) ProtoReflect() protoreflect.Message + func (x *Data_ClickHouse) Reset() + func (x *Data_ClickHouse) String() string + type Data_Database struct + ConnectionMaxLifetime *durationpb.Duration + Debug bool + Driver string + EnableMetrics bool + EnableTrace bool + MaxIdleConnections int32 + MaxOpenConnections int32 + Migrate bool + Source string + func (*Data_Database) Descriptor() ([]byte, []int) + func (*Data_Database) ProtoMessage() + func (x *Data_Database) GetConnectionMaxLifetime() *durationpb.Duration + func (x *Data_Database) GetDebug() bool + func (x *Data_Database) GetDriver() string + func (x *Data_Database) GetEnableMetrics() bool + func (x *Data_Database) GetEnableTrace() bool + func (x *Data_Database) GetMaxIdleConnections() int32 + func (x *Data_Database) GetMaxOpenConnections() int32 + func (x *Data_Database) GetMigrate() bool + func (x *Data_Database) GetSource() string + func (x *Data_Database) ProtoReflect() protoreflect.Message + func (x *Data_Database) Reset() + func (x *Data_Database) String() string + type Data_Doris struct + Address string + func (*Data_Doris) Descriptor() ([]byte, []int) + func (*Data_Doris) ProtoMessage() + func (x *Data_Doris) GetAddress() string + func (x *Data_Doris) ProtoReflect() protoreflect.Message + func (x *Data_Doris) Reset() + func (x *Data_Doris) String() string + type Data_ElasticSearch struct + Addresses []string + EnableGzip bool + EnableSniffer bool + HealthCheckInterval *durationpb.Duration + Password string + Username string + func (*Data_ElasticSearch) Descriptor() ([]byte, []int) + func (*Data_ElasticSearch) ProtoMessage() + func (x *Data_ElasticSearch) GetAddresses() []string + func (x *Data_ElasticSearch) GetEnableGzip() bool + func (x *Data_ElasticSearch) GetEnableSniffer() bool + func (x *Data_ElasticSearch) GetHealthCheckInterval() *durationpb.Duration + func (x *Data_ElasticSearch) GetPassword() string + func (x *Data_ElasticSearch) GetUsername() string + func (x *Data_ElasticSearch) ProtoReflect() protoreflect.Message + func (x *Data_ElasticSearch) Reset() + func (x *Data_ElasticSearch) String() string + type Data_InfluxDB struct + Address string + Bucket string + Organization string + Token string + func (*Data_InfluxDB) Descriptor() ([]byte, []int) + func (*Data_InfluxDB) ProtoMessage() + func (x *Data_InfluxDB) GetAddress() string + func (x *Data_InfluxDB) GetBucket() string + func (x *Data_InfluxDB) GetOrganization() string + func (x *Data_InfluxDB) GetToken() string + func (x *Data_InfluxDB) ProtoReflect() protoreflect.Message + func (x *Data_InfluxDB) Reset() + func (x *Data_InfluxDB) String() string + type Data_Kafka struct + Addrs []string + AllowAutoTopicCreation bool + Async bool + BatchBytes int64 + BatchSize int32 + BatchTimeout *durationpb.Duration + Codec string + ReadTimeout *durationpb.Duration + WriteTimeout *durationpb.Duration + func (*Data_Kafka) Descriptor() ([]byte, []int) + func (*Data_Kafka) ProtoMessage() + func (x *Data_Kafka) GetAddrs() []string + func (x *Data_Kafka) GetAllowAutoTopicCreation() bool + func (x *Data_Kafka) GetAsync() bool + func (x *Data_Kafka) GetBatchBytes() int64 + func (x *Data_Kafka) GetBatchSize() int32 + func (x *Data_Kafka) GetBatchTimeout() *durationpb.Duration + func (x *Data_Kafka) GetCodec() string + func (x *Data_Kafka) GetReadTimeout() *durationpb.Duration + func (x *Data_Kafka) GetWriteTimeout() *durationpb.Duration + func (x *Data_Kafka) ProtoReflect() protoreflect.Message + func (x *Data_Kafka) Reset() + func (x *Data_Kafka) String() string + type Data_MongoDB struct + Address string + Password string + Username string + func (*Data_MongoDB) Descriptor() ([]byte, []int) + func (*Data_MongoDB) ProtoMessage() + func (x *Data_MongoDB) GetAddress() string + func (x *Data_MongoDB) GetPassword() string + func (x *Data_MongoDB) GetUsername() string + func (x *Data_MongoDB) ProtoReflect() protoreflect.Message + func (x *Data_MongoDB) Reset() + func (x *Data_MongoDB) String() string + type Data_Redis struct + Addr string + Db int32 + DialTimeout *durationpb.Duration + EnableMetrics bool + EnableTracing bool + Network string + Password string + ReadTimeout *durationpb.Duration + WriteTimeout *durationpb.Duration + func (*Data_Redis) Descriptor() ([]byte, []int) + func (*Data_Redis) ProtoMessage() + func (x *Data_Redis) GetAddr() string + func (x *Data_Redis) GetDb() int32 + func (x *Data_Redis) GetDialTimeout() *durationpb.Duration + func (x *Data_Redis) GetEnableMetrics() bool + func (x *Data_Redis) GetEnableTracing() bool + func (x *Data_Redis) GetNetwork() string + func (x *Data_Redis) GetPassword() string + func (x *Data_Redis) GetReadTimeout() *durationpb.Duration + func (x *Data_Redis) GetWriteTimeout() *durationpb.Duration + func (x *Data_Redis) ProtoReflect() protoreflect.Message + func (x *Data_Redis) Reset() + func (x *Data_Redis) String() string + type Logger struct + Aliyun *Logger_Aliyun + Fluent *Logger_Fluent + Logrus *Logger_Logrus + Tencent *Logger_Tencent + Type string + Zap *Logger_Zap + func (*Logger) Descriptor() ([]byte, []int) + func (*Logger) ProtoMessage() + func (x *Logger) GetAliyun() *Logger_Aliyun + func (x *Logger) GetFluent() *Logger_Fluent + func (x *Logger) GetLogrus() *Logger_Logrus + func (x *Logger) GetTencent() *Logger_Tencent + func (x *Logger) GetType() string + func (x *Logger) GetZap() *Logger_Zap + func (x *Logger) ProtoReflect() protoreflect.Message + func (x *Logger) Reset() + func (x *Logger) String() string + type Logger_Aliyun struct + AccessKey string + AccessSecret string + Endpoint string + Project string + func (*Logger_Aliyun) Descriptor() ([]byte, []int) + func (*Logger_Aliyun) ProtoMessage() + func (x *Logger_Aliyun) GetAccessKey() string + func (x *Logger_Aliyun) GetAccessSecret() string + func (x *Logger_Aliyun) GetEndpoint() string + func (x *Logger_Aliyun) GetProject() string + func (x *Logger_Aliyun) ProtoReflect() protoreflect.Message + func (x *Logger_Aliyun) Reset() + func (x *Logger_Aliyun) String() string + type Logger_Fluent struct + Endpoint string + func (*Logger_Fluent) Descriptor() ([]byte, []int) + func (*Logger_Fluent) ProtoMessage() + func (x *Logger_Fluent) GetEndpoint() string + func (x *Logger_Fluent) ProtoReflect() protoreflect.Message + func (x *Logger_Fluent) Reset() + func (x *Logger_Fluent) String() string + type Logger_Logrus struct + DisableColors bool + DisableTimestamp bool + Formatter string + Level string + TimestampFormat string + func (*Logger_Logrus) Descriptor() ([]byte, []int) + func (*Logger_Logrus) ProtoMessage() + func (x *Logger_Logrus) GetDisableColors() bool + func (x *Logger_Logrus) GetDisableTimestamp() bool + func (x *Logger_Logrus) GetFormatter() string + func (x *Logger_Logrus) GetLevel() string + func (x *Logger_Logrus) GetTimestampFormat() string + func (x *Logger_Logrus) ProtoReflect() protoreflect.Message + func (x *Logger_Logrus) Reset() + func (x *Logger_Logrus) String() string + type Logger_Tencent struct + AccessKey string + AccessSecret string + Endpoint string + TopicId string + func (*Logger_Tencent) Descriptor() ([]byte, []int) + func (*Logger_Tencent) ProtoMessage() + func (x *Logger_Tencent) GetAccessKey() string + func (x *Logger_Tencent) GetAccessSecret() string + func (x *Logger_Tencent) GetEndpoint() string + func (x *Logger_Tencent) GetTopicId() string + func (x *Logger_Tencent) ProtoReflect() protoreflect.Message + func (x *Logger_Tencent) Reset() + func (x *Logger_Tencent) String() string + type Logger_Zap struct + Filename string + Level string + MaxAge int32 + MaxBackups int32 + MaxSize int32 + func (*Logger_Zap) Descriptor() ([]byte, []int) + func (*Logger_Zap) ProtoMessage() + func (x *Logger_Zap) GetFilename() string + func (x *Logger_Zap) GetLevel() string + func (x *Logger_Zap) GetMaxAge() int32 + func (x *Logger_Zap) GetMaxBackups() int32 + func (x *Logger_Zap) GetMaxSize() int32 + func (x *Logger_Zap) ProtoReflect() protoreflect.Message + func (x *Logger_Zap) Reset() + func (x *Logger_Zap) String() string + type Middleware struct + Auth *Middleware_Auth + EnableCircuitBreaker bool + EnableLogging bool + EnableRecovery bool + EnableTracing bool + EnableValidate bool + Limiter *Middleware_RateLimiter + Metrics *Middleware_Metrics + func (*Middleware) Descriptor() ([]byte, []int) + func (*Middleware) ProtoMessage() + func (x *Middleware) GetAuth() *Middleware_Auth + func (x *Middleware) GetEnableCircuitBreaker() bool + func (x *Middleware) GetEnableLogging() bool + func (x *Middleware) GetEnableRecovery() bool + func (x *Middleware) GetEnableTracing() bool + func (x *Middleware) GetEnableValidate() bool + func (x *Middleware) GetLimiter() *Middleware_RateLimiter + func (x *Middleware) GetMetrics() *Middleware_Metrics + func (x *Middleware) ProtoReflect() protoreflect.Message + func (x *Middleware) Reset() + func (x *Middleware) String() string + type Middleware_Auth struct + Key string + Method string + func (*Middleware_Auth) Descriptor() ([]byte, []int) + func (*Middleware_Auth) ProtoMessage() + func (x *Middleware_Auth) GetKey() string + func (x *Middleware_Auth) GetMethod() string + func (x *Middleware_Auth) ProtoReflect() protoreflect.Message + func (x *Middleware_Auth) Reset() + func (x *Middleware_Auth) String() string + type Middleware_Metrics struct + Counter bool + Gauge bool + Histogram bool + Summary bool + func (*Middleware_Metrics) Descriptor() ([]byte, []int) + func (*Middleware_Metrics) ProtoMessage() + func (x *Middleware_Metrics) GetCounter() bool + func (x *Middleware_Metrics) GetGauge() bool + func (x *Middleware_Metrics) GetHistogram() bool + func (x *Middleware_Metrics) GetSummary() bool + func (x *Middleware_Metrics) ProtoReflect() protoreflect.Message + func (x *Middleware_Metrics) Reset() + func (x *Middleware_Metrics) String() string + type Middleware_RateLimiter struct + Name string + func (*Middleware_RateLimiter) Descriptor() ([]byte, []int) + func (*Middleware_RateLimiter) ProtoMessage() + func (x *Middleware_RateLimiter) GetName() string + func (x *Middleware_RateLimiter) ProtoReflect() protoreflect.Message + func (x *Middleware_RateLimiter) Reset() + func (x *Middleware_RateLimiter) String() string + type Notification struct + Sms *Notification_SMS + func (*Notification) Descriptor() ([]byte, []int) + func (*Notification) ProtoMessage() + func (x *Notification) GetSms() *Notification_SMS + func (x *Notification) ProtoReflect() protoreflect.Message + func (x *Notification) Reset() + func (x *Notification) String() string + type Notification_SMS struct + AccessKeyId string + AccessKeySecret string + Endpoint string + RegionId string + func (*Notification_SMS) Descriptor() ([]byte, []int) + func (*Notification_SMS) ProtoMessage() + func (x *Notification_SMS) GetAccessKeyId() string + func (x *Notification_SMS) GetAccessKeySecret() string + func (x *Notification_SMS) GetEndpoint() string + func (x *Notification_SMS) GetRegionId() string + func (x *Notification_SMS) ProtoReflect() protoreflect.Message + func (x *Notification_SMS) Reset() + func (x *Notification_SMS) String() string + type OSS struct + Minio *OSS_MinIO + func (*OSS) Descriptor() ([]byte, []int) + func (*OSS) ProtoMessage() + func (x *OSS) GetMinio() *OSS_MinIO + func (x *OSS) ProtoReflect() protoreflect.Message + func (x *OSS) Reset() + func (x *OSS) String() string + type OSS_MinIO struct + AccessKey string + DownloadHost string + Endpoint string + SecretKey string + Token string + UploadHost string + UseSsl bool + func (*OSS_MinIO) Descriptor() ([]byte, []int) + func (*OSS_MinIO) ProtoMessage() + func (x *OSS_MinIO) GetAccessKey() string + func (x *OSS_MinIO) GetDownloadHost() string + func (x *OSS_MinIO) GetEndpoint() string + func (x *OSS_MinIO) GetSecretKey() string + func (x *OSS_MinIO) GetToken() string + func (x *OSS_MinIO) GetUploadHost() string + func (x *OSS_MinIO) GetUseSsl() bool + func (x *OSS_MinIO) ProtoReflect() protoreflect.Message + func (x *OSS_MinIO) Reset() + func (x *OSS_MinIO) String() string + type Registry struct + Consul *Registry_Consul + Etcd *Registry_Etcd + Eureka *Registry_Eureka + Kubernetes *Registry_Kubernetes + Nacos *Registry_Nacos + Polaris *Registry_Polaris + Servicecomb *Registry_Servicecomb + Type string + Zookeeper *Registry_ZooKeeper + func (*Registry) Descriptor() ([]byte, []int) + func (*Registry) ProtoMessage() + func (x *Registry) GetConsul() *Registry_Consul + func (x *Registry) GetEtcd() *Registry_Etcd + func (x *Registry) GetEureka() *Registry_Eureka + func (x *Registry) GetKubernetes() *Registry_Kubernetes + func (x *Registry) GetNacos() *Registry_Nacos + func (x *Registry) GetPolaris() *Registry_Polaris + func (x *Registry) GetServicecomb() *Registry_Servicecomb + func (x *Registry) GetType() string + func (x *Registry) GetZookeeper() *Registry_ZooKeeper + func (x *Registry) ProtoReflect() protoreflect.Message + func (x *Registry) Reset() + func (x *Registry) String() string + type Registry_Consul struct + Address string + HealthCheck bool + Scheme string + func (*Registry_Consul) Descriptor() ([]byte, []int) + func (*Registry_Consul) ProtoMessage() + func (x *Registry_Consul) GetAddress() string + func (x *Registry_Consul) GetHealthCheck() bool + func (x *Registry_Consul) GetScheme() string + func (x *Registry_Consul) ProtoReflect() protoreflect.Message + func (x *Registry_Consul) Reset() + func (x *Registry_Consul) String() string + type Registry_Etcd struct + Endpoints []string + func (*Registry_Etcd) Descriptor() ([]byte, []int) + func (*Registry_Etcd) ProtoMessage() + func (x *Registry_Etcd) GetEndpoints() []string + func (x *Registry_Etcd) ProtoReflect() protoreflect.Message + func (x *Registry_Etcd) Reset() + func (x *Registry_Etcd) String() string + type Registry_Eureka struct + Endpoints []string + HeartbeatInterval *durationpb.Duration + Path string + RefreshInterval *durationpb.Duration + func (*Registry_Eureka) Descriptor() ([]byte, []int) + func (*Registry_Eureka) ProtoMessage() + func (x *Registry_Eureka) GetEndpoints() []string + func (x *Registry_Eureka) GetHeartbeatInterval() *durationpb.Duration + func (x *Registry_Eureka) GetPath() string + func (x *Registry_Eureka) GetRefreshInterval() *durationpb.Duration + func (x *Registry_Eureka) ProtoReflect() protoreflect.Message + func (x *Registry_Eureka) Reset() + func (x *Registry_Eureka) String() string + type Registry_Kubernetes struct + func (*Registry_Kubernetes) Descriptor() ([]byte, []int) + func (*Registry_Kubernetes) ProtoMessage() + func (x *Registry_Kubernetes) ProtoReflect() protoreflect.Message + func (x *Registry_Kubernetes) Reset() + func (x *Registry_Kubernetes) String() string + type Registry_Nacos struct + Address string + BeatInterval *durationpb.Duration + CacheDir string + LogDir string + LogLevel string + NamespaceId string + NotLoadCacheAtStart bool + Port uint64 + Timeout *durationpb.Duration + UpdateCacheWhenEmpty bool + UpdateThreadNum int32 + func (*Registry_Nacos) Descriptor() ([]byte, []int) + func (*Registry_Nacos) ProtoMessage() + func (x *Registry_Nacos) GetAddress() string + func (x *Registry_Nacos) GetBeatInterval() *durationpb.Duration + func (x *Registry_Nacos) GetCacheDir() string + func (x *Registry_Nacos) GetLogDir() string + func (x *Registry_Nacos) GetLogLevel() string + func (x *Registry_Nacos) GetNamespaceId() string + func (x *Registry_Nacos) GetNotLoadCacheAtStart() bool + func (x *Registry_Nacos) GetPort() uint64 + func (x *Registry_Nacos) GetTimeout() *durationpb.Duration + func (x *Registry_Nacos) GetUpdateCacheWhenEmpty() bool + func (x *Registry_Nacos) GetUpdateThreadNum() int32 + func (x *Registry_Nacos) ProtoReflect() protoreflect.Message + func (x *Registry_Nacos) Reset() + func (x *Registry_Nacos) String() string + type Registry_Polaris struct + Address string + InstanceCount int32 + Namespace string + Port int32 + Service string + Token string + func (*Registry_Polaris) Descriptor() ([]byte, []int) + func (*Registry_Polaris) ProtoMessage() + func (x *Registry_Polaris) GetAddress() string + func (x *Registry_Polaris) GetInstanceCount() int32 + func (x *Registry_Polaris) GetNamespace() string + func (x *Registry_Polaris) GetPort() int32 + func (x *Registry_Polaris) GetService() string + func (x *Registry_Polaris) GetToken() string + func (x *Registry_Polaris) ProtoReflect() protoreflect.Message + func (x *Registry_Polaris) Reset() + func (x *Registry_Polaris) String() string + type Registry_Servicecomb struct + Endpoints []string + func (*Registry_Servicecomb) Descriptor() ([]byte, []int) + func (*Registry_Servicecomb) ProtoMessage() + func (x *Registry_Servicecomb) GetEndpoints() []string + func (x *Registry_Servicecomb) ProtoReflect() protoreflect.Message + func (x *Registry_Servicecomb) Reset() + func (x *Registry_Servicecomb) String() string + type Registry_ZooKeeper struct + Endpoints []string + Timeout *durationpb.Duration + func (*Registry_ZooKeeper) Descriptor() ([]byte, []int) + func (*Registry_ZooKeeper) ProtoMessage() + func (x *Registry_ZooKeeper) GetEndpoints() []string + func (x *Registry_ZooKeeper) GetTimeout() *durationpb.Duration + func (x *Registry_ZooKeeper) ProtoReflect() protoreflect.Message + func (x *Registry_ZooKeeper) Reset() + func (x *Registry_ZooKeeper) String() string + type RemoteConfig struct + Apollo *RemoteConfig_Apollo + Consul *RemoteConfig_Consul + Etcd *RemoteConfig_Etcd + Kubernetes *RemoteConfig_Kubernetes + Nacos *RemoteConfig_Nacos + Polaris *RemoteConfig_Polaris + Type string + func (*RemoteConfig) Descriptor() ([]byte, []int) + func (*RemoteConfig) ProtoMessage() + func (x *RemoteConfig) GetApollo() *RemoteConfig_Apollo + func (x *RemoteConfig) GetConsul() *RemoteConfig_Consul + func (x *RemoteConfig) GetEtcd() *RemoteConfig_Etcd + func (x *RemoteConfig) GetKubernetes() *RemoteConfig_Kubernetes + func (x *RemoteConfig) GetNacos() *RemoteConfig_Nacos + func (x *RemoteConfig) GetPolaris() *RemoteConfig_Polaris + func (x *RemoteConfig) GetType() string + func (x *RemoteConfig) ProtoReflect() protoreflect.Message + func (x *RemoteConfig) Reset() + func (x *RemoteConfig) String() string + type RemoteConfig_Apollo struct + AppId string + Cluster string + Endpoint string + Namespace string + Secret string + func (*RemoteConfig_Apollo) Descriptor() ([]byte, []int) + func (*RemoteConfig_Apollo) ProtoMessage() + func (x *RemoteConfig_Apollo) GetAppId() string + func (x *RemoteConfig_Apollo) GetCluster() string + func (x *RemoteConfig_Apollo) GetEndpoint() string + func (x *RemoteConfig_Apollo) GetNamespace() string + func (x *RemoteConfig_Apollo) GetSecret() string + func (x *RemoteConfig_Apollo) ProtoReflect() protoreflect.Message + func (x *RemoteConfig_Apollo) Reset() + func (x *RemoteConfig_Apollo) String() string + type RemoteConfig_Consul struct + Address string + Key string + Scheme string + func (*RemoteConfig_Consul) Descriptor() ([]byte, []int) + func (*RemoteConfig_Consul) ProtoMessage() + func (x *RemoteConfig_Consul) GetAddress() string + func (x *RemoteConfig_Consul) GetKey() string + func (x *RemoteConfig_Consul) GetScheme() string + func (x *RemoteConfig_Consul) ProtoReflect() protoreflect.Message + func (x *RemoteConfig_Consul) Reset() + func (x *RemoteConfig_Consul) String() string + type RemoteConfig_Etcd struct + Endpoints []string + Key string + Timeout *durationpb.Duration + func (*RemoteConfig_Etcd) Descriptor() ([]byte, []int) + func (*RemoteConfig_Etcd) ProtoMessage() + func (x *RemoteConfig_Etcd) GetEndpoints() []string + func (x *RemoteConfig_Etcd) GetKey() string + func (x *RemoteConfig_Etcd) GetTimeout() *durationpb.Duration + func (x *RemoteConfig_Etcd) ProtoReflect() protoreflect.Message + func (x *RemoteConfig_Etcd) Reset() + func (x *RemoteConfig_Etcd) String() string + type RemoteConfig_Kubernetes struct + Namespace string + func (*RemoteConfig_Kubernetes) Descriptor() ([]byte, []int) + func (*RemoteConfig_Kubernetes) ProtoMessage() + func (x *RemoteConfig_Kubernetes) GetNamespace() string + func (x *RemoteConfig_Kubernetes) ProtoReflect() protoreflect.Message + func (x *RemoteConfig_Kubernetes) Reset() + func (x *RemoteConfig_Kubernetes) String() string + type RemoteConfig_Nacos struct + Address string + Key string + Port uint64 + func (*RemoteConfig_Nacos) Descriptor() ([]byte, []int) + func (*RemoteConfig_Nacos) ProtoMessage() + func (x *RemoteConfig_Nacos) GetAddress() string + func (x *RemoteConfig_Nacos) GetKey() string + func (x *RemoteConfig_Nacos) GetPort() uint64 + func (x *RemoteConfig_Nacos) ProtoReflect() protoreflect.Message + func (x *RemoteConfig_Nacos) Reset() + func (x *RemoteConfig_Nacos) String() string + type RemoteConfig_Polaris struct + func (*RemoteConfig_Polaris) Descriptor() ([]byte, []int) + func (*RemoteConfig_Polaris) ProtoMessage() + func (x *RemoteConfig_Polaris) ProtoReflect() protoreflect.Message + func (x *RemoteConfig_Polaris) Reset() + func (x *RemoteConfig_Polaris) String() string + type Server struct + Activemq *Server_ActiveMQ + Asynq *Server_Asynq + Graphql *Server_GraphQL + Grpc *Server_GRPC + Kafka *Server_Kafka + Machinery *Server_Machinery + Mqtt *Server_Mqtt + Nats *Server_NATS + Nsq *Server_NSQ + Pulsar *Server_Pulsar + Rabbitmq *Server_RabbitMQ + Redis *Server_Redis + Rest *Server_REST + Rocketmq *Server_RocketMQ + Signalr *Server_SignalR + Socketio *Server_SocketIO + Sse *Server_SSE + Thrift *Server_Thrift + Websocket *Server_Websocket + func (*Server) Descriptor() ([]byte, []int) + func (*Server) ProtoMessage() + func (x *Server) GetActivemq() *Server_ActiveMQ + func (x *Server) GetAsynq() *Server_Asynq + func (x *Server) GetGraphql() *Server_GraphQL + func (x *Server) GetGrpc() *Server_GRPC + func (x *Server) GetKafka() *Server_Kafka + func (x *Server) GetMachinery() *Server_Machinery + func (x *Server) GetMqtt() *Server_Mqtt + func (x *Server) GetNats() *Server_NATS + func (x *Server) GetNsq() *Server_NSQ + func (x *Server) GetPulsar() *Server_Pulsar + func (x *Server) GetRabbitmq() *Server_RabbitMQ + func (x *Server) GetRedis() *Server_Redis + func (x *Server) GetRest() *Server_REST + func (x *Server) GetRocketmq() *Server_RocketMQ + func (x *Server) GetSignalr() *Server_SignalR + func (x *Server) GetSocketio() *Server_SocketIO + func (x *Server) GetSse() *Server_SSE + func (x *Server) GetThrift() *Server_Thrift + func (x *Server) GetWebsocket() *Server_Websocket + func (x *Server) ProtoReflect() protoreflect.Message + func (x *Server) Reset() + func (x *Server) String() string + type Server_ActiveMQ struct + Codec string + Endpoint string + func (*Server_ActiveMQ) Descriptor() ([]byte, []int) + func (*Server_ActiveMQ) ProtoMessage() + func (x *Server_ActiveMQ) GetCodec() string + func (x *Server_ActiveMQ) GetEndpoint() string + func (x *Server_ActiveMQ) ProtoReflect() protoreflect.Message + func (x *Server_ActiveMQ) Reset() + func (x *Server_ActiveMQ) String() string + type Server_Asynq struct + Db int32 + Endpoint string + Location string + Password string + func (*Server_Asynq) Descriptor() ([]byte, []int) + func (*Server_Asynq) ProtoMessage() + func (x *Server_Asynq) GetDb() int32 + func (x *Server_Asynq) GetEndpoint() string + func (x *Server_Asynq) GetLocation() string + func (x *Server_Asynq) GetPassword() string + func (x *Server_Asynq) ProtoReflect() protoreflect.Message + func (x *Server_Asynq) Reset() + func (x *Server_Asynq) String() string + type Server_GRPC struct + Addr string + Middleware *Middleware + Network string + Timeout *durationpb.Duration + func (*Server_GRPC) Descriptor() ([]byte, []int) + func (*Server_GRPC) ProtoMessage() + func (x *Server_GRPC) GetAddr() string + func (x *Server_GRPC) GetMiddleware() *Middleware + func (x *Server_GRPC) GetNetwork() string + func (x *Server_GRPC) GetTimeout() *durationpb.Duration + func (x *Server_GRPC) ProtoReflect() protoreflect.Message + func (x *Server_GRPC) Reset() + func (x *Server_GRPC) String() string + type Server_GraphQL struct + Addr string + Codec string + Network string + Path string + StrictSlash bool + Timeout *durationpb.Duration + func (*Server_GraphQL) Descriptor() ([]byte, []int) + func (*Server_GraphQL) ProtoMessage() + func (x *Server_GraphQL) GetAddr() string + func (x *Server_GraphQL) GetCodec() string + func (x *Server_GraphQL) GetNetwork() string + func (x *Server_GraphQL) GetPath() string + func (x *Server_GraphQL) GetStrictSlash() bool + func (x *Server_GraphQL) GetTimeout() *durationpb.Duration + func (x *Server_GraphQL) ProtoReflect() protoreflect.Message + func (x *Server_GraphQL) Reset() + func (x *Server_GraphQL) String() string + type Server_Kafka struct + Addrs []string + func (*Server_Kafka) Descriptor() ([]byte, []int) + func (*Server_Kafka) ProtoMessage() + func (x *Server_Kafka) GetAddrs() []string + func (x *Server_Kafka) ProtoReflect() protoreflect.Message + func (x *Server_Kafka) Reset() + func (x *Server_Kafka) String() string + type Server_Machinery struct + Backends []string + Brokers []string + func (*Server_Machinery) Descriptor() ([]byte, []int) + func (*Server_Machinery) ProtoMessage() + func (x *Server_Machinery) GetBackends() []string + func (x *Server_Machinery) GetBrokers() []string + func (x *Server_Machinery) ProtoReflect() protoreflect.Message + func (x *Server_Machinery) Reset() + func (x *Server_Machinery) String() string + type Server_Mqtt struct + Addr string + func (*Server_Mqtt) Descriptor() ([]byte, []int) + func (*Server_Mqtt) ProtoMessage() + func (x *Server_Mqtt) GetAddr() string + func (x *Server_Mqtt) ProtoReflect() protoreflect.Message + func (x *Server_Mqtt) Reset() + func (x *Server_Mqtt) String() string + type Server_NATS struct + Codec string + Endpoint string + func (*Server_NATS) Descriptor() ([]byte, []int) + func (*Server_NATS) ProtoMessage() + func (x *Server_NATS) GetCodec() string + func (x *Server_NATS) GetEndpoint() string + func (x *Server_NATS) ProtoReflect() protoreflect.Message + func (x *Server_NATS) Reset() + func (x *Server_NATS) String() string + type Server_NSQ struct + Codec string + Endpoint string + func (*Server_NSQ) Descriptor() ([]byte, []int) + func (*Server_NSQ) ProtoMessage() + func (x *Server_NSQ) GetCodec() string + func (x *Server_NSQ) GetEndpoint() string + func (x *Server_NSQ) ProtoReflect() protoreflect.Message + func (x *Server_NSQ) Reset() + func (x *Server_NSQ) String() string + type Server_Pulsar struct + Codec string + Endpoint string + func (*Server_Pulsar) Descriptor() ([]byte, []int) + func (*Server_Pulsar) ProtoMessage() + func (x *Server_Pulsar) GetCodec() string + func (x *Server_Pulsar) GetEndpoint() string + func (x *Server_Pulsar) ProtoReflect() protoreflect.Message + func (x *Server_Pulsar) Reset() + func (x *Server_Pulsar) String() string + type Server_REST struct + Addr string + Cors *Server_REST_CORS + EnablePprof bool + EnableSwagger bool + Middleware *Middleware + Network string + Timeout *durationpb.Duration + func (*Server_REST) Descriptor() ([]byte, []int) + func (*Server_REST) ProtoMessage() + func (x *Server_REST) GetAddr() string + func (x *Server_REST) GetCors() *Server_REST_CORS + func (x *Server_REST) GetEnablePprof() bool + func (x *Server_REST) GetEnableSwagger() bool + func (x *Server_REST) GetMiddleware() *Middleware + func (x *Server_REST) GetNetwork() string + func (x *Server_REST) GetTimeout() *durationpb.Duration + func (x *Server_REST) ProtoReflect() protoreflect.Message + func (x *Server_REST) Reset() + func (x *Server_REST) String() string + type Server_REST_CORS struct + Headers []string + Methods []string + Origins []string + func (*Server_REST_CORS) Descriptor() ([]byte, []int) + func (*Server_REST_CORS) ProtoMessage() + func (x *Server_REST_CORS) GetHeaders() []string + func (x *Server_REST_CORS) GetMethods() []string + func (x *Server_REST_CORS) GetOrigins() []string + func (x *Server_REST_CORS) ProtoReflect() protoreflect.Message + func (x *Server_REST_CORS) Reset() + func (x *Server_REST_CORS) String() string + type Server_RabbitMQ struct + Addrs []string + func (*Server_RabbitMQ) Descriptor() ([]byte, []int) + func (*Server_RabbitMQ) ProtoMessage() + func (x *Server_RabbitMQ) GetAddrs() []string + func (x *Server_RabbitMQ) ProtoReflect() protoreflect.Message + func (x *Server_RabbitMQ) Reset() + func (x *Server_RabbitMQ) String() string + type Server_Redis struct + Codec string + Endpoint string + func (*Server_Redis) Descriptor() ([]byte, []int) + func (*Server_Redis) ProtoMessage() + func (x *Server_Redis) GetCodec() string + func (x *Server_Redis) GetEndpoint() string + func (x *Server_Redis) ProtoReflect() protoreflect.Message + func (x *Server_Redis) Reset() + func (x *Server_Redis) String() string + type Server_RocketMQ struct + AccessKey string + Codec string + EnableTrace bool + GroupName string + InstanceName string + NameServerDomain string + NameServers []string + Namespace string + SecretKey string + SecurityToken string + Version string + func (*Server_RocketMQ) Descriptor() ([]byte, []int) + func (*Server_RocketMQ) ProtoMessage() + func (x *Server_RocketMQ) GetAccessKey() string + func (x *Server_RocketMQ) GetCodec() string + func (x *Server_RocketMQ) GetEnableTrace() bool + func (x *Server_RocketMQ) GetGroupName() string + func (x *Server_RocketMQ) GetInstanceName() string + func (x *Server_RocketMQ) GetNameServerDomain() string + func (x *Server_RocketMQ) GetNameServers() []string + func (x *Server_RocketMQ) GetNamespace() string + func (x *Server_RocketMQ) GetSecretKey() string + func (x *Server_RocketMQ) GetSecurityToken() string + func (x *Server_RocketMQ) GetVersion() string + func (x *Server_RocketMQ) ProtoReflect() protoreflect.Message + func (x *Server_RocketMQ) Reset() + func (x *Server_RocketMQ) String() string + type Server_SSE struct + Addr string + AutoReply bool + AutoStream bool + Codec string + EncodeBase64 bool + EventTtl *durationpb.Duration + Network string + Path string + SplitData bool + Timeout *durationpb.Duration + func (*Server_SSE) Descriptor() ([]byte, []int) + func (*Server_SSE) ProtoMessage() + func (x *Server_SSE) GetAddr() string + func (x *Server_SSE) GetAutoReply() bool + func (x *Server_SSE) GetAutoStream() bool + func (x *Server_SSE) GetCodec() string + func (x *Server_SSE) GetEncodeBase64() bool + func (x *Server_SSE) GetEventTtl() *durationpb.Duration + func (x *Server_SSE) GetNetwork() string + func (x *Server_SSE) GetPath() string + func (x *Server_SSE) GetSplitData() bool + func (x *Server_SSE) GetTimeout() *durationpb.Duration + func (x *Server_SSE) ProtoReflect() protoreflect.Message + func (x *Server_SSE) Reset() + func (x *Server_SSE) String() string + type Server_SignalR struct + Addr string + ChanReceiveTimeout *durationpb.Duration + Codec string + Debug bool + KeepAliveInterval *durationpb.Duration + Network string + StreamBufferCapacity uint32 + func (*Server_SignalR) Descriptor() ([]byte, []int) + func (*Server_SignalR) ProtoMessage() + func (x *Server_SignalR) GetAddr() string + func (x *Server_SignalR) GetChanReceiveTimeout() *durationpb.Duration + func (x *Server_SignalR) GetCodec() string + func (x *Server_SignalR) GetDebug() bool + func (x *Server_SignalR) GetKeepAliveInterval() *durationpb.Duration + func (x *Server_SignalR) GetNetwork() string + func (x *Server_SignalR) GetStreamBufferCapacity() uint32 + func (x *Server_SignalR) ProtoReflect() protoreflect.Message + func (x *Server_SignalR) Reset() + func (x *Server_SignalR) String() string + type Server_SocketIO struct + Addr string + Codec string + Network string + Path string + func (*Server_SocketIO) Descriptor() ([]byte, []int) + func (*Server_SocketIO) ProtoMessage() + func (x *Server_SocketIO) GetAddr() string + func (x *Server_SocketIO) GetCodec() string + func (x *Server_SocketIO) GetNetwork() string + func (x *Server_SocketIO) GetPath() string + func (x *Server_SocketIO) ProtoReflect() protoreflect.Message + func (x *Server_SocketIO) Reset() + func (x *Server_SocketIO) String() string + type Server_Thrift struct + Addr string + BufferSize bool + Buffered bool + Framed bool + Network string + Protocol string + func (*Server_Thrift) Descriptor() ([]byte, []int) + func (*Server_Thrift) ProtoMessage() + func (x *Server_Thrift) GetAddr() string + func (x *Server_Thrift) GetBufferSize() bool + func (x *Server_Thrift) GetBuffered() bool + func (x *Server_Thrift) GetFramed() bool + func (x *Server_Thrift) GetNetwork() string + func (x *Server_Thrift) GetProtocol() string + func (x *Server_Thrift) ProtoReflect() protoreflect.Message + func (x *Server_Thrift) Reset() + func (x *Server_Thrift) String() string + type Server_Websocket struct + Addr string + Codec string + Network string + Path string + Timeout *durationpb.Duration + func (*Server_Websocket) Descriptor() ([]byte, []int) + func (*Server_Websocket) ProtoMessage() + func (x *Server_Websocket) GetAddr() string + func (x *Server_Websocket) GetCodec() string + func (x *Server_Websocket) GetNetwork() string + func (x *Server_Websocket) GetPath() string + func (x *Server_Websocket) GetTimeout() *durationpb.Duration + func (x *Server_Websocket) ProtoReflect() protoreflect.Message + func (x *Server_Websocket) Reset() + func (x *Server_Websocket) String() string + type Tracer struct + Batcher string + Endpoint string + Env string + Insecure bool + Sampler float64 + func (*Tracer) Descriptor() ([]byte, []int) + func (*Tracer) ProtoMessage() + func (x *Tracer) GetBatcher() string + func (x *Tracer) GetEndpoint() string + func (x *Tracer) GetEnv() string + func (x *Tracer) GetInsecure() bool + func (x *Tracer) GetSampler() float64 + func (x *Tracer) ProtoReflect() protoreflect.Message + func (x *Tracer) Reset() + func (x *Tracer) String() string
Go to main page