v1

package
v0.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 30, 2024 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_conf_v1_kratos_conf_bootstrap_proto protoreflect.FileDescriptor
View Source 
var File_conf_v1_kratos_conf_client_proto protoreflect.FileDescriptor
View Source 
var File_conf_v1_kratos_conf_config_proto protoreflect.FileDescriptor
View Source 
var File_conf_v1_kratos_conf_data_proto protoreflect.FileDescriptor
View Source 
var File_conf_v1_kratos_conf_logger_proto protoreflect.FileDescriptor
View Source 
var File_conf_v1_kratos_conf_middleware_proto protoreflect.FileDescriptor
View Source 
var File_conf_v1_kratos_conf_notify_proto protoreflect.FileDescriptor
View Source 
var File_conf_v1_kratos_conf_oss_proto protoreflect.FileDescriptor
View Source 
var File_conf_v1_kratos_conf_registry_proto protoreflect.FileDescriptor
View Source 
var File_conf_v1_kratos_conf_server_proto protoreflect.FileDescriptor
View Source 
var File_conf_v1_kratos_conf_tracer_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Bootstrap 

type Bootstrap struct {
	Server   *Server       `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"`
	Client   *Client       `protobuf:"bytes,2,opt,name=client,proto3" json:"client,omitempty"`
	Data     *Data         `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	Trace    *Tracer       `protobuf:"bytes,4,opt,name=trace,proto3" json:"trace,omitempty"`
	Logger   *Logger       `protobuf:"bytes,5,opt,name=logger,proto3" json:"logger,omitempty"`
	Registry *Registry     `protobuf:"bytes,6,opt,name=registry,proto3" json:"registry,omitempty"`
	Config   *RemoteConfig `protobuf:"bytes,7,opt,name=config,proto3" json:"config,omitempty"`
	Oss      *OSS          `protobuf:"bytes,8,opt,name=oss,proto3" json:"oss,omitempty"`
	Notify   *Notification `protobuf:"bytes,9,opt,name=notify,proto3" json:"notify,omitempty"`
	// contains filtered or unexported fields
}

引导信息

func (*Bootstrap) Descriptor deprecated 

func (*Bootstrap) Descriptor() ([]byte, []int)

Deprecated: Use Bootstrap.ProtoReflect.Descriptor instead.

func (*Bootstrap) GetClient 

func (x *Bootstrap) GetClient() *Client

func (*Bootstrap) GetConfig 

func (x *Bootstrap) GetConfig() *RemoteConfig

func (*Bootstrap) GetData 

func (x *Bootstrap) GetData() *Data

func (*Bootstrap) GetLogger 

func (x *Bootstrap) GetLogger() *Logger

func (*Bootstrap) GetNotify 

func (x *Bootstrap) GetNotify() *Notification

func (*Bootstrap) GetOss 

func (x *Bootstrap) GetOss() *OSS

func (*Bootstrap) GetRegistry 

func (x *Bootstrap) GetRegistry() *Registry

func (*Bootstrap) GetServer 

func (x *Bootstrap) GetServer() *Server

func (*Bootstrap) GetTrace 

func (x *Bootstrap) GetTrace() *Tracer

func (*Bootstrap) ProtoMessage 

func (*Bootstrap) ProtoMessage()

func (*Bootstrap) ProtoReflect 

func (x *Bootstrap) ProtoReflect() protoreflect.Message

func (*Bootstrap) Reset 

func (x *Bootstrap) Reset()

func (*Bootstrap) String 

func (x *Bootstrap) String() string

type Client 

type Client struct {
	Rest *Client_REST `protobuf:"bytes,1,opt,name=rest,proto3" json:"rest,omitempty"` // REST服务
	Grpc *Client_GRPC `protobuf:"bytes,2,opt,name=grpc,proto3" json:"grpc,omitempty"` // gRPC服务
	// contains filtered or unexported fields
}

客户端

func (*Client) Descriptor deprecated 

func (*Client) Descriptor() ([]byte, []int)

Deprecated: Use Client.ProtoReflect.Descriptor instead.

func (*Client) GetGrpc 

func (x *Client) GetGrpc() *Client_GRPC

func (*Client) GetRest 

func (x *Client) GetRest() *Client_REST

func (*Client) ProtoMessage 

func (*Client) ProtoMessage()

func (*Client) ProtoReflect 

func (x *Client) ProtoReflect() protoreflect.Message

func (*Client) Reset 

func (x *Client) Reset()

func (*Client) String 

func (x *Client) String() string

type Client_GRPC 

type Client_GRPC struct {
	Timeout    *durationpb.Duration `protobuf:"bytes,1,opt,name=timeout,proto3" json:"timeout,omitempty"` // 超时时间
	Middleware *Middleware          `protobuf:"bytes,2,opt,name=middleware,proto3" json:"middleware,omitempty"`
	// contains filtered or unexported fields
}

gPRC

func (*Client_GRPC) Descriptor deprecated 

func (*Client_GRPC) Descriptor() ([]byte, []int)

Deprecated: Use Client_GRPC.ProtoReflect.Descriptor instead.

func (*Client_GRPC) GetMiddleware 

func (x *Client_GRPC) GetMiddleware() *Middleware

func (*Client_GRPC) GetTimeout 

func (x *Client_GRPC) GetTimeout() *durationpb.Duration

func (*Client_GRPC) ProtoMessage 

func (*Client_GRPC) ProtoMessage()

func (*Client_GRPC) ProtoReflect 

func (x *Client_GRPC) ProtoReflect() protoreflect.Message

func (*Client_GRPC) Reset 

func (x *Client_GRPC) Reset()

func (*Client_GRPC) String 

func (x *Client_GRPC) String() string

type Client_REST 

type Client_REST struct {
	Timeout    *durationpb.Duration `protobuf:"bytes,1,opt,name=timeout,proto3" json:"timeout,omitempty"` // 超时时间
	Middleware *Middleware          `protobuf:"bytes,2,opt,name=middleware,proto3" json:"middleware,omitempty"`
	// contains filtered or unexported fields
}

REST

func (*Client_REST) Descriptor deprecated 

func (*Client_REST) Descriptor() ([]byte, []int)

Deprecated: Use Client_REST.ProtoReflect.Descriptor instead.

func (*Client_REST) GetMiddleware 

func (x *Client_REST) GetMiddleware() *Middleware

func (*Client_REST) GetTimeout 

func (x *Client_REST) GetTimeout() *durationpb.Duration

func (*Client_REST) ProtoMessage 

func (*Client_REST) ProtoMessage()

func (*Client_REST) ProtoReflect 

func (x *Client_REST) ProtoReflect() protoreflect.Message

func (*Client_REST) Reset 

func (x *Client_REST) Reset()

func (*Client_REST) String 

func (x *Client_REST) String() string

type Data 

type Data struct {
	Database      *Data_Database      `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`                                 // 数据库DSN
	Redis         *Data_Redis         `protobuf:"bytes,10,opt,name=redis,proto3" json:"redis,omitempty"`                                      // Redis
	Mongodb       *Data_MongoDB       `protobuf:"bytes,11,opt,name=mongodb,proto3" json:"mongodb,omitempty"`                                  // MongoDB数据库
	ElasticSearch *Data_ElasticSearch `protobuf:"bytes,12,opt,name=elastic_search,json=elasticSearch,proto3" json:"elastic_search,omitempty"` // ElasticSearch数据库
	Cassandra     *Data_Cassandra     `protobuf:"bytes,13,opt,name=cassandra,proto3" json:"cassandra,omitempty"`                              // Cassandra数据库
	Clickhouse    *Data_ClickHouse    `protobuf:"bytes,20,opt,name=clickhouse,proto3" json:"clickhouse,omitempty"`                            // ClickHouse数据库
	Influxdb      *Data_InfluxDB      `protobuf:"bytes,21,opt,name=influxdb,proto3" json:"influxdb,omitempty"`                                // InfluxDB数据库
	Doris         *Data_Doris         `protobuf:"bytes,22,opt,name=doris,proto3" json:"doris,omitempty"`                                      // Doris数据库
	Kafka         *Data_Kafka         `protobuf:"bytes,30,opt,name=kafka,proto3" json:"kafka,omitempty"`                                      // Kafka服务
	// contains filtered or unexported fields
}

数据

func (*Data) Descriptor deprecated 

func (*Data) Descriptor() ([]byte, []int)

Deprecated: Use Data.ProtoReflect.Descriptor instead.

func (*Data) GetCassandra 

func (x *Data) GetCassandra() *Data_Cassandra

func (*Data) GetClickhouse 

func (x *Data) GetClickhouse() *Data_ClickHouse

func (*Data) GetDatabase 

func (x *Data) GetDatabase() *Data_Database

func (*Data) GetDoris 

func (x *Data) GetDoris() *Data_Doris

func (*Data) GetElasticSearch 

func (x *Data) GetElasticSearch() *Data_ElasticSearch

func (*Data) GetInfluxdb 

func (x *Data) GetInfluxdb() *Data_InfluxDB

func (*Data) GetKafka 

func (x *Data) GetKafka() *Data_Kafka

func (*Data) GetMongodb 

func (x *Data) GetMongodb() *Data_MongoDB

func (*Data) GetRedis 

func (x *Data) GetRedis() *Data_Redis

func (*Data) ProtoMessage 

func (*Data) ProtoMessage()

func (*Data) ProtoReflect 

func (x *Data) ProtoReflect() protoreflect.Message

func (*Data) Reset 

func (x *Data) Reset()

func (*Data) String 

func (x *Data) String() string

type Data_Cassandra 

type Data_Cassandra struct {
	Address                  string               `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Username                 string               `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	Password                 string               `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	Keyspace                 string               `protobuf:"bytes,5,opt,name=keyspace,proto3" json:"keyspace,omitempty"`
	ConnectTimeout           *durationpb.Duration `protobuf:"bytes,6,opt,name=connect_timeout,json=connectTimeout,proto3" json:"connect_timeout,omitempty"`
	Timeout                  *durationpb.Duration `protobuf:"bytes,7,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Consistency              uint32               `protobuf:"varint,8,opt,name=consistency,proto3" json:"consistency,omitempty"`
	DisableInitialHostLookup bool                 `` /* 138-byte string literal not displayed */
	IgnorePeerAddr           bool                 `protobuf:"varint,10,opt,name=ignore_peer_addr,json=ignorePeerAddr,proto3" json:"ignore_peer_addr,omitempty"`
	// contains filtered or unexported fields
}

func (*Data_Cassandra) Descriptor deprecated 

func (*Data_Cassandra) Descriptor() ([]byte, []int)

Deprecated: Use Data_Cassandra.ProtoReflect.Descriptor instead.

func (*Data_Cassandra) GetAddress 

func (x *Data_Cassandra) GetAddress() string

func (*Data_Cassandra) GetConnectTimeout 

func (x *Data_Cassandra) GetConnectTimeout() *durationpb.Duration

func (*Data_Cassandra) GetConsistency 

func (x *Data_Cassandra) GetConsistency() uint32

func (*Data_Cassandra) GetDisableInitialHostLookup 

func (x *Data_Cassandra) GetDisableInitialHostLookup() bool

func (*Data_Cassandra) GetIgnorePeerAddr 

func (x *Data_Cassandra) GetIgnorePeerAddr() bool

func (*Data_Cassandra) GetKeyspace 

func (x *Data_Cassandra) GetKeyspace() string

func (*Data_Cassandra) GetPassword 

func (x *Data_Cassandra) GetPassword() string

func (*Data_Cassandra) GetTimeout 

func (x *Data_Cassandra) GetTimeout() *durationpb.Duration

func (*Data_Cassandra) GetUsername 

func (x *Data_Cassandra) GetUsername() string

func (*Data_Cassandra) ProtoMessage 

func (*Data_Cassandra) ProtoMessage()

func (*Data_Cassandra) ProtoReflect 

func (x *Data_Cassandra) ProtoReflect() protoreflect.Message

func (*Data_Cassandra) Reset 

func (x *Data_Cassandra) Reset()

func (*Data_Cassandra) String 

func (x *Data_Cassandra) String() string

type Data_ClickHouse 

type Data_ClickHouse struct {
	Address               string               `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Database              string               `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"`
	Username              string               `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
	Password              string               `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
	Debug                 bool                 `protobuf:"varint,5,opt,name=debug,proto3" json:"debug,omitempty"`
	CompressionMethod     string               `protobuf:"bytes,6,opt,name=compression_method,json=compressionMethod,proto3" json:"compression_method,omitempty"`
	DialTimeout           *durationpb.Duration `protobuf:"bytes,7,opt,name=dial_timeout,json=dialTimeout,proto3" json:"dial_timeout,omitempty"`
	MaxExecutionTime      int32                `protobuf:"varint,8,opt,name=max_execution_time,json=maxExecutionTime,proto3" json:"max_execution_time,omitempty"`
	MaxOpenConns          int32                `protobuf:"varint,9,opt,name=max_open_conns,json=maxOpenConns,proto3" json:"max_open_conns,omitempty"`
	MaxIdleConns          int32                `protobuf:"varint,10,opt,name=max_idle_conns,json=maxIdleConns,proto3" json:"max_idle_conns,omitempty"`
	ConnMaxLifeTime       *durationpb.Duration `protobuf:"bytes,11,opt,name=conn_max_life_time,json=connMaxLifeTime,proto3" json:"conn_max_life_time,omitempty"`
	BlockBufferSize       int32                `protobuf:"varint,12,opt,name=block_buffer_size,json=blockBufferSize,proto3" json:"block_buffer_size,omitempty"`
	MaxCompressionBuffer  int32                `protobuf:"varint,13,opt,name=max_compression_buffer,json=maxCompressionBuffer,proto3" json:"max_compression_buffer,omitempty"`
	ConnOpenStrategy      string               `protobuf:"bytes,14,opt,name=conn_open_strategy,json=connOpenStrategy,proto3" json:"conn_open_strategy,omitempty"`
	MaxIdleConnections    int32                `protobuf:"varint,15,opt,name=max_idle_connections,json=maxIdleConnections,proto3" json:"max_idle_connections,omitempty"` // 连接池最大空闲连接数
	MaxOpenConnections    int32                `protobuf:"varint,16,opt,name=max_open_connections,json=maxOpenConnections,proto3" json:"max_open_connections,omitempty"` // 连接池最大打开连接数
	ConnectionMaxLifetime *durationpb.Duration ``                                                                                                                        // 连接可重用的最大时间长度
	/* 127-byte string literal not displayed */
	Protocol string `protobuf:"bytes,18,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// contains filtered or unexported fields
}

ClickHouse

func (*Data_ClickHouse) Descriptor deprecated 

func (*Data_ClickHouse) Descriptor() ([]byte, []int)

Deprecated: Use Data_ClickHouse.ProtoReflect.Descriptor instead.

func (*Data_ClickHouse) GetAddress 

func (x *Data_ClickHouse) GetAddress() string

func (*Data_ClickHouse) GetBlockBufferSize 

func (x *Data_ClickHouse) GetBlockBufferSize() int32

func (*Data_ClickHouse) GetCompressionMethod 

func (x *Data_ClickHouse) GetCompressionMethod() string

func (*Data_ClickHouse) GetConnMaxLifeTime 

func (x *Data_ClickHouse) GetConnMaxLifeTime() *durationpb.Duration

func (*Data_ClickHouse) GetConnOpenStrategy 

func (x *Data_ClickHouse) GetConnOpenStrategy() string

func (*Data_ClickHouse) GetConnectionMaxLifetime 

func (x *Data_ClickHouse) GetConnectionMaxLifetime() *durationpb.Duration

func (*Data_ClickHouse) GetDatabase 

func (x *Data_ClickHouse) GetDatabase() string

func (*Data_ClickHouse) GetDebug 

func (x *Data_ClickHouse) GetDebug() bool

func (*Data_ClickHouse) GetDialTimeout 

func (x *Data_ClickHouse) GetDialTimeout() *durationpb.Duration

func (*Data_ClickHouse) GetMaxCompressionBuffer 

func (x *Data_ClickHouse) GetMaxCompressionBuffer() int32

func (*Data_ClickHouse) GetMaxExecutionTime 

func (x *Data_ClickHouse) GetMaxExecutionTime() int32

func (*Data_ClickHouse) GetMaxIdleConnections 

func (x *Data_ClickHouse) GetMaxIdleConnections() int32

func (*Data_ClickHouse) GetMaxIdleConns 

func (x *Data_ClickHouse) GetMaxIdleConns() int32

func (*Data_ClickHouse) GetMaxOpenConnections 

func (x *Data_ClickHouse) GetMaxOpenConnections() int32

func (*Data_ClickHouse) GetMaxOpenConns 

func (x *Data_ClickHouse) GetMaxOpenConns() int32

func (*Data_ClickHouse) GetPassword 

func (x *Data_ClickHouse) GetPassword() string

func (*Data_ClickHouse) GetProtocol 

func (x *Data_ClickHouse) GetProtocol() string

func (*Data_ClickHouse) GetUsername 

func (x *Data_ClickHouse) GetUsername() string

func (*Data_ClickHouse) ProtoMessage 

func (*Data_ClickHouse) ProtoMessage()

func (*Data_ClickHouse) ProtoReflect 

func (x *Data_ClickHouse) ProtoReflect() protoreflect.Message

func (*Data_ClickHouse) Reset 

func (x *Data_ClickHouse) Reset()

func (*Data_ClickHouse) String 

func (x *Data_ClickHouse) String() string

type Data_Database 

type Data_Database struct {
	Driver                string               `protobuf:"bytes,1,opt,name=driver,proto3" json:"driver,omitempty"`                                                       // 驱动名：mysql、postgresql、mongodb、sqlite……
	Source                string               `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`                                                       // 数据源（DSN字符串）
	Migrate               bool                 `protobuf:"varint,10,opt,name=migrate,proto3" json:"migrate,omitempty"`                                                   // 数据迁移开关
	Debug                 bool                 `protobuf:"varint,11,opt,name=debug,proto3" json:"debug,omitempty"`                                                       // 调试开关
	EnableTrace           bool                 `protobuf:"varint,12,opt,name=enable_trace,json=enableTrace,proto3" json:"enable_trace,omitempty"`                        // 链路追踪开关
	EnableMetrics         bool                 `protobuf:"varint,13,opt,name=enable_metrics,json=enableMetrics,proto3" json:"enable_metrics,omitempty"`                  // 性能分析开关
	MaxIdleConnections    int32                `protobuf:"varint,20,opt,name=max_idle_connections,json=maxIdleConnections,proto3" json:"max_idle_connections,omitempty"` // 连接池最大空闲连接数
	MaxOpenConnections    int32                `protobuf:"varint,21,opt,name=max_open_connections,json=maxOpenConnections,proto3" json:"max_open_connections,omitempty"` // 连接池最大打开连接数
	ConnectionMaxLifetime *durationpb.Duration ``                                                                                                                        // 连接可重用的最大时间长度
	/* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

数据库

func (*Data_Database) Descriptor deprecated 

func (*Data_Database) Descriptor() ([]byte, []int)

Deprecated: Use Data_Database.ProtoReflect.Descriptor instead.

func (*Data_Database) GetConnectionMaxLifetime 

func (x *Data_Database) GetConnectionMaxLifetime() *durationpb.Duration

func (*Data_Database) GetDebug 

func (x *Data_Database) GetDebug() bool

func (*Data_Database) GetDriver 

func (x *Data_Database) GetDriver() string

func (*Data_Database) GetEnableMetrics 

func (x *Data_Database) GetEnableMetrics() bool

func (*Data_Database) GetEnableTrace 

func (x *Data_Database) GetEnableTrace() bool

func (*Data_Database) GetMaxIdleConnections 

func (x *Data_Database) GetMaxIdleConnections() int32

func (*Data_Database) GetMaxOpenConnections 

func (x *Data_Database) GetMaxOpenConnections() int32

func (*Data_Database) GetMigrate 

func (x *Data_Database) GetMigrate() bool

func (*Data_Database) GetSource 

func (x *Data_Database) GetSource() string

func (*Data_Database) ProtoMessage 

func (*Data_Database) ProtoMessage()

func (*Data_Database) ProtoReflect 

func (x *Data_Database) ProtoReflect() protoreflect.Message

func (*Data_Database) Reset 

func (x *Data_Database) Reset()

func (*Data_Database) String 

func (x *Data_Database) String() string

type Data_Doris 

type Data_Doris struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*Data_Doris) Descriptor deprecated 

func (*Data_Doris) Descriptor() ([]byte, []int)

Deprecated: Use Data_Doris.ProtoReflect.Descriptor instead.

func (*Data_Doris) GetAddress 

func (x *Data_Doris) GetAddress() string

func (*Data_Doris) ProtoMessage 

func (*Data_Doris) ProtoMessage()

func (*Data_Doris) ProtoReflect 

func (x *Data_Doris) ProtoReflect() protoreflect.Message

func (*Data_Doris) Reset 

func (x *Data_Doris) Reset()

func (*Data_Doris) String 

func (x *Data_Doris) String() string

type Data_ElasticSearch 

type Data_ElasticSearch struct {
	Addresses           []string             `protobuf:"bytes,1,rep,name=addresses,proto3" json:"addresses,omitempty"`
	Username            string               `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	Password            string               `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	EnableSniffer       bool                 `protobuf:"varint,4,opt,name=enable_sniffer,json=enableSniffer,proto3" json:"enable_sniffer,omitempty"`
	EnableGzip          bool                 `protobuf:"varint,5,opt,name=enable_gzip,json=enableGzip,proto3" json:"enable_gzip,omitempty"`
	HealthCheckInterval *durationpb.Duration `protobuf:"bytes,6,opt,name=health_check_interval,json=healthCheckInterval,proto3" json:"health_check_interval,omitempty"`
	// contains filtered or unexported fields
}

func (*Data_ElasticSearch) Descriptor deprecated 

func (*Data_ElasticSearch) Descriptor() ([]byte, []int)

Deprecated: Use Data_ElasticSearch.ProtoReflect.Descriptor instead.

func (*Data_ElasticSearch) GetAddresses 

func (x *Data_ElasticSearch) GetAddresses() []string

func (*Data_ElasticSearch) GetEnableGzip 

func (x *Data_ElasticSearch) GetEnableGzip() bool

func (*Data_ElasticSearch) GetEnableSniffer 

func (x *Data_ElasticSearch) GetEnableSniffer() bool

func (*Data_ElasticSearch) GetHealthCheckInterval 

func (x *Data_ElasticSearch) GetHealthCheckInterval() *durationpb.Duration

func (*Data_ElasticSearch) GetPassword 

func (x *Data_ElasticSearch) GetPassword() string

func (*Data_ElasticSearch) GetUsername 

func (x *Data_ElasticSearch) GetUsername() string

func (*Data_ElasticSearch) ProtoMessage 

func (*Data_ElasticSearch) ProtoMessage()

func (*Data_ElasticSearch) ProtoReflect 

func (x *Data_ElasticSearch) ProtoReflect() protoreflect.Message

func (*Data_ElasticSearch) Reset 

func (x *Data_ElasticSearch) Reset()

func (*Data_ElasticSearch) String 

func (x *Data_ElasticSearch) String() string

type Data_InfluxDB 

type Data_InfluxDB struct {
	Address      string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Token        string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	Organization string `protobuf:"bytes,3,opt,name=organization,proto3" json:"organization,omitempty"`
	Bucket       string `protobuf:"bytes,4,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// contains filtered or unexported fields
}

InfluxDB

func (*Data_InfluxDB) Descriptor deprecated 

func (*Data_InfluxDB) Descriptor() ([]byte, []int)

Deprecated: Use Data_InfluxDB.ProtoReflect.Descriptor instead.

func (*Data_InfluxDB) GetAddress 

func (x *Data_InfluxDB) GetAddress() string

func (*Data_InfluxDB) GetBucket 

func (x *Data_InfluxDB) GetBucket() string

func (*Data_InfluxDB) GetOrganization 

func (x *Data_InfluxDB) GetOrganization() string

func (*Data_InfluxDB) GetToken 

func (x *Data_InfluxDB) GetToken() string

func (*Data_InfluxDB) ProtoMessage 

func (*Data_InfluxDB) ProtoMessage()

func (*Data_InfluxDB) ProtoReflect 

func (x *Data_InfluxDB) ProtoReflect() protoreflect.Message

func (*Data_InfluxDB) Reset 

func (x *Data_InfluxDB) Reset()

func (*Data_InfluxDB) String 

func (x *Data_InfluxDB) String() string

type Data_Kafka 

type Data_Kafka struct {
	Addrs                  []string `protobuf:"bytes,1,rep,name=addrs,proto3" json:"addrs,omitempty"`  // 对端网络地址
	Codec                  string   `protobuf:"bytes,2,opt,name=codec,proto3" json:"codec,omitempty"`  // 编解码器
	Async                  bool     `protobuf:"varint,3,opt,name=async,proto3" json:"async,omitempty"` // 异步发送
	AllowAutoTopicCreation bool     ``                                                                 // 允许发送的时候自动创建主题
	/* 132-byte string literal not displayed */
	BatchSize    int32                `protobuf:"varint,5,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`         // 批量发送量
	BatchTimeout *durationpb.Duration `protobuf:"bytes,6,opt,name=batch_timeout,json=batchTimeout,proto3" json:"batch_timeout,omitempty"` // 批量发送超时时间
	ReadTimeout  *durationpb.Duration `protobuf:"bytes,7,opt,name=read_timeout,json=readTimeout,proto3" json:"read_timeout,omitempty"`    // 读取超时时间
	WriteTimeout *durationpb.Duration `protobuf:"bytes,8,opt,name=write_timeout,json=writeTimeout,proto3" json:"write_timeout,omitempty"` // 发送超时时间
	BatchBytes   int64                `protobuf:"varint,9,opt,name=batch_bytes,json=batchBytes,proto3" json:"batch_bytes,omitempty"`      // 批量发送字节数
	// contains filtered or unexported fields
}

Kafka

func (*Data_Kafka) Descriptor deprecated 

func (*Data_Kafka) Descriptor() ([]byte, []int)

Deprecated: Use Data_Kafka.ProtoReflect.Descriptor instead.

func (*Data_Kafka) GetAddrs 

func (x *Data_Kafka) GetAddrs() []string

func (*Data_Kafka) GetAllowAutoTopicCreation 

func (x *Data_Kafka) GetAllowAutoTopicCreation() bool

func (*Data_Kafka) GetAsync 

func (x *Data_Kafka) GetAsync() bool

func (*Data_Kafka) GetBatchBytes 

func (x *Data_Kafka) GetBatchBytes() int64

func (*Data_Kafka) GetBatchSize 

func (x *Data_Kafka) GetBatchSize() int32

func (*Data_Kafka) GetBatchTimeout 

func (x *Data_Kafka) GetBatchTimeout() *durationpb.Duration

func (*Data_Kafka) GetCodec 

func (x *Data_Kafka) GetCodec() string

func (*Data_Kafka) GetReadTimeout 

func (x *Data_Kafka) GetReadTimeout() *durationpb.Duration

func (*Data_Kafka) GetWriteTimeout 

func (x *Data_Kafka) GetWriteTimeout() *durationpb.Duration

func (*Data_Kafka) ProtoMessage 

func (*Data_Kafka) ProtoMessage()

func (*Data_Kafka) ProtoReflect 

func (x *Data_Kafka) ProtoReflect() protoreflect.Message

func (*Data_Kafka) Reset 

func (x *Data_Kafka) Reset()

func (*Data_Kafka) String 

func (x *Data_Kafka) String() string

type Data_MongoDB 

type Data_MongoDB struct {
	Address  string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Username string `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

MongoDB

func (*Data_MongoDB) Descriptor deprecated 

func (*Data_MongoDB) Descriptor() ([]byte, []int)

Deprecated: Use Data_MongoDB.ProtoReflect.Descriptor instead.

func (*Data_MongoDB) GetAddress 

func (x *Data_MongoDB) GetAddress() string

func (*Data_MongoDB) GetPassword 

func (x *Data_MongoDB) GetPassword() string

func (*Data_MongoDB) GetUsername 

func (x *Data_MongoDB) GetUsername() string

func (*Data_MongoDB) ProtoMessage 

func (*Data_MongoDB) ProtoMessage()

func (*Data_MongoDB) ProtoReflect 

func (x *Data_MongoDB) ProtoReflect() protoreflect.Message

func (*Data_MongoDB) Reset 

func (x *Data_MongoDB) Reset()

func (*Data_MongoDB) String 

func (x *Data_MongoDB) String() string

type Data_Redis 

type Data_Redis struct {
	Network       string               `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"`                                   // 网络
	Addr          string               `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`                                         // 服务端地址
	Password      string               `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`                                 // 密码
	Db            int32                `protobuf:"varint,4,opt,name=db,proto3" json:"db,omitempty"`                                            // 数据库索引
	DialTimeout   *durationpb.Duration `protobuf:"bytes,5,opt,name=dial_timeout,json=dialTimeout,proto3" json:"dial_timeout,omitempty"`        // 连接超时时间
	ReadTimeout   *durationpb.Duration `protobuf:"bytes,6,opt,name=read_timeout,json=readTimeout,proto3" json:"read_timeout,omitempty"`        // 读取超时时间
	WriteTimeout  *durationpb.Duration `protobuf:"bytes,7,opt,name=write_timeout,json=writeTimeout,proto3" json:"write_timeout,omitempty"`     // 写入超时时间
	EnableTracing bool                 `protobuf:"varint,8,opt,name=enable_tracing,json=enableTracing,proto3" json:"enable_tracing,omitempty"` // 打开链路追踪
	EnableMetrics bool                 `protobuf:"varint,9,opt,name=enable_metrics,json=enableMetrics,proto3" json:"enable_metrics,omitempty"` // 打开性能度量
	// contains filtered or unexported fields
}

redis

func (*Data_Redis) Descriptor deprecated 

func (*Data_Redis) Descriptor() ([]byte, []int)

Deprecated: Use Data_Redis.ProtoReflect.Descriptor instead.

func (*Data_Redis) GetAddr 

func (x *Data_Redis) GetAddr() string

func (*Data_Redis) GetDb 

func (x *Data_Redis) GetDb() int32

func (*Data_Redis) GetDialTimeout 

func (x *Data_Redis) GetDialTimeout() *durationpb.Duration

func (*Data_Redis) GetEnableMetrics 

func (x *Data_Redis) GetEnableMetrics() bool

func (*Data_Redis) GetEnableTracing 

func (x *Data_Redis) GetEnableTracing() bool

func (*Data_Redis) GetNetwork 

func (x *Data_Redis) GetNetwork() string

func (*Data_Redis) GetPassword 

func (x *Data_Redis) GetPassword() string

func (*Data_Redis) GetReadTimeout 

func (x *Data_Redis) GetReadTimeout() *durationpb.Duration

func (*Data_Redis) GetWriteTimeout 

func (x *Data_Redis) GetWriteTimeout() *durationpb.Duration

func (*Data_Redis) ProtoMessage 

func (*Data_Redis) ProtoMessage()

func (*Data_Redis) ProtoReflect 

func (x *Data_Redis) ProtoReflect() protoreflect.Message

func (*Data_Redis) Reset 

func (x *Data_Redis) Reset()

func (*Data_Redis) String 

func (x *Data_Redis) String() string

type Logger 

type Logger struct {
	Type    string          `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Zap     *Logger_Zap     `protobuf:"bytes,2,opt,name=zap,proto3" json:"zap,omitempty"`
	Logrus  *Logger_Logrus  `protobuf:"bytes,3,opt,name=logrus,proto3" json:"logrus,omitempty"`
	Fluent  *Logger_Fluent  `protobuf:"bytes,4,opt,name=fluent,proto3" json:"fluent,omitempty"`
	Aliyun  *Logger_Aliyun  `protobuf:"bytes,5,opt,name=aliyun,proto3" json:"aliyun,omitempty"`
	Tencent *Logger_Tencent `protobuf:"bytes,6,opt,name=tencent,proto3" json:"tencent,omitempty"`
	// contains filtered or unexported fields
}

日志

func (*Logger) Descriptor deprecated 

func (*Logger) Descriptor() ([]byte, []int)

Deprecated: Use Logger.ProtoReflect.Descriptor instead.

func (*Logger) GetAliyun 

func (x *Logger) GetAliyun() *Logger_Aliyun

func (*Logger) GetFluent 

func (x *Logger) GetFluent() *Logger_Fluent

func (*Logger) GetLogrus 

func (x *Logger) GetLogrus() *Logger_Logrus

func (*Logger) GetTencent 

func (x *Logger) GetTencent() *Logger_Tencent

func (*Logger) GetType 

func (x *Logger) GetType() string

func (*Logger) GetZap 

func (x *Logger) GetZap() *Logger_Zap

func (*Logger) ProtoMessage 

func (*Logger) ProtoMessage()

func (*Logger) ProtoReflect 

func (x *Logger) ProtoReflect() protoreflect.Message

func (*Logger) Reset 

func (x *Logger) Reset()

func (*Logger) String 

func (x *Logger) String() string

type Logger_Aliyun 

type Logger_Aliyun struct {
	Endpoint     string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`                             // 公网接入地址
	Project      string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`                               //
	AccessKey    string `protobuf:"bytes,3,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`          // 访问密钥ID
	AccessSecret string `protobuf:"bytes,4,opt,name=access_secret,json=accessSecret,proto3" json:"access_secret,omitempty"` // 访问密钥
	// contains filtered or unexported fields
}

阿里云

func (*Logger_Aliyun) Descriptor deprecated 

func (*Logger_Aliyun) Descriptor() ([]byte, []int)

Deprecated: Use Logger_Aliyun.ProtoReflect.Descriptor instead.

func (*Logger_Aliyun) GetAccessKey 

func (x *Logger_Aliyun) GetAccessKey() string

func (*Logger_Aliyun) GetAccessSecret 

func (x *Logger_Aliyun) GetAccessSecret() string

func (*Logger_Aliyun) GetEndpoint 

func (x *Logger_Aliyun) GetEndpoint() string

func (*Logger_Aliyun) GetProject 

func (x *Logger_Aliyun) GetProject() string

func (*Logger_Aliyun) ProtoMessage 

func (*Logger_Aliyun) ProtoMessage()

func (*Logger_Aliyun) ProtoReflect 

func (x *Logger_Aliyun) ProtoReflect() protoreflect.Message

func (*Logger_Aliyun) Reset 

func (x *Logger_Aliyun) Reset()

func (*Logger_Aliyun) String 

func (x *Logger_Aliyun) String() string

type Logger_Fluent 

type Logger_Fluent struct {
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"` // 公网接入地址
	// contains filtered or unexported fields
}

Fluent

func (*Logger_Fluent) Descriptor deprecated 

func (*Logger_Fluent) Descriptor() ([]byte, []int)

Deprecated: Use Logger_Fluent.ProtoReflect.Descriptor instead.

func (*Logger_Fluent) GetEndpoint 

func (x *Logger_Fluent) GetEndpoint() string

func (*Logger_Fluent) ProtoMessage 

func (*Logger_Fluent) ProtoMessage()

func (*Logger_Fluent) ProtoReflect 

func (x *Logger_Fluent) ProtoReflect() protoreflect.Message

func (*Logger_Fluent) Reset 

func (x *Logger_Fluent) Reset()

func (*Logger_Fluent) String 

func (x *Logger_Fluent) String() string

type Logger_Logrus 

type Logger_Logrus struct {
	Level            string `protobuf:"bytes,1,opt,name=level,proto3" json:"level,omitempty"`                                                // 日志等级
	Formatter        string `protobuf:"bytes,2,opt,name=formatter,proto3" json:"formatter,omitempty"`                                        // 输出格式：text, json.
	TimestampFormat  string `protobuf:"bytes,3,opt,name=timestamp_format,json=timestampFormat,proto3" json:"timestamp_format,omitempty"`     // 定义时间戳格式，例如："2006-01-02 15:04:05"
	DisableColors    bool   `protobuf:"varint,4,opt,name=disable_colors,json=disableColors,proto3" json:"disable_colors,omitempty"`          // 不需要彩色日志
	DisableTimestamp bool   `protobuf:"varint,5,opt,name=disable_timestamp,json=disableTimestamp,proto3" json:"disable_timestamp,omitempty"` // 不需要时间戳
	// contains filtered or unexported fields
}

logrus

func (*Logger_Logrus) Descriptor deprecated 

func (*Logger_Logrus) Descriptor() ([]byte, []int)

Deprecated: Use Logger_Logrus.ProtoReflect.Descriptor instead.

func (*Logger_Logrus) GetDisableColors 

func (x *Logger_Logrus) GetDisableColors() bool

func (*Logger_Logrus) GetDisableTimestamp 

func (x *Logger_Logrus) GetDisableTimestamp() bool

func (*Logger_Logrus) GetFormatter 

func (x *Logger_Logrus) GetFormatter() string

func (*Logger_Logrus) GetLevel 

func (x *Logger_Logrus) GetLevel() string

func (*Logger_Logrus) GetTimestampFormat 

func (x *Logger_Logrus) GetTimestampFormat() string

func (*Logger_Logrus) ProtoMessage 

func (*Logger_Logrus) ProtoMessage()

func (*Logger_Logrus) ProtoReflect 

func (x *Logger_Logrus) ProtoReflect() protoreflect.Message

func (*Logger_Logrus) Reset 

func (x *Logger_Logrus) Reset()

func (*Logger_Logrus) String 

func (x *Logger_Logrus) String() string

type Logger_Tencent 

type Logger_Tencent struct {
	Endpoint     string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`                             // 公网接入地址
	TopicId      string `protobuf:"bytes,2,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"`                //
	AccessKey    string `protobuf:"bytes,3,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`          // 访问密钥ID
	AccessSecret string `protobuf:"bytes,4,opt,name=access_secret,json=accessSecret,proto3" json:"access_secret,omitempty"` // 访问密钥
	// contains filtered or unexported fields
}

腾讯

func (*Logger_Tencent) Descriptor deprecated 

func (*Logger_Tencent) Descriptor() ([]byte, []int)

Deprecated: Use Logger_Tencent.ProtoReflect.Descriptor instead.

func (*Logger_Tencent) GetAccessKey 

func (x *Logger_Tencent) GetAccessKey() string

func (*Logger_Tencent) GetAccessSecret 

func (x *Logger_Tencent) GetAccessSecret() string

func (*Logger_Tencent) GetEndpoint 

func (x *Logger_Tencent) GetEndpoint() string

func (*Logger_Tencent) GetTopicId 

func (x *Logger_Tencent) GetTopicId() string

func (*Logger_Tencent) ProtoMessage 

func (*Logger_Tencent) ProtoMessage()

func (*Logger_Tencent) ProtoReflect 

func (x *Logger_Tencent) ProtoReflect() protoreflect.Message

func (*Logger_Tencent) Reset 

func (x *Logger_Tencent) Reset()

func (*Logger_Tencent) String 

func (x *Logger_Tencent) String() string

type Logger_Zap 

type Logger_Zap struct {
	Filename   string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`                        //
	Level      string `protobuf:"bytes,2,opt,name=level,proto3" json:"level,omitempty"`                              //
	MaxSize    int32  `protobuf:"varint,3,opt,name=max_size,json=maxSize,proto3" json:"max_size,omitempty"`          //
	MaxAge     int32  `protobuf:"varint,4,opt,name=max_age,json=maxAge,proto3" json:"max_age,omitempty"`             //
	MaxBackups int32  `protobuf:"varint,5,opt,name=max_backups,json=maxBackups,proto3" json:"max_backups,omitempty"` //
	// contains filtered or unexported fields
}

Zap

func (*Logger_Zap) Descriptor deprecated 

func (*Logger_Zap) Descriptor() ([]byte, []int)

Deprecated: Use Logger_Zap.ProtoReflect.Descriptor instead.

func (*Logger_Zap) GetFilename 

func (x *Logger_Zap) GetFilename() string

func (*Logger_Zap) GetLevel 

func (x *Logger_Zap) GetLevel() string

func (*Logger_Zap) GetMaxAge 

func (x *Logger_Zap) GetMaxAge() int32

func (*Logger_Zap) GetMaxBackups 

func (x *Logger_Zap) GetMaxBackups() int32

func (*Logger_Zap) GetMaxSize 

func (x *Logger_Zap) GetMaxSize() int32

func (*Logger_Zap) ProtoMessage 

func (*Logger_Zap) ProtoMessage()

func (*Logger_Zap) ProtoReflect 

func (x *Logger_Zap) ProtoReflect() protoreflect.Message

func (*Logger_Zap) Reset 

func (x *Logger_Zap) Reset()

func (*Logger_Zap) String 

func (x *Logger_Zap) String() string

type Middleware 

type Middleware struct {
	EnableLogging        bool                    `protobuf:"varint,1,opt,name=enable_logging,json=enableLogging,proto3" json:"enable_logging,omitempty"`                        // 日志开关
	EnableRecovery       bool                    `protobuf:"varint,2,opt,name=enable_recovery,json=enableRecovery,proto3" json:"enable_recovery,omitempty"`                     // 异常恢复
	EnableTracing        bool                    `protobuf:"varint,3,opt,name=enable_tracing,json=enableTracing,proto3" json:"enable_tracing,omitempty"`                        // 链路追踪开关
	EnableValidate       bool                    `protobuf:"varint,4,opt,name=enable_validate,json=enableValidate,proto3" json:"enable_validate,omitempty"`                     // 参数校验开关
	EnableCircuitBreaker bool                    `protobuf:"varint,5,opt,name=enable_circuit_breaker,json=enableCircuitBreaker,proto3" json:"enable_circuit_breaker,omitempty"` // 熔断器
	Limiter              *Middleware_RateLimiter `protobuf:"bytes,6,opt,name=limiter,proto3" json:"limiter,omitempty"`
	Metrics              *Middleware_Metrics     `protobuf:"bytes,7,opt,name=metrics,proto3" json:"metrics,omitempty"`
	Auth                 *Middleware_Auth        `protobuf:"bytes,8,opt,name=auth,proto3" json:"auth,omitempty"`
	// contains filtered or unexported fields
}

func (*Middleware) Descriptor deprecated 

func (*Middleware) Descriptor() ([]byte, []int)

Deprecated: Use Middleware.ProtoReflect.Descriptor instead.

func (*Middleware) GetAuth 

func (x *Middleware) GetAuth() *Middleware_Auth

func (*Middleware) GetEnableCircuitBreaker 

func (x *Middleware) GetEnableCircuitBreaker() bool

func (*Middleware) GetEnableLogging 

func (x *Middleware) GetEnableLogging() bool

func (*Middleware) GetEnableRecovery 

func (x *Middleware) GetEnableRecovery() bool

func (*Middleware) GetEnableTracing 

func (x *Middleware) GetEnableTracing() bool

func (*Middleware) GetEnableValidate 

func (x *Middleware) GetEnableValidate() bool

func (*Middleware) GetLimiter 

func (x *Middleware) GetLimiter() *Middleware_RateLimiter

func (*Middleware) GetMetrics 

func (x *Middleware) GetMetrics() *Middleware_Metrics

func (*Middleware) ProtoMessage 

func (*Middleware) ProtoMessage()

func (*Middleware) ProtoReflect 

func (x *Middleware) ProtoReflect() protoreflect.Message

func (*Middleware) Reset 

func (x *Middleware) Reset()

func (*Middleware) String 

func (x *Middleware) String() string

type Middleware_Auth 

type Middleware_Auth struct {
	Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"` // JWT签名的算法，支持算法：HS256
	Key    string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`       // JWT 秘钥
	// contains filtered or unexported fields
}

JWT校验

func (*Middleware_Auth) Descriptor deprecated 

func (*Middleware_Auth) Descriptor() ([]byte, []int)

Deprecated: Use Middleware_Auth.ProtoReflect.Descriptor instead.

func (*Middleware_Auth) GetKey 

func (x *Middleware_Auth) GetKey() string

func (*Middleware_Auth) GetMethod 

func (x *Middleware_Auth) GetMethod() string

func (*Middleware_Auth) ProtoMessage 

func (*Middleware_Auth) ProtoMessage()

func (*Middleware_Auth) ProtoReflect 

func (x *Middleware_Auth) ProtoReflect() protoreflect.Message

func (*Middleware_Auth) Reset 

func (x *Middleware_Auth) Reset()

func (*Middleware_Auth) String 

func (x *Middleware_Auth) String() string

type Middleware_Metrics 

type Middleware_Metrics struct {
	Histogram bool `protobuf:"varint,1,opt,name=histogram,proto3" json:"histogram,omitempty"` // 直方图
	Counter   bool `protobuf:"varint,2,opt,name=counter,proto3" json:"counter,omitempty"`     // 计数器
	Gauge     bool `protobuf:"varint,3,opt,name=gauge,proto3" json:"gauge,omitempty"`         // 仪表盘
	Summary   bool `protobuf:"varint,4,opt,name=summary,proto3" json:"summary,omitempty"`     // 摘要
	// contains filtered or unexported fields
}

性能指标

func (*Middleware_Metrics) Descriptor deprecated 

func (*Middleware_Metrics) Descriptor() ([]byte, []int)

Deprecated: Use Middleware_Metrics.ProtoReflect.Descriptor instead.

func (*Middleware_Metrics) GetCounter 

func (x *Middleware_Metrics) GetCounter() bool

func (*Middleware_Metrics) GetGauge 

func (x *Middleware_Metrics) GetGauge() bool

func (*Middleware_Metrics) GetHistogram 

func (x *Middleware_Metrics) GetHistogram() bool

func (*Middleware_Metrics) GetSummary 

func (x *Middleware_Metrics) GetSummary() bool

func (*Middleware_Metrics) ProtoMessage 

func (*Middleware_Metrics) ProtoMessage()

func (*Middleware_Metrics) ProtoReflect 

func (x *Middleware_Metrics) ProtoReflect() protoreflect.Message

func (*Middleware_Metrics) Reset 

func (x *Middleware_Metrics) Reset()

func (*Middleware_Metrics) String 

func (x *Middleware_Metrics) String() string

type Middleware_RateLimiter 

type Middleware_RateLimiter struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // 限流器名字，支持：bbr。
	// contains filtered or unexported fields
}

限流器

func (*Middleware_RateLimiter) Descriptor deprecated 

func (*Middleware_RateLimiter) Descriptor() ([]byte, []int)

Deprecated: Use Middleware_RateLimiter.ProtoReflect.Descriptor instead.

func (*Middleware_RateLimiter) GetName 

func (x *Middleware_RateLimiter) GetName() string

func (*Middleware_RateLimiter) ProtoMessage 

func (*Middleware_RateLimiter) ProtoMessage()

func (*Middleware_RateLimiter) ProtoReflect 

func (x *Middleware_RateLimiter) ProtoReflect() protoreflect.Message

func (*Middleware_RateLimiter) Reset 

func (x *Middleware_RateLimiter) Reset()

func (*Middleware_RateLimiter) String 

func (x *Middleware_RateLimiter) String() string

type Notification 

type Notification struct {
	Sms *Notification_SMS `protobuf:"bytes,1,opt,name=sms,proto3" json:"sms,omitempty"`
	// contains filtered or unexported fields
}

通知消息

func (*Notification) Descriptor deprecated 

func (*Notification) Descriptor() ([]byte, []int)

Deprecated: Use Notification.ProtoReflect.Descriptor instead.

func (*Notification) GetSms 

func (x *Notification) GetSms() *Notification_SMS

func (*Notification) ProtoMessage 

func (*Notification) ProtoMessage()

func (*Notification) ProtoReflect 

func (x *Notification) ProtoReflect() protoreflect.Message

func (*Notification) Reset 

func (x *Notification) Reset()

func (*Notification) String 

func (x *Notification) String() string

type Notification_SMS 

type Notification_SMS struct {
	Endpoint        string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`                                        // 公网接入地址
	RegionId        string `protobuf:"bytes,2,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`                        // 地域ID
	AccessKeyId     string `protobuf:"bytes,3,opt,name=access_key_id,json=accessKeyId,proto3" json:"access_key_id,omitempty"`             // 访问密钥ID
	AccessKeySecret string `protobuf:"bytes,4,opt,name=access_key_secret,json=accessKeySecret,proto3" json:"access_key_secret,omitempty"` // 访问密钥
	// contains filtered or unexported fields
}

短信

func (*Notification_SMS) Descriptor deprecated 

func (*Notification_SMS) Descriptor() ([]byte, []int)

Deprecated: Use Notification_SMS.ProtoReflect.Descriptor instead.

func (*Notification_SMS) GetAccessKeyId 

func (x *Notification_SMS) GetAccessKeyId() string

func (*Notification_SMS) GetAccessKeySecret 

func (x *Notification_SMS) GetAccessKeySecret() string

func (*Notification_SMS) GetEndpoint 

func (x *Notification_SMS) GetEndpoint() string

func (*Notification_SMS) GetRegionId 

func (x *Notification_SMS) GetRegionId() string

func (*Notification_SMS) ProtoMessage 

func (*Notification_SMS) ProtoMessage()

func (*Notification_SMS) ProtoReflect 

func (x *Notification_SMS) ProtoReflect() protoreflect.Message

func (*Notification_SMS) Reset 

func (x *Notification_SMS) Reset()

func (*Notification_SMS) String 

func (x *Notification_SMS) String() string

type OSS 

type OSS struct {
	Minio *OSS_MinIO `protobuf:"bytes,1,opt,name=minio,proto3" json:"minio,omitempty"`
	// contains filtered or unexported fields
}

func (*OSS) Descriptor deprecated 

func (*OSS) Descriptor() ([]byte, []int)

Deprecated: Use OSS.ProtoReflect.Descriptor instead.

func (*OSS) GetMinio 

func (x *OSS) GetMinio() *OSS_MinIO

func (*OSS) ProtoMessage 

func (*OSS) ProtoMessage()

func (*OSS) ProtoReflect 

func (x *OSS) ProtoReflect() protoreflect.Message

func (*OSS) Reset 

func (x *OSS) Reset()

func (*OSS) String 

func (x *OSS) String() string

type OSS_MinIO 

type OSS_MinIO struct {
	Endpoint     string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`                             // 对端端口
	AccessKey    string `protobuf:"bytes,2,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`          // 访问密钥
	SecretKey    string `protobuf:"bytes,3,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty"`          // 密钥
	Token        string `protobuf:"bytes,4,opt,name=token,proto3" json:"token,omitempty"`                                   // 令牌
	UseSsl       bool   `protobuf:"varint,5,opt,name=use_ssl,json=useSsl,proto3" json:"use_ssl,omitempty"`                  // 使用SSL
	UploadHost   string `protobuf:"bytes,6,opt,name=upload_host,json=uploadHost,proto3" json:"upload_host,omitempty"`       // 上传链接的主机名
	DownloadHost string `protobuf:"bytes,7,opt,name=download_host,json=downloadHost,proto3" json:"download_host,omitempty"` // 下载链接的主机名
	// contains filtered or unexported fields
}

MinIO

func (*OSS_MinIO) Descriptor deprecated 

func (*OSS_MinIO) Descriptor() ([]byte, []int)

Deprecated: Use OSS_MinIO.ProtoReflect.Descriptor instead.

func (*OSS_MinIO) GetAccessKey 

func (x *OSS_MinIO) GetAccessKey() string

func (*OSS_MinIO) GetDownloadHost 

func (x *OSS_MinIO) GetDownloadHost() string

func (*OSS_MinIO) GetEndpoint 

func (x *OSS_MinIO) GetEndpoint() string

func (*OSS_MinIO) GetSecretKey 

func (x *OSS_MinIO) GetSecretKey() string

func (*OSS_MinIO) GetToken 

func (x *OSS_MinIO) GetToken() string

func (*OSS_MinIO) GetUploadHost 

func (x *OSS_MinIO) GetUploadHost() string

func (*OSS_MinIO) GetUseSsl 

func (x *OSS_MinIO) GetUseSsl() bool

func (*OSS_MinIO) ProtoMessage 

func (*OSS_MinIO) ProtoMessage()

func (*OSS_MinIO) ProtoReflect 

func (x *OSS_MinIO) ProtoReflect() protoreflect.Message

func (*OSS_MinIO) Reset 

func (x *OSS_MinIO) Reset()

func (*OSS_MinIO) String 

func (x *OSS_MinIO) String() string

type Registry 

type Registry struct {
	Type        string                `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Consul      *Registry_Consul      `protobuf:"bytes,2,opt,name=consul,proto3" json:"consul,omitempty"`           // Consul
	Etcd        *Registry_Etcd        `protobuf:"bytes,3,opt,name=etcd,proto3" json:"etcd,omitempty"`               // Etcd
	Zookeeper   *Registry_ZooKeeper   `protobuf:"bytes,4,opt,name=zookeeper,proto3" json:"zookeeper,omitempty"`     // ZooKeeper
	Nacos       *Registry_Nacos       `protobuf:"bytes,5,opt,name=nacos,proto3" json:"nacos,omitempty"`             // Nacos
	Kubernetes  *Registry_Kubernetes  `protobuf:"bytes,6,opt,name=kubernetes,proto3" json:"kubernetes,omitempty"`   // Kubernetes
	Eureka      *Registry_Eureka      `protobuf:"bytes,7,opt,name=eureka,proto3" json:"eureka,omitempty"`           // Eureka
	Polaris     *Registry_Polaris     `protobuf:"bytes,8,opt,name=polaris,proto3" json:"polaris,omitempty"`         // Polaris
	Servicecomb *Registry_Servicecomb `protobuf:"bytes,9,opt,name=servicecomb,proto3" json:"servicecomb,omitempty"` // Servicecomb
	// contains filtered or unexported fields
}

注册发现中心

func (*Registry) Descriptor deprecated 

func (*Registry) Descriptor() ([]byte, []int)

Deprecated: Use Registry.ProtoReflect.Descriptor instead.

func (*Registry) GetConsul 

func (x *Registry) GetConsul() *Registry_Consul

func (*Registry) GetEtcd 

func (x *Registry) GetEtcd() *Registry_Etcd

func (*Registry) GetEureka 

func (x *Registry) GetEureka() *Registry_Eureka

func (*Registry) GetKubernetes 

func (x *Registry) GetKubernetes() *Registry_Kubernetes

func (*Registry) GetNacos 

func (x *Registry) GetNacos() *Registry_Nacos

func (*Registry) GetPolaris 

func (x *Registry) GetPolaris() *Registry_Polaris

func (*Registry) GetServicecomb 

func (x *Registry) GetServicecomb() *Registry_Servicecomb

func (*Registry) GetType 

func (x *Registry) GetType() string

func (*Registry) GetZookeeper 

func (x *Registry) GetZookeeper() *Registry_ZooKeeper

func (*Registry) ProtoMessage 

func (*Registry) ProtoMessage()

func (*Registry) ProtoReflect 

func (x *Registry) ProtoReflect() protoreflect.Message

func (*Registry) Reset 

func (x *Registry) Reset()

func (*Registry) String 

func (x *Registry) String() string

type Registry_Consul 

type Registry_Consul struct {
	Scheme      string `protobuf:"bytes,1,opt,name=scheme,proto3" json:"scheme,omitempty"`                               // 网络样式
	Address     string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`                             // 服务端地址
	HealthCheck bool   `protobuf:"varint,3,opt,name=health_check,json=healthCheck,proto3" json:"health_check,omitempty"` // 健康检查
	// contains filtered or unexported fields
}

Consul

func (*Registry_Consul) Descriptor deprecated 

func (*Registry_Consul) Descriptor() ([]byte, []int)

Deprecated: Use Registry_Consul.ProtoReflect.Descriptor instead.

func (*Registry_Consul) GetAddress 

func (x *Registry_Consul) GetAddress() string

func (*Registry_Consul) GetHealthCheck 

func (x *Registry_Consul) GetHealthCheck() bool

func (*Registry_Consul) GetScheme 

func (x *Registry_Consul) GetScheme() string

func (*Registry_Consul) ProtoMessage 

func (*Registry_Consul) ProtoMessage()

func (*Registry_Consul) ProtoReflect 

func (x *Registry_Consul) ProtoReflect() protoreflect.Message

func (*Registry_Consul) Reset 

func (x *Registry_Consul) Reset()

func (*Registry_Consul) String 

func (x *Registry_Consul) String() string

type Registry_Etcd 

type Registry_Etcd struct {
	Endpoints []string `protobuf:"bytes,1,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	// contains filtered or unexported fields
}

Etcd

func (*Registry_Etcd) Descriptor deprecated 

func (*Registry_Etcd) Descriptor() ([]byte, []int)

Deprecated: Use Registry_Etcd.ProtoReflect.Descriptor instead.

func (*Registry_Etcd) GetEndpoints 

func (x *Registry_Etcd) GetEndpoints() []string

func (*Registry_Etcd) ProtoMessage 

func (*Registry_Etcd) ProtoMessage()

func (*Registry_Etcd) ProtoReflect 

func (x *Registry_Etcd) ProtoReflect() protoreflect.Message

func (*Registry_Etcd) Reset 

func (x *Registry_Etcd) Reset()

func (*Registry_Etcd) String 

func (x *Registry_Etcd) String() string

type Registry_Eureka 

type Registry_Eureka struct {
	Endpoints         []string             `protobuf:"bytes,1,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	HeartbeatInterval *durationpb.Duration `protobuf:"bytes,2,opt,name=heartbeat_interval,json=heartbeatInterval,proto3" json:"heartbeat_interval,omitempty"`
	RefreshInterval   *durationpb.Duration `protobuf:"bytes,3,opt,name=refresh_interval,json=refreshInterval,proto3" json:"refresh_interval,omitempty"`
	Path              string               `protobuf:"bytes,4,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

Eureka

func (*Registry_Eureka) Descriptor deprecated 

func (*Registry_Eureka) Descriptor() ([]byte, []int)

Deprecated: Use Registry_Eureka.ProtoReflect.Descriptor instead.

func (*Registry_Eureka) GetEndpoints 

func (x *Registry_Eureka) GetEndpoints() []string

func (*Registry_Eureka) GetHeartbeatInterval 

func (x *Registry_Eureka) GetHeartbeatInterval() *durationpb.Duration

func (*Registry_Eureka) GetPath 

func (x *Registry_Eureka) GetPath() string

func (*Registry_Eureka) GetRefreshInterval 

func (x *Registry_Eureka) GetRefreshInterval() *durationpb.Duration

func (*Registry_Eureka) ProtoMessage 

func (*Registry_Eureka) ProtoMessage()

func (*Registry_Eureka) ProtoReflect 

func (x *Registry_Eureka) ProtoReflect() protoreflect.Message

func (*Registry_Eureka) Reset 

func (x *Registry_Eureka) Reset()

func (*Registry_Eureka) String 

func (x *Registry_Eureka) String() string

type Registry_Kubernetes 

type Registry_Kubernetes struct {
	// contains filtered or unexported fields
}

Kubernetes

func (*Registry_Kubernetes) Descriptor deprecated 

func (*Registry_Kubernetes) Descriptor() ([]byte, []int)

Deprecated: Use Registry_Kubernetes.ProtoReflect.Descriptor instead.

func (*Registry_Kubernetes) ProtoMessage 

func (*Registry_Kubernetes) ProtoMessage()

func (*Registry_Kubernetes) ProtoReflect 

func (x *Registry_Kubernetes) ProtoReflect() protoreflect.Message

func (*Registry_Kubernetes) Reset 

func (x *Registry_Kubernetes) Reset()

func (*Registry_Kubernetes) String 

func (x *Registry_Kubernetes) String() string

type Registry_Nacos 

type Registry_Nacos struct {
	Address             string               `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`                                           // 服务端地址
	Port                uint64               `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`                                                // 服务端端口
	NamespaceId         string               `protobuf:"bytes,3,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`                //
	LogLevel            string               `protobuf:"bytes,4,opt,name=log_level,json=logLevel,proto3" json:"log_level,omitempty"`                         // 日志等级
	CacheDir            string               `protobuf:"bytes,5,opt,name=cache_dir,json=cacheDir,proto3" json:"cache_dir,omitempty"`                         // 缓存目录
	LogDir              string               `protobuf:"bytes,6,opt,name=log_dir,json=logDir,proto3" json:"log_dir,omitempty"`                               // 日志目录
	UpdateThreadNum     int32                `protobuf:"varint,7,opt,name=update_thread_num,json=updateThreadNum,proto3" json:"update_thread_num,omitempty"` // 更新服务的线程数
	Timeout             *durationpb.Duration `protobuf:"bytes,8,opt,name=timeout,proto3" json:"timeout,omitempty"`                                           // http请求超时时间，单位: 毫秒
	BeatInterval        *durationpb.Duration `protobuf:"bytes,9,opt,name=beat_interval,json=beatInterval,proto3" json:"beat_interval,omitempty"`             // 心跳间隔时间，单位: 毫秒
	NotLoadCacheAtStart bool                 ``                                                                                                              // 在启动时不读取本地缓存数据，true: 不读取，false: 读取
	/* 126-byte string literal not displayed */
	UpdateCacheWhenEmpty bool `` // 当服务列表为空时是否更新本地缓存，true: 更新,false: 不更新
	/* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

Nacos

func (*Registry_Nacos) Descriptor deprecated 

func (*Registry_Nacos) Descriptor() ([]byte, []int)

Deprecated: Use Registry_Nacos.ProtoReflect.Descriptor instead.

func (*Registry_Nacos) GetAddress 

func (x *Registry_Nacos) GetAddress() string

func (*Registry_Nacos) GetBeatInterval 

func (x *Registry_Nacos) GetBeatInterval() *durationpb.Duration

func (*Registry_Nacos) GetCacheDir 

func (x *Registry_Nacos) GetCacheDir() string

func (*Registry_Nacos) GetLogDir 

func (x *Registry_Nacos) GetLogDir() string

func (*Registry_Nacos) GetLogLevel 

func (x *Registry_Nacos) GetLogLevel() string

func (*Registry_Nacos) GetNamespaceId 

func (x *Registry_Nacos) GetNamespaceId() string

func (*Registry_Nacos) GetNotLoadCacheAtStart 

func (x *Registry_Nacos) GetNotLoadCacheAtStart() bool

func (*Registry_Nacos) GetPort 

func (x *Registry_Nacos) GetPort() uint64

func (*Registry_Nacos) GetTimeout 

func (x *Registry_Nacos) GetTimeout() *durationpb.Duration

func (*Registry_Nacos) GetUpdateCacheWhenEmpty 

func (x *Registry_Nacos) GetUpdateCacheWhenEmpty() bool

func (*Registry_Nacos) GetUpdateThreadNum 

func (x *Registry_Nacos) GetUpdateThreadNum() int32

func (*Registry_Nacos) ProtoMessage 

func (*Registry_Nacos) ProtoMessage()

func (*Registry_Nacos) ProtoReflect 

func (x *Registry_Nacos) ProtoReflect() protoreflect.Message

func (*Registry_Nacos) Reset 

func (x *Registry_Nacos) Reset()

func (*Registry_Nacos) String 

func (x *Registry_Nacos) String() string

type Registry_Polaris 

type Registry_Polaris struct {
	Address       string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` // 服务端地址
	Port          int32  `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`      // 服务端端口
	InstanceCount int32  `protobuf:"varint,3,opt,name=instance_count,json=instanceCount,proto3" json:"instance_count,omitempty"`
	Namespace     string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Service       string `protobuf:"bytes,5,opt,name=service,proto3" json:"service,omitempty"`
	Token         string `protobuf:"bytes,6,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

Polaris

func (*Registry_Polaris) Descriptor deprecated 

func (*Registry_Polaris) Descriptor() ([]byte, []int)

Deprecated: Use Registry_Polaris.ProtoReflect.Descriptor instead.

func (*Registry_Polaris) GetAddress 

func (x *Registry_Polaris) GetAddress() string

func (*Registry_Polaris) GetInstanceCount 

func (x *Registry_Polaris) GetInstanceCount() int32

func (*Registry_Polaris) GetNamespace 

func (x *Registry_Polaris) GetNamespace() string

func (*Registry_Polaris) GetPort 

func (x *Registry_Polaris) GetPort() int32

func (*Registry_Polaris) GetService 

func (x *Registry_Polaris) GetService() string

func (*Registry_Polaris) GetToken 

func (x *Registry_Polaris) GetToken() string

func (*Registry_Polaris) ProtoMessage 

func (*Registry_Polaris) ProtoMessage()

func (*Registry_Polaris) ProtoReflect 

func (x *Registry_Polaris) ProtoReflect() protoreflect.Message

func (*Registry_Polaris) Reset 

func (x *Registry_Polaris) Reset()

func (*Registry_Polaris) String 

func (x *Registry_Polaris) String() string

type Registry_Servicecomb 

type Registry_Servicecomb struct {
	Endpoints []string `protobuf:"bytes,1,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	// contains filtered or unexported fields
}

Servicecomb

func (*Registry_Servicecomb) Descriptor deprecated 

func (*Registry_Servicecomb) Descriptor() ([]byte, []int)

Deprecated: Use Registry_Servicecomb.ProtoReflect.Descriptor instead.

func (*Registry_Servicecomb) GetEndpoints 

func (x *Registry_Servicecomb) GetEndpoints() []string

func (*Registry_Servicecomb) ProtoMessage 

func (*Registry_Servicecomb) ProtoMessage()

func (*Registry_Servicecomb) ProtoReflect 

func (x *Registry_Servicecomb) ProtoReflect() protoreflect.Message

func (*Registry_Servicecomb) Reset 

func (x *Registry_Servicecomb) Reset()

func (*Registry_Servicecomb) String 

func (x *Registry_Servicecomb) String() string

type Registry_ZooKeeper 

type Registry_ZooKeeper struct {
	Endpoints []string             `protobuf:"bytes,1,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	Timeout   *durationpb.Duration `protobuf:"bytes,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

ZooKeeper

func (*Registry_ZooKeeper) Descriptor deprecated 

func (*Registry_ZooKeeper) Descriptor() ([]byte, []int)

Deprecated: Use Registry_ZooKeeper.ProtoReflect.Descriptor instead.

func (*Registry_ZooKeeper) GetEndpoints 

func (x *Registry_ZooKeeper) GetEndpoints() []string

func (*Registry_ZooKeeper) GetTimeout 

func (x *Registry_ZooKeeper) GetTimeout() *durationpb.Duration

func (*Registry_ZooKeeper) ProtoMessage 

func (*Registry_ZooKeeper) ProtoMessage()

func (*Registry_ZooKeeper) ProtoReflect 

func (x *Registry_ZooKeeper) ProtoReflect() protoreflect.Message

func (*Registry_ZooKeeper) Reset 

func (x *Registry_ZooKeeper) Reset()

func (*Registry_ZooKeeper) String 

func (x *Registry_ZooKeeper) String() string

type RemoteConfig 

type RemoteConfig struct {
	Type       string                   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Etcd       *RemoteConfig_Etcd       `protobuf:"bytes,2,opt,name=etcd,proto3" json:"etcd,omitempty"`
	Consul     *RemoteConfig_Consul     `protobuf:"bytes,3,opt,name=consul,proto3" json:"consul,omitempty"`
	Nacos      *RemoteConfig_Nacos      `protobuf:"bytes,4,opt,name=nacos,proto3" json:"nacos,omitempty"`
	Apollo     *RemoteConfig_Apollo     `protobuf:"bytes,6,opt,name=apollo,proto3" json:"apollo,omitempty"`
	Kubernetes *RemoteConfig_Kubernetes `protobuf:"bytes,7,opt,name=kubernetes,proto3" json:"kubernetes,omitempty"`
	Polaris    *RemoteConfig_Polaris    `protobuf:"bytes,8,opt,name=polaris,proto3" json:"polaris,omitempty"`
	// contains filtered or unexported fields
}

配置服务

func (*RemoteConfig) Descriptor deprecated 

func (*RemoteConfig) Descriptor() ([]byte, []int)

Deprecated: Use RemoteConfig.ProtoReflect.Descriptor instead.

func (*RemoteConfig) GetApollo 

func (x *RemoteConfig) GetApollo() *RemoteConfig_Apollo

func (*RemoteConfig) GetConsul 

func (x *RemoteConfig) GetConsul() *RemoteConfig_Consul

func (*RemoteConfig) GetEtcd 

func (x *RemoteConfig) GetEtcd() *RemoteConfig_Etcd

func (*RemoteConfig) GetKubernetes 

func (x *RemoteConfig) GetKubernetes() *RemoteConfig_Kubernetes

func (*RemoteConfig) GetNacos 

func (x *RemoteConfig) GetNacos() *RemoteConfig_Nacos

func (*RemoteConfig) GetPolaris 

func (x *RemoteConfig) GetPolaris() *RemoteConfig_Polaris

func (*RemoteConfig) GetType 

func (x *RemoteConfig) GetType() string

func (*RemoteConfig) ProtoMessage 

func (*RemoteConfig) ProtoMessage()

func (*RemoteConfig) ProtoReflect 

func (x *RemoteConfig) ProtoReflect() protoreflect.Message

func (*RemoteConfig) Reset 

func (x *RemoteConfig) Reset()

func (*RemoteConfig) String 

func (x *RemoteConfig) String() string

type RemoteConfig_Apollo 

type RemoteConfig_Apollo struct {
	Endpoint  string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	AppId     string `protobuf:"bytes,2,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	Cluster   string `protobuf:"bytes,3,opt,name=cluster,proto3" json:"cluster,omitempty"`
	Namespace string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Secret    string `protobuf:"bytes,5,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoteConfig_Apollo) Descriptor deprecated 

func (*RemoteConfig_Apollo) Descriptor() ([]byte, []int)

Deprecated: Use RemoteConfig_Apollo.ProtoReflect.Descriptor instead.

func (*RemoteConfig_Apollo) GetAppId 

func (x *RemoteConfig_Apollo) GetAppId() string

func (*RemoteConfig_Apollo) GetCluster 

func (x *RemoteConfig_Apollo) GetCluster() string

func (*RemoteConfig_Apollo) GetEndpoint 

func (x *RemoteConfig_Apollo) GetEndpoint() string

func (*RemoteConfig_Apollo) GetNamespace 

func (x *RemoteConfig_Apollo) GetNamespace() string

func (*RemoteConfig_Apollo) GetSecret 

func (x *RemoteConfig_Apollo) GetSecret() string

func (*RemoteConfig_Apollo) ProtoMessage 

func (*RemoteConfig_Apollo) ProtoMessage()

func (*RemoteConfig_Apollo) ProtoReflect 

func (x *RemoteConfig_Apollo) ProtoReflect() protoreflect.Message

func (*RemoteConfig_Apollo) Reset 

func (x *RemoteConfig_Apollo) Reset()

func (*RemoteConfig_Apollo) String 

func (x *RemoteConfig_Apollo) String() string

type RemoteConfig_Consul 

type RemoteConfig_Consul struct {
	Scheme  string `protobuf:"bytes,1,opt,name=scheme,proto3" json:"scheme,omitempty"`   // 网络样式
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` // 服务端地址
	Key     string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`         //
	// contains filtered or unexported fields
}

func (*RemoteConfig_Consul) Descriptor deprecated 

func (*RemoteConfig_Consul) Descriptor() ([]byte, []int)

Deprecated: Use RemoteConfig_Consul.ProtoReflect.Descriptor instead.

func (*RemoteConfig_Consul) GetAddress 

func (x *RemoteConfig_Consul) GetAddress() string

func (*RemoteConfig_Consul) GetKey 

func (x *RemoteConfig_Consul) GetKey() string

func (*RemoteConfig_Consul) GetScheme 

func (x *RemoteConfig_Consul) GetScheme() string

func (*RemoteConfig_Consul) ProtoMessage 

func (*RemoteConfig_Consul) ProtoMessage()

func (*RemoteConfig_Consul) ProtoReflect 

func (x *RemoteConfig_Consul) ProtoReflect() protoreflect.Message

func (*RemoteConfig_Consul) Reset 

func (x *RemoteConfig_Consul) Reset()

func (*RemoteConfig_Consul) String 

func (x *RemoteConfig_Consul) String() string

type RemoteConfig_Etcd 

type RemoteConfig_Etcd struct {
	Endpoints []string             `protobuf:"bytes,1,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	Timeout   *durationpb.Duration `protobuf:"bytes,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Key       string               `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"` //
	// contains filtered or unexported fields
}

func (*RemoteConfig_Etcd) Descriptor deprecated 

func (*RemoteConfig_Etcd) Descriptor() ([]byte, []int)

Deprecated: Use RemoteConfig_Etcd.ProtoReflect.Descriptor instead.

func (*RemoteConfig_Etcd) GetEndpoints 

func (x *RemoteConfig_Etcd) GetEndpoints() []string

func (*RemoteConfig_Etcd) GetKey 

func (x *RemoteConfig_Etcd) GetKey() string

func (*RemoteConfig_Etcd) GetTimeout 

func (x *RemoteConfig_Etcd) GetTimeout() *durationpb.Duration

func (*RemoteConfig_Etcd) ProtoMessage 

func (*RemoteConfig_Etcd) ProtoMessage()

func (*RemoteConfig_Etcd) ProtoReflect 

func (x *RemoteConfig_Etcd) ProtoReflect() protoreflect.Message

func (*RemoteConfig_Etcd) Reset 

func (x *RemoteConfig_Etcd) Reset()

func (*RemoteConfig_Etcd) String 

func (x *RemoteConfig_Etcd) String() string

type RemoteConfig_Kubernetes 

type RemoteConfig_Kubernetes struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoteConfig_Kubernetes) Descriptor deprecated 

func (*RemoteConfig_Kubernetes) Descriptor() ([]byte, []int)

Deprecated: Use RemoteConfig_Kubernetes.ProtoReflect.Descriptor instead.

func (*RemoteConfig_Kubernetes) GetNamespace 

func (x *RemoteConfig_Kubernetes) GetNamespace() string

func (*RemoteConfig_Kubernetes) ProtoMessage 

func (*RemoteConfig_Kubernetes) ProtoMessage()

func (*RemoteConfig_Kubernetes) ProtoReflect 

func (x *RemoteConfig_Kubernetes) ProtoReflect() protoreflect.Message

func (*RemoteConfig_Kubernetes) Reset 

func (x *RemoteConfig_Kubernetes) Reset()

func (*RemoteConfig_Kubernetes) String 

func (x *RemoteConfig_Kubernetes) String() string

type RemoteConfig_Nacos 

type RemoteConfig_Nacos struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` // 服务端地址
	Port    uint64 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`      // 服务端端口
	Key     string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`         //
	// contains filtered or unexported fields
}

func (*RemoteConfig_Nacos) Descriptor deprecated 

func (*RemoteConfig_Nacos) Descriptor() ([]byte, []int)

Deprecated: Use RemoteConfig_Nacos.ProtoReflect.Descriptor instead.

func (*RemoteConfig_Nacos) GetAddress 

func (x *RemoteConfig_Nacos) GetAddress() string

func (*RemoteConfig_Nacos) GetKey 

func (x *RemoteConfig_Nacos) GetKey() string

func (*RemoteConfig_Nacos) GetPort 

func (x *RemoteConfig_Nacos) GetPort() uint64

func (*RemoteConfig_Nacos) ProtoMessage 

func (*RemoteConfig_Nacos) ProtoMessage()

func (*RemoteConfig_Nacos) ProtoReflect 

func (x *RemoteConfig_Nacos) ProtoReflect() protoreflect.Message

func (*RemoteConfig_Nacos) Reset 

func (x *RemoteConfig_Nacos) Reset()

func (*RemoteConfig_Nacos) String 

func (x *RemoteConfig_Nacos) String() string

type RemoteConfig_Polaris 

type RemoteConfig_Polaris struct {
	// contains filtered or unexported fields
}

func (*RemoteConfig_Polaris) Descriptor deprecated 

func (*RemoteConfig_Polaris) Descriptor() ([]byte, []int)

Deprecated: Use RemoteConfig_Polaris.ProtoReflect.Descriptor instead.

func (*RemoteConfig_Polaris) ProtoMessage 

func (*RemoteConfig_Polaris) ProtoMessage()

func (*RemoteConfig_Polaris) ProtoReflect 

func (x *RemoteConfig_Polaris) ProtoReflect() protoreflect.Message

func (*RemoteConfig_Polaris) Reset 

func (x *RemoteConfig_Polaris) Reset()

func (*RemoteConfig_Polaris) String 

func (x *RemoteConfig_Polaris) String() string

type Server 

type Server struct {
	Rest      *Server_REST      `protobuf:"bytes,1,opt,name=rest,proto3" json:"rest,omitempty"`            // REST服务
	Grpc      *Server_GRPC      `protobuf:"bytes,2,opt,name=grpc,proto3" json:"grpc,omitempty"`            // gRPC服务
	Graphql   *Server_GraphQL   `protobuf:"bytes,3,opt,name=graphql,proto3" json:"graphql,omitempty"`      // GraphQL服务
	Thrift    *Server_Thrift    `protobuf:"bytes,4,opt,name=thrift,proto3" json:"thrift,omitempty"`        // Thrift服务
	Mqtt      *Server_Mqtt      `protobuf:"bytes,10,opt,name=mqtt,proto3" json:"mqtt,omitempty"`           // MQTT服务
	Kafka     *Server_Kafka     `protobuf:"bytes,11,opt,name=kafka,proto3" json:"kafka,omitempty"`         // Kafka服务
	Rabbitmq  *Server_RabbitMQ  `protobuf:"bytes,12,opt,name=rabbitmq,proto3" json:"rabbitmq,omitempty"`   // RabbitMQ服务
	Activemq  *Server_ActiveMQ  `protobuf:"bytes,13,opt,name=activemq,proto3" json:"activemq,omitempty"`   // ActiveMQ
	Nats      *Server_NATS      `protobuf:"bytes,14,opt,name=nats,proto3" json:"nats,omitempty"`           // NATS
	Nsq       *Server_NSQ       `protobuf:"bytes,15,opt,name=nsq,proto3" json:"nsq,omitempty"`             // NATS
	Pulsar    *Server_Pulsar    `protobuf:"bytes,16,opt,name=pulsar,proto3" json:"pulsar,omitempty"`       // Pulsar
	Redis     *Server_Redis     `protobuf:"bytes,17,opt,name=redis,proto3" json:"redis,omitempty"`         // Redis
	Rocketmq  *Server_RocketMQ  `protobuf:"bytes,18,opt,name=rocketmq,proto3" json:"rocketmq,omitempty"`   // RocketMQ
	Websocket *Server_Websocket `protobuf:"bytes,20,opt,name=websocket,proto3" json:"websocket,omitempty"` // Websocket服务
	Sse       *Server_SSE       `protobuf:"bytes,21,opt,name=sse,proto3" json:"sse,omitempty"`             // SSE服务
	Socketio  *Server_SocketIO  `protobuf:"bytes,22,opt,name=socketio,proto3" json:"socketio,omitempty"`   // SocketIO服务
	Signalr   *Server_SignalR   `protobuf:"bytes,23,opt,name=signalr,proto3" json:"signalr,omitempty"`     // SignalR服务
	Asynq     *Server_Asynq     `protobuf:"bytes,30,opt,name=asynq,proto3" json:"asynq,omitempty"`         // Asynq服务
	Machinery *Server_Machinery `protobuf:"bytes,31,opt,name=machinery,proto3" json:"machinery,omitempty"` // Machinery服务
	// contains filtered or unexported fields
}

服务器

func (*Server) Descriptor deprecated 

func (*Server) Descriptor() ([]byte, []int)

Deprecated: Use Server.ProtoReflect.Descriptor instead.

func (*Server) GetActivemq 

func (x *Server) GetActivemq() *Server_ActiveMQ

func (*Server) GetAsynq 

func (x *Server) GetAsynq() *Server_Asynq

func (*Server) GetGraphql 

func (x *Server) GetGraphql() *Server_GraphQL

func (*Server) GetGrpc 

func (x *Server) GetGrpc() *Server_GRPC

func (*Server) GetKafka 

func (x *Server) GetKafka() *Server_Kafka

func (*Server) GetMachinery 

func (x *Server) GetMachinery() *Server_Machinery

func (*Server) GetMqtt 

func (x *Server) GetMqtt() *Server_Mqtt

func (*Server) GetNats 

func (x *Server) GetNats() *Server_NATS

func (*Server) GetNsq 

func (x *Server) GetNsq() *Server_NSQ

func (*Server) GetPulsar 

func (x *Server) GetPulsar() *Server_Pulsar

func (*Server) GetRabbitmq 

func (x *Server) GetRabbitmq() *Server_RabbitMQ

func (*Server) GetRedis 

func (x *Server) GetRedis() *Server_Redis

func (*Server) GetRest 

func (x *Server) GetRest() *Server_REST

func (*Server) GetRocketmq 

func (x *Server) GetRocketmq() *Server_RocketMQ

func (*Server) GetSignalr 

func (x *Server) GetSignalr() *Server_SignalR

func (*Server) GetSocketio 

func (x *Server) GetSocketio() *Server_SocketIO

func (*Server) GetSse 

func (x *Server) GetSse() *Server_SSE

func (*Server) GetThrift 

func (x *Server) GetThrift() *Server_Thrift

func (*Server) GetWebsocket 

func (x *Server) GetWebsocket() *Server_Websocket

func (*Server) ProtoMessage 

func (*Server) ProtoMessage()

func (*Server) ProtoReflect 

func (x *Server) ProtoReflect() protoreflect.Message

func (*Server) Reset 

func (x *Server) Reset()

func (*Server) String 

func (x *Server) String() string

type Server_ActiveMQ 

type Server_ActiveMQ struct {
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"` // 对端网络地址
	Codec    string `protobuf:"bytes,2,opt,name=codec,proto3" json:"codec,omitempty"`       // 编解码器: json,xml,yaml...
	// contains filtered or unexported fields
}

func (*Server_ActiveMQ) Descriptor deprecated 

func (*Server_ActiveMQ) Descriptor() ([]byte, []int)

Deprecated: Use Server_ActiveMQ.ProtoReflect.Descriptor instead.

func (*Server_ActiveMQ) GetCodec 

func (x *Server_ActiveMQ) GetCodec() string

func (*Server_ActiveMQ) GetEndpoint 

func (x *Server_ActiveMQ) GetEndpoint() string

func (*Server_ActiveMQ) ProtoMessage 

func (*Server_ActiveMQ) ProtoMessage()

func (*Server_ActiveMQ) ProtoReflect 

func (x *Server_ActiveMQ) ProtoReflect() protoreflect.Message

func (*Server_ActiveMQ) Reset 

func (x *Server_ActiveMQ) Reset()

func (*Server_ActiveMQ) String 

func (x *Server_ActiveMQ) String() string

type Server_Asynq 

type Server_Asynq struct {
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"` // 对端网络地址
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"` // redis登录密码
	Db       int32  `protobuf:"varint,3,opt,name=db,proto3" json:"db,omitempty"`            // 数据库索引
	Location string `protobuf:"bytes,4,opt,name=location,proto3" json:"location,omitempty"` // 时区
	// contains filtered or unexported fields
}

Asynq

func (*Server_Asynq) Descriptor deprecated 

func (*Server_Asynq) Descriptor() ([]byte, []int)

Deprecated: Use Server_Asynq.ProtoReflect.Descriptor instead.

func (*Server_Asynq) GetDb 

func (x *Server_Asynq) GetDb() int32

func (*Server_Asynq) GetEndpoint 

func (x *Server_Asynq) GetEndpoint() string

func (*Server_Asynq) GetLocation 

func (x *Server_Asynq) GetLocation() string

func (*Server_Asynq) GetPassword 

func (x *Server_Asynq) GetPassword() string

func (*Server_Asynq) ProtoMessage 

func (*Server_Asynq) ProtoMessage()

func (*Server_Asynq) ProtoReflect 

func (x *Server_Asynq) ProtoReflect() protoreflect.Message

func (*Server_Asynq) Reset 

func (x *Server_Asynq) Reset()

func (*Server_Asynq) String 

func (x *Server_Asynq) String() string

type Server_GRPC 

type Server_GRPC struct {
	Network    string               `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"` // 网络
	Addr       string               `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`       // 服务监听地址
	Timeout    *durationpb.Duration `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"` // 超时时间
	Middleware *Middleware          `protobuf:"bytes,4,opt,name=middleware,proto3" json:"middleware,omitempty"`
	// contains filtered or unexported fields
}

gPRC

func (*Server_GRPC) Descriptor deprecated 

func (*Server_GRPC) Descriptor() ([]byte, []int)

Deprecated: Use Server_GRPC.ProtoReflect.Descriptor instead.

func (*Server_GRPC) GetAddr 

func (x *Server_GRPC) GetAddr() string

func (*Server_GRPC) GetMiddleware 

func (x *Server_GRPC) GetMiddleware() *Middleware

func (*Server_GRPC) GetNetwork 

func (x *Server_GRPC) GetNetwork() string

func (*Server_GRPC) GetTimeout 

func (x *Server_GRPC) GetTimeout() *durationpb.Duration

func (*Server_GRPC) ProtoMessage 

func (*Server_GRPC) ProtoMessage()

func (*Server_GRPC) ProtoReflect 

func (x *Server_GRPC) ProtoReflect() protoreflect.Message

func (*Server_GRPC) Reset 

func (x *Server_GRPC) Reset()

func (*Server_GRPC) String 

func (x *Server_GRPC) String() string

type Server_GraphQL 

type Server_GraphQL struct {
	Network     string               `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"` // 网络
	Addr        string               `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`       // 服务监听地址
	Path        string               `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`       // 路径
	Codec       string               `protobuf:"bytes,4,opt,name=codec,proto3" json:"codec,omitempty"`     // 编解码器
	Timeout     *durationpb.Duration `protobuf:"bytes,5,opt,name=timeout,proto3" json:"timeout,omitempty"` // 超时时间
	StrictSlash bool                 `protobuf:"varint,6,opt,name=strict_slash,json=strictSlash,proto3" json:"strict_slash,omitempty"`
	// contains filtered or unexported fields
}

GraphQL

func (*Server_GraphQL) Descriptor deprecated 

func (*Server_GraphQL) Descriptor() ([]byte, []int)

Deprecated: Use Server_GraphQL.ProtoReflect.Descriptor instead.

func (*Server_GraphQL) GetAddr 

func (x *Server_GraphQL) GetAddr() string

func (*Server_GraphQL) GetCodec 

func (x *Server_GraphQL) GetCodec() string

func (*Server_GraphQL) GetNetwork 

func (x *Server_GraphQL) GetNetwork() string

func (*Server_GraphQL) GetPath 

func (x *Server_GraphQL) GetPath() string

func (*Server_GraphQL) GetStrictSlash 

func (x *Server_GraphQL) GetStrictSlash() bool

func (*Server_GraphQL) GetTimeout 

func (x *Server_GraphQL) GetTimeout() *durationpb.Duration

func (*Server_GraphQL) ProtoMessage 

func (*Server_GraphQL) ProtoMessage()

func (*Server_GraphQL) ProtoReflect 

func (x *Server_GraphQL) ProtoReflect() protoreflect.Message

func (*Server_GraphQL) Reset 

func (x *Server_GraphQL) Reset()

func (*Server_GraphQL) String 

func (x *Server_GraphQL) String() string

type Server_Kafka 

type Server_Kafka struct {
	Addrs []string `protobuf:"bytes,1,rep,name=addrs,proto3" json:"addrs,omitempty"` // 对端网络地址
	// contains filtered or unexported fields
}

Kafka

func (*Server_Kafka) Descriptor deprecated 

func (*Server_Kafka) Descriptor() ([]byte, []int)

Deprecated: Use Server_Kafka.ProtoReflect.Descriptor instead.

func (*Server_Kafka) GetAddrs 

func (x *Server_Kafka) GetAddrs() []string

func (*Server_Kafka) ProtoMessage 

func (*Server_Kafka) ProtoMessage()

func (*Server_Kafka) ProtoReflect 

func (x *Server_Kafka) ProtoReflect() protoreflect.Message

func (*Server_Kafka) Reset 

func (x *Server_Kafka) Reset()

func (*Server_Kafka) String 

func (x *Server_Kafka) String() string

type Server_Machinery 

type Server_Machinery struct {
	Brokers  []string `protobuf:"bytes,1,rep,name=brokers,proto3" json:"brokers,omitempty"`   // broker的地址，可以根据实际使用的存储介质，分别指定Redis、AMQP或AWS SQS；
	Backends []string `protobuf:"bytes,2,rep,name=backends,proto3" json:"backends,omitempty"` // backend配置，用来指定存放结果的介质的配置。可以根据需求，分别指定为：Redis、memcached或mongodb等；
	// contains filtered or unexported fields
}

Machinery

func (*Server_Machinery) Descriptor deprecated 

func (*Server_Machinery) Descriptor() ([]byte, []int)

Deprecated: Use Server_Machinery.ProtoReflect.Descriptor instead.

func (*Server_Machinery) GetBackends 

func (x *Server_Machinery) GetBackends() []string

func (*Server_Machinery) GetBrokers 

func (x *Server_Machinery) GetBrokers() []string

func (*Server_Machinery) ProtoMessage 

func (*Server_Machinery) ProtoMessage()

func (*Server_Machinery) ProtoReflect 

func (x *Server_Machinery) ProtoReflect() protoreflect.Message

func (*Server_Machinery) Reset 

func (x *Server_Machinery) Reset()

func (*Server_Machinery) String 

func (x *Server_Machinery) String() string

type Server_Mqtt 

type Server_Mqtt struct {
	Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"` // 对端网络地址
	// contains filtered or unexported fields
}

MQTT

func (*Server_Mqtt) Descriptor deprecated 

func (*Server_Mqtt) Descriptor() ([]byte, []int)

Deprecated: Use Server_Mqtt.ProtoReflect.Descriptor instead.

func (*Server_Mqtt) GetAddr 

func (x *Server_Mqtt) GetAddr() string

func (*Server_Mqtt) ProtoMessage 

func (*Server_Mqtt) ProtoMessage()

func (*Server_Mqtt) ProtoReflect 

func (x *Server_Mqtt) ProtoReflect() protoreflect.Message

func (*Server_Mqtt) Reset 

func (x *Server_Mqtt) Reset()

func (*Server_Mqtt) String 

func (x *Server_Mqtt) String() string

type Server_NATS 

type Server_NATS struct {
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"` // 对端网络地址
	Codec    string `protobuf:"bytes,2,opt,name=codec,proto3" json:"codec,omitempty"`       // 编解码器: json,xml,yaml...
	// contains filtered or unexported fields
}

func (*Server_NATS) Descriptor deprecated 

func (*Server_NATS) Descriptor() ([]byte, []int)

Deprecated: Use Server_NATS.ProtoReflect.Descriptor instead.

func (*Server_NATS) GetCodec 

func (x *Server_NATS) GetCodec() string

func (*Server_NATS) GetEndpoint 

func (x *Server_NATS) GetEndpoint() string

func (*Server_NATS) ProtoMessage 

func (*Server_NATS) ProtoMessage()

func (*Server_NATS) ProtoReflect 

func (x *Server_NATS) ProtoReflect() protoreflect.Message

func (*Server_NATS) Reset 

func (x *Server_NATS) Reset()

func (*Server_NATS) String 

func (x *Server_NATS) String() string

type Server_NSQ 

type Server_NSQ struct {
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"` // 对端网络地址
	Codec    string `protobuf:"bytes,2,opt,name=codec,proto3" json:"codec,omitempty"`       // 编解码器: json,xml,yaml...
	// contains filtered or unexported fields
}

func (*Server_NSQ) Descriptor deprecated 

func (*Server_NSQ) Descriptor() ([]byte, []int)

Deprecated: Use Server_NSQ.ProtoReflect.Descriptor instead.

func (*Server_NSQ) GetCodec 

func (x *Server_NSQ) GetCodec() string

func (*Server_NSQ) GetEndpoint 

func (x *Server_NSQ) GetEndpoint() string

func (*Server_NSQ) ProtoMessage 

func (*Server_NSQ) ProtoMessage()

func (*Server_NSQ) ProtoReflect 

func (x *Server_NSQ) ProtoReflect() protoreflect.Message

func (*Server_NSQ) Reset 

func (x *Server_NSQ) Reset()

func (*Server_NSQ) String 

func (x *Server_NSQ) String() string

type Server_Pulsar 

type Server_Pulsar struct {
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"` // 对端网络地址
	Codec    string `protobuf:"bytes,2,opt,name=codec,proto3" json:"codec,omitempty"`       // 编解码器: json,xml,yaml...
	// contains filtered or unexported fields
}

func (*Server_Pulsar) Descriptor deprecated 

func (*Server_Pulsar) Descriptor() ([]byte, []int)

Deprecated: Use Server_Pulsar.ProtoReflect.Descriptor instead.

func (*Server_Pulsar) GetCodec 

func (x *Server_Pulsar) GetCodec() string

func (*Server_Pulsar) GetEndpoint 

func (x *Server_Pulsar) GetEndpoint() string

func (*Server_Pulsar) ProtoMessage 

func (*Server_Pulsar) ProtoMessage()

func (*Server_Pulsar) ProtoReflect 

func (x *Server_Pulsar) ProtoReflect() protoreflect.Message

func (*Server_Pulsar) Reset 

func (x *Server_Pulsar) Reset()

func (*Server_Pulsar) String 

func (x *Server_Pulsar) String() string

type Server_REST 

type Server_REST struct {
	Network       string               `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"`                                   // 网络
	Addr          string               `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`                                         // 服务监听地址
	Timeout       *durationpb.Duration `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"`                                   // 超时时间
	Cors          *Server_REST_CORS    `protobuf:"bytes,4,opt,name=cors,proto3" json:"cors,omitempty"`                                         // 服务监听地址
	Middleware    *Middleware          `protobuf:"bytes,5,opt,name=middleware,proto3" json:"middleware,omitempty"`                             // 中间件
	EnableSwagger bool                 `protobuf:"varint,6,opt,name=enable_swagger,json=enableSwagger,proto3" json:"enable_swagger,omitempty"` // 启用SwaggerUI
	EnablePprof   bool                 `protobuf:"varint,7,opt,name=enable_pprof,json=enablePprof,proto3" json:"enable_pprof,omitempty"`       // 启用pprof
	// contains filtered or unexported fields
}

REST

func (*Server_REST) Descriptor deprecated 

func (*Server_REST) Descriptor() ([]byte, []int)

Deprecated: Use Server_REST.ProtoReflect.Descriptor instead.

func (*Server_REST) GetAddr 

func (x *Server_REST) GetAddr() string

func (*Server_REST) GetCors 

func (x *Server_REST) GetCors() *Server_REST_CORS

func (*Server_REST) GetEnablePprof 

func (x *Server_REST) GetEnablePprof() bool

func (*Server_REST) GetEnableSwagger 

func (x *Server_REST) GetEnableSwagger() bool

func (*Server_REST) GetMiddleware 

func (x *Server_REST) GetMiddleware() *Middleware

func (*Server_REST) GetNetwork 

func (x *Server_REST) GetNetwork() string

func (*Server_REST) GetTimeout 

func (x *Server_REST) GetTimeout() *durationpb.Duration

func (*Server_REST) ProtoMessage 

func (*Server_REST) ProtoMessage()

func (*Server_REST) ProtoReflect 

func (x *Server_REST) ProtoReflect() protoreflect.Message

func (*Server_REST) Reset 

func (x *Server_REST) Reset()

func (*Server_REST) String 

func (x *Server_REST) String() string

type Server_REST_CORS 

type Server_REST_CORS struct {
	Headers []string `protobuf:"bytes,1,rep,name=headers,proto3" json:"headers,omitempty"` //
	Methods []string `protobuf:"bytes,2,rep,name=methods,proto3" json:"methods,omitempty"` //
	Origins []string `protobuf:"bytes,3,rep,name=origins,proto3" json:"origins,omitempty"` //
	// contains filtered or unexported fields
}

func (*Server_REST_CORS) Descriptor deprecated 

func (*Server_REST_CORS) Descriptor() ([]byte, []int)

Deprecated: Use Server_REST_CORS.ProtoReflect.Descriptor instead.

func (*Server_REST_CORS) GetHeaders 

func (x *Server_REST_CORS) GetHeaders() []string

func (*Server_REST_CORS) GetMethods 

func (x *Server_REST_CORS) GetMethods() []string

func (*Server_REST_CORS) GetOrigins 

func (x *Server_REST_CORS) GetOrigins() []string

func (*Server_REST_CORS) ProtoMessage 

func (*Server_REST_CORS) ProtoMessage()

func (*Server_REST_CORS) ProtoReflect 

func (x *Server_REST_CORS) ProtoReflect() protoreflect.Message

func (*Server_REST_CORS) Reset 

func (x *Server_REST_CORS) Reset()

func (*Server_REST_CORS) String 

func (x *Server_REST_CORS) String() string

type Server_RabbitMQ 

type Server_RabbitMQ struct {
	Addrs []string `protobuf:"bytes,1,rep,name=addrs,proto3" json:"addrs,omitempty"` // 对端网络地址
	// contains filtered or unexported fields
}

RabbitMQ

func (*Server_RabbitMQ) Descriptor deprecated 

func (*Server_RabbitMQ) Descriptor() ([]byte, []int)

Deprecated: Use Server_RabbitMQ.ProtoReflect.Descriptor instead.

func (*Server_RabbitMQ) GetAddrs 

func (x *Server_RabbitMQ) GetAddrs() []string

func (*Server_RabbitMQ) ProtoMessage 

func (*Server_RabbitMQ) ProtoMessage()

func (*Server_RabbitMQ) ProtoReflect 

func (x *Server_RabbitMQ) ProtoReflect() protoreflect.Message

func (*Server_RabbitMQ) Reset 

func (x *Server_RabbitMQ) Reset()

func (*Server_RabbitMQ) String 

func (x *Server_RabbitMQ) String() string

type Server_Redis 

type Server_Redis struct {
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"` // 对端网络地址
	Codec    string `protobuf:"bytes,2,opt,name=codec,proto3" json:"codec,omitempty"`       // 编解码器: json,xml,yaml...
	// contains filtered or unexported fields
}

func (*Server_Redis) Descriptor deprecated 

func (*Server_Redis) Descriptor() ([]byte, []int)

Deprecated: Use Server_Redis.ProtoReflect.Descriptor instead.

func (*Server_Redis) GetCodec 

func (x *Server_Redis) GetCodec() string

func (*Server_Redis) GetEndpoint 

func (x *Server_Redis) GetEndpoint() string

func (*Server_Redis) ProtoMessage 

func (*Server_Redis) ProtoMessage()

func (*Server_Redis) ProtoReflect 

func (x *Server_Redis) ProtoReflect() protoreflect.Message

func (*Server_Redis) Reset 

func (x *Server_Redis) Reset()

func (*Server_Redis) String 

func (x *Server_Redis) String() string

type Server_RocketMQ 

type Server_RocketMQ struct {
	Version          string   `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` // 驱动版本：aliyun、v2、v5
	Codec            string   `protobuf:"bytes,2,opt,name=codec,proto3" json:"codec,omitempty"`     // 编解码器: json,xml,yaml...
	EnableTrace      bool     `protobuf:"varint,3,opt,name=enable_trace,json=enableTrace,proto3" json:"enable_trace,omitempty"`
	NameServers      []string `protobuf:"bytes,4,rep,name=name_servers,json=nameServers,proto3" json:"name_servers,omitempty"`
	NameServerDomain string   `protobuf:"bytes,5,opt,name=name_server_domain,json=nameServerDomain,proto3" json:"name_server_domain,omitempty"`
	AccessKey        string   `protobuf:"bytes,6,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
	SecretKey        string   `protobuf:"bytes,7,opt,name=secret_key,json=secretKey,proto3" json:"secret_key,omitempty"`
	SecurityToken    string   `protobuf:"bytes,8,opt,name=security_token,json=securityToken,proto3" json:"security_token,omitempty"`
	Namespace        string   `protobuf:"bytes,9,opt,name=namespace,proto3" json:"namespace,omitempty"`
	InstanceName     string   `protobuf:"bytes,10,opt,name=instance_name,json=instanceName,proto3" json:"instance_name,omitempty"`
	GroupName        string   `protobuf:"bytes,11,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
	// contains filtered or unexported fields
}

func (*Server_RocketMQ) Descriptor deprecated 

func (*Server_RocketMQ) Descriptor() ([]byte, []int)

Deprecated: Use Server_RocketMQ.ProtoReflect.Descriptor instead.

func (*Server_RocketMQ) GetAccessKey 

func (x *Server_RocketMQ) GetAccessKey() string

func (*Server_RocketMQ) GetCodec 

func (x *Server_RocketMQ) GetCodec() string

func (*Server_RocketMQ) GetEnableTrace 

func (x *Server_RocketMQ) GetEnableTrace() bool

func (*Server_RocketMQ) GetGroupName 

func (x *Server_RocketMQ) GetGroupName() string

func (*Server_RocketMQ) GetInstanceName 

func (x *Server_RocketMQ) GetInstanceName() string

func (*Server_RocketMQ) GetNameServerDomain 

func (x *Server_RocketMQ) GetNameServerDomain() string

func (*Server_RocketMQ) GetNameServers 

func (x *Server_RocketMQ) GetNameServers() []string

func (*Server_RocketMQ) GetNamespace 

func (x *Server_RocketMQ) GetNamespace() string

func (*Server_RocketMQ) GetSecretKey 

func (x *Server_RocketMQ) GetSecretKey() string

func (*Server_RocketMQ) GetSecurityToken 

func (x *Server_RocketMQ) GetSecurityToken() string

func (*Server_RocketMQ) GetVersion 

func (x *Server_RocketMQ) GetVersion() string

func (*Server_RocketMQ) ProtoMessage 

func (*Server_RocketMQ) ProtoMessage()

func (*Server_RocketMQ) ProtoReflect 

func (x *Server_RocketMQ) ProtoReflect() protoreflect.Message

func (*Server_RocketMQ) Reset 

func (x *Server_RocketMQ) Reset()

func (*Server_RocketMQ) String 

func (x *Server_RocketMQ) String() string

type Server_SSE 

type Server_SSE struct {
	Network      string               `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"`                                 // 网络
	Addr         string               `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`                                       // 服务监听地址
	Path         string               `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`                                       // 路径
	Codec        string               `protobuf:"bytes,4,opt,name=codec,proto3" json:"codec,omitempty"`                                     // 编解码器
	Timeout      *durationpb.Duration `protobuf:"bytes,5,opt,name=timeout,proto3" json:"timeout,omitempty"`                                 // 超时时间
	EventTtl     *durationpb.Duration `protobuf:"bytes,6,opt,name=event_ttl,json=eventTtl,proto3" json:"event_ttl,omitempty"`               // 超时时间
	AutoStream   bool                 `protobuf:"varint,7,opt,name=auto_stream,json=autoStream,proto3" json:"auto_stream,omitempty"`        //
	AutoReply    bool                 `protobuf:"varint,8,opt,name=auto_reply,json=autoReply,proto3" json:"auto_reply,omitempty"`           //
	SplitData    bool                 `protobuf:"varint,9,opt,name=split_data,json=splitData,proto3" json:"split_data,omitempty"`           //
	EncodeBase64 bool                 `protobuf:"varint,10,opt,name=encode_base64,json=encodeBase64,proto3" json:"encode_base64,omitempty"` // 进行BASE64编码
	// contains filtered or unexported fields
}

SSE

func (*Server_SSE) Descriptor deprecated 

func (*Server_SSE) Descriptor() ([]byte, []int)

Deprecated: Use Server_SSE.ProtoReflect.Descriptor instead.

func (*Server_SSE) GetAddr 

func (x *Server_SSE) GetAddr() string

func (*Server_SSE) GetAutoReply 

func (x *Server_SSE) GetAutoReply() bool

func (*Server_SSE) GetAutoStream 

func (x *Server_SSE) GetAutoStream() bool

func (*Server_SSE) GetCodec 

func (x *Server_SSE) GetCodec() string

func (*Server_SSE) GetEncodeBase64 

func (x *Server_SSE) GetEncodeBase64() bool

func (*Server_SSE) GetEventTtl 

func (x *Server_SSE) GetEventTtl() *durationpb.Duration

func (*Server_SSE) GetNetwork 

func (x *Server_SSE) GetNetwork() string

func (*Server_SSE) GetPath 

func (x *Server_SSE) GetPath() string

func (*Server_SSE) GetSplitData 

func (x *Server_SSE) GetSplitData() bool

func (*Server_SSE) GetTimeout 

func (x *Server_SSE) GetTimeout() *durationpb.Duration

func (*Server_SSE) ProtoMessage 

func (*Server_SSE) ProtoMessage()

func (*Server_SSE) ProtoReflect 

func (x *Server_SSE) ProtoReflect() protoreflect.Message

func (*Server_SSE) Reset 

func (x *Server_SSE) Reset()

func (*Server_SSE) String 

func (x *Server_SSE) String() string

type Server_SignalR 

type Server_SignalR struct {
	Network              string               `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"`                                                          // 网络
	Addr                 string               `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`                                                                // 服务监听地址
	Codec                string               `protobuf:"bytes,3,opt,name=codec,proto3" json:"codec,omitempty"`                                                              // 编解码器
	KeepAliveInterval    *durationpb.Duration `protobuf:"bytes,4,opt,name=keep_alive_interval,json=keepAliveInterval,proto3" json:"keep_alive_interval,omitempty"`           // 超时时间
	ChanReceiveTimeout   *durationpb.Duration `protobuf:"bytes,5,opt,name=chan_receive_timeout,json=chanReceiveTimeout,proto3" json:"chan_receive_timeout,omitempty"`        // 超时时间
	Debug                bool                 `protobuf:"varint,6,opt,name=debug,proto3" json:"debug,omitempty"`                                                             // 调试开关
	StreamBufferCapacity uint32               `protobuf:"varint,7,opt,name=stream_buffer_capacity,json=streamBufferCapacity,proto3" json:"stream_buffer_capacity,omitempty"` //
	// contains filtered or unexported fields
}

SignalR

func (*Server_SignalR) Descriptor deprecated 

func (*Server_SignalR) Descriptor() ([]byte, []int)

Deprecated: Use Server_SignalR.ProtoReflect.Descriptor instead.

func (*Server_SignalR) GetAddr 

func (x *Server_SignalR) GetAddr() string

func (*Server_SignalR) GetChanReceiveTimeout 

func (x *Server_SignalR) GetChanReceiveTimeout() *durationpb.Duration

func (*Server_SignalR) GetCodec 

func (x *Server_SignalR) GetCodec() string

func (*Server_SignalR) GetDebug 

func (x *Server_SignalR) GetDebug() bool

func (*Server_SignalR) GetKeepAliveInterval 

func (x *Server_SignalR) GetKeepAliveInterval() *durationpb.Duration

func (*Server_SignalR) GetNetwork 

func (x *Server_SignalR) GetNetwork() string

func (*Server_SignalR) GetStreamBufferCapacity 

func (x *Server_SignalR) GetStreamBufferCapacity() uint32

func (*Server_SignalR) ProtoMessage 

func (*Server_SignalR) ProtoMessage()

func (*Server_SignalR) ProtoReflect 

func (x *Server_SignalR) ProtoReflect() protoreflect.Message

func (*Server_SignalR) Reset 

func (x *Server_SignalR) Reset()

func (*Server_SignalR) String 

func (x *Server_SignalR) String() string

type Server_SocketIO 

type Server_SocketIO struct {
	Network string `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"` // 网络
	Addr    string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`       // 服务监听地址
	Path    string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`       // 路径
	Codec   string `protobuf:"bytes,4,opt,name=codec,proto3" json:"codec,omitempty"`     // 编解码器
	// contains filtered or unexported fields
}

SocketIO

func (*Server_SocketIO) Descriptor deprecated 

func (*Server_SocketIO) Descriptor() ([]byte, []int)

Deprecated: Use Server_SocketIO.ProtoReflect.Descriptor instead.

func (*Server_SocketIO) GetAddr 

func (x *Server_SocketIO) GetAddr() string

func (*Server_SocketIO) GetCodec 

func (x *Server_SocketIO) GetCodec() string

func (*Server_SocketIO) GetNetwork 

func (x *Server_SocketIO) GetNetwork() string

func (*Server_SocketIO) GetPath 

func (x *Server_SocketIO) GetPath() string

func (*Server_SocketIO) ProtoMessage 

func (*Server_SocketIO) ProtoMessage()

func (*Server_SocketIO) ProtoReflect 

func (x *Server_SocketIO) ProtoReflect() protoreflect.Message

func (*Server_SocketIO) Reset 

func (x *Server_SocketIO) Reset()

func (*Server_SocketIO) String 

func (x *Server_SocketIO) String() string

type Server_Thrift 

type Server_Thrift struct {
	Network    string `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"` // 网络
	Addr       string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`       // 服务监听地址
	Protocol   string `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Buffered   bool   `protobuf:"varint,4,opt,name=buffered,proto3" json:"buffered,omitempty"`
	Framed     bool   `protobuf:"varint,5,opt,name=framed,proto3" json:"framed,omitempty"`
	BufferSize bool   `protobuf:"varint,6,opt,name=buffer_size,json=bufferSize,proto3" json:"buffer_size,omitempty"`
	// contains filtered or unexported fields
}

Thrift

func (*Server_Thrift) Descriptor deprecated 

func (*Server_Thrift) Descriptor() ([]byte, []int)

Deprecated: Use Server_Thrift.ProtoReflect.Descriptor instead.

func (*Server_Thrift) GetAddr 

func (x *Server_Thrift) GetAddr() string

func (*Server_Thrift) GetBufferSize 

func (x *Server_Thrift) GetBufferSize() bool

func (*Server_Thrift) GetBuffered 

func (x *Server_Thrift) GetBuffered() bool

func (*Server_Thrift) GetFramed 

func (x *Server_Thrift) GetFramed() bool

func (*Server_Thrift) GetNetwork 

func (x *Server_Thrift) GetNetwork() string

func (*Server_Thrift) GetProtocol 

func (x *Server_Thrift) GetProtocol() string

func (*Server_Thrift) ProtoMessage 

func (*Server_Thrift) ProtoMessage()

func (*Server_Thrift) ProtoReflect 

func (x *Server_Thrift) ProtoReflect() protoreflect.Message

func (*Server_Thrift) Reset 

func (x *Server_Thrift) Reset()

func (*Server_Thrift) String 

func (x *Server_Thrift) String() string

type Server_Websocket 

type Server_Websocket struct {
	Network string               `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"` // 网络样式：http、https
	Addr    string               `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`       // 服务监听地址
	Path    string               `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`       // 路径
	Codec   string               `protobuf:"bytes,4,opt,name=codec,proto3" json:"codec,omitempty"`     // 编解码器: json,xml,yaml...
	Timeout *durationpb.Duration `protobuf:"bytes,5,opt,name=timeout,proto3" json:"timeout,omitempty"` // 超时时间
	// contains filtered or unexported fields
}

Websocket

func (*Server_Websocket) Descriptor deprecated 

func (*Server_Websocket) Descriptor() ([]byte, []int)

Deprecated: Use Server_Websocket.ProtoReflect.Descriptor instead.

func (*Server_Websocket) GetAddr 

func (x *Server_Websocket) GetAddr() string

func (*Server_Websocket) GetCodec 

func (x *Server_Websocket) GetCodec() string

func (*Server_Websocket) GetNetwork 

func (x *Server_Websocket) GetNetwork() string

func (*Server_Websocket) GetPath 

func (x *Server_Websocket) GetPath() string

func (*Server_Websocket) GetTimeout 

func (x *Server_Websocket) GetTimeout() *durationpb.Duration

func (*Server_Websocket) ProtoMessage 

func (*Server_Websocket) ProtoMessage()

func (*Server_Websocket) ProtoReflect 

func (x *Server_Websocket) ProtoReflect() protoreflect.Message

func (*Server_Websocket) Reset 

func (x *Server_Websocket) Reset()

func (*Server_Websocket) String 

func (x *Server_Websocket) String() string

type Tracer 

type Tracer struct {
	Batcher  string  `protobuf:"bytes,1,opt,name=batcher,proto3" json:"batcher,omitempty"`   // jaeger或者zipkin
	Endpoint string  `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"` // 端口
	Sampler  float64 `protobuf:"fixed64,3,opt,name=sampler,proto3" json:"sampler,omitempty"` // 采样率，默认：1.0
	Env      string  `protobuf:"bytes,4,opt,name=env,proto3" json:"env,omitempty"`           // 运行环境：dev、debug、product
	Insecure bool    `protobuf:"varint,5,opt,name=insecure,proto3" json:"insecure,omitempty"`
	// contains filtered or unexported fields
}

链路追踪

func (*Tracer) Descriptor deprecated 

func (*Tracer) Descriptor() ([]byte, []int)

Deprecated: Use Tracer.ProtoReflect.Descriptor instead.

func (*Tracer) GetBatcher 

func (x *Tracer) GetBatcher() string

func (*Tracer) GetEndpoint 

func (x *Tracer) GetEndpoint() string

func (*Tracer) GetEnv 

func (x *Tracer) GetEnv() string

func (*Tracer) GetInsecure 

func (x *Tracer) GetInsecure() bool

func (*Tracer) GetSampler 

func (x *Tracer) GetSampler() float64

func (*Tracer) ProtoMessage 

func (*Tracer) ProtoMessage()

func (*Tracer) ProtoReflect 

func (x *Tracer) ProtoReflect() protoreflect.Message

func (*Tracer) Reset 

func (x *Tracer) Reset()

func (*Tracer) String 

func (x *Tracer) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.