v1

package
v0.2.24 Latest Latest
Warning

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

Go to latest
Published: Apr 18, 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数据库
	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) GetClickhouse added in v0.2.11

func (x *Data) GetClickhouse() *Data_ClickHouse

func (*Data) GetDatabase

func (x *Data) GetDatabase() *Data_Database

func (*Data) GetDoris added in v0.2.17

func (x *Data) GetDoris() *Data_Doris

func (*Data) GetElasticSearch added in v0.2.17

func (x *Data) GetElasticSearch() *Data_ElasticSearch

func (*Data) GetInfluxdb added in v0.2.11

func (x *Data) GetInfluxdb() *Data_InfluxDB

func (*Data) GetKafka added in v0.2.7

func (x *Data) GetKafka() *Data_Kafka

func (*Data) GetMongodb added in v0.2.11

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_ClickHouse added in v0.2.11

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 added in v0.2.11

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

Deprecated: Use Data_ClickHouse.ProtoReflect.Descriptor instead.

func (*Data_ClickHouse) GetAddress added in v0.2.17

func (x *Data_ClickHouse) GetAddress() string

func (*Data_ClickHouse) GetBlockBufferSize added in v0.2.23

func (x *Data_ClickHouse) GetBlockBufferSize() int32

func (*Data_ClickHouse) GetCompressionMethod added in v0.2.23

func (x *Data_ClickHouse) GetCompressionMethod() string

func (*Data_ClickHouse) GetConnMaxLifeTime added in v0.2.23

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

func (*Data_ClickHouse) GetConnOpenStrategy added in v0.2.23

func (x *Data_ClickHouse) GetConnOpenStrategy() string

func (*Data_ClickHouse) GetConnectionMaxLifetime added in v0.2.23

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

func (*Data_ClickHouse) GetDatabase added in v0.2.23

func (x *Data_ClickHouse) GetDatabase() string

func (*Data_ClickHouse) GetDebug added in v0.2.23

func (x *Data_ClickHouse) GetDebug() bool

func (*Data_ClickHouse) GetDialTimeout added in v0.2.23

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

func (*Data_ClickHouse) GetMaxCompressionBuffer added in v0.2.23

func (x *Data_ClickHouse) GetMaxCompressionBuffer() int32

func (*Data_ClickHouse) GetMaxExecutionTime added in v0.2.23

func (x *Data_ClickHouse) GetMaxExecutionTime() int32

func (*Data_ClickHouse) GetMaxIdleConnections added in v0.2.23

func (x *Data_ClickHouse) GetMaxIdleConnections() int32

func (*Data_ClickHouse) GetMaxIdleConns added in v0.2.23

func (x *Data_ClickHouse) GetMaxIdleConns() int32

func (*Data_ClickHouse) GetMaxOpenConnections added in v0.2.23

func (x *Data_ClickHouse) GetMaxOpenConnections() int32

func (*Data_ClickHouse) GetMaxOpenConns added in v0.2.23

func (x *Data_ClickHouse) GetMaxOpenConns() int32

func (*Data_ClickHouse) GetPassword added in v0.2.23

func (x *Data_ClickHouse) GetPassword() string

func (*Data_ClickHouse) GetProtocol added in v0.2.23

func (x *Data_ClickHouse) GetProtocol() string

func (*Data_ClickHouse) GetUsername added in v0.2.23

func (x *Data_ClickHouse) GetUsername() string

func (*Data_ClickHouse) ProtoMessage added in v0.2.11

func (*Data_ClickHouse) ProtoMessage()

func (*Data_ClickHouse) ProtoReflect added in v0.2.11

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

func (*Data_ClickHouse) Reset added in v0.2.11

func (x *Data_ClickHouse) Reset()

func (*Data_ClickHouse) String added in v0.2.11

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,3,opt,name=migrate,proto3" json:"migrate,omitempty"`                                                   // 数据迁移开关
	Debug                 bool                 `protobuf:"varint,4,opt,name=debug,proto3" json:"debug,omitempty"`                                                       // 调试开关
	MaxIdleConnections    int32                `protobuf:"varint,5,opt,name=max_idle_connections,json=maxIdleConnections,proto3" json:"max_idle_connections,omitempty"` // 连接池最大空闲连接数
	MaxOpenConnections    int32                `protobuf:"varint,6,opt,name=max_open_connections,json=maxOpenConnections,proto3" json:"max_open_connections,omitempty"` // 连接池最大打开连接数
	ConnectionMaxLifetime *durationpb.Duration ``                                                                                                                       // 连接可重用的最大时间长度
	/* 126-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) 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 added in v0.2.17

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 added in v0.2.17

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

Deprecated: Use Data_Doris.ProtoReflect.Descriptor instead.

func (*Data_Doris) GetAddress added in v0.2.17

func (x *Data_Doris) GetAddress() string

func (*Data_Doris) ProtoMessage added in v0.2.17

func (*Data_Doris) ProtoMessage()

func (*Data_Doris) ProtoReflect added in v0.2.17

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

func (*Data_Doris) Reset added in v0.2.17

func (x *Data_Doris) Reset()

func (*Data_Doris) String added in v0.2.17

func (x *Data_Doris) String() string

type Data_ElasticSearch added in v0.2.17

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 added in v0.2.17

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

Deprecated: Use Data_ElasticSearch.ProtoReflect.Descriptor instead.

func (*Data_ElasticSearch) GetAddresses added in v0.2.23

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

func (*Data_ElasticSearch) GetEnableGzip added in v0.2.23

func (x *Data_ElasticSearch) GetEnableGzip() bool

func (*Data_ElasticSearch) GetEnableSniffer added in v0.2.23

func (x *Data_ElasticSearch) GetEnableSniffer() bool

func (*Data_ElasticSearch) GetHealthCheckInterval added in v0.2.23

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

func (*Data_ElasticSearch) GetPassword added in v0.2.23

func (x *Data_ElasticSearch) GetPassword() string

func (*Data_ElasticSearch) GetUsername added in v0.2.23

func (x *Data_ElasticSearch) GetUsername() string

func (*Data_ElasticSearch) ProtoMessage added in v0.2.17

func (*Data_ElasticSearch) ProtoMessage()

func (*Data_ElasticSearch) ProtoReflect added in v0.2.17

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

func (*Data_ElasticSearch) Reset added in v0.2.17

func (x *Data_ElasticSearch) Reset()

func (*Data_ElasticSearch) String added in v0.2.17

func (x *Data_ElasticSearch) String() string

type Data_InfluxDB added in v0.2.11

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 added in v0.2.11

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

Deprecated: Use Data_InfluxDB.ProtoReflect.Descriptor instead.

func (*Data_InfluxDB) GetAddress added in v0.2.17

func (x *Data_InfluxDB) GetAddress() string

func (*Data_InfluxDB) GetBucket added in v0.2.17

func (x *Data_InfluxDB) GetBucket() string

func (*Data_InfluxDB) GetOrganization added in v0.2.23

func (x *Data_InfluxDB) GetOrganization() string

func (*Data_InfluxDB) GetToken added in v0.2.17

func (x *Data_InfluxDB) GetToken() string

func (*Data_InfluxDB) ProtoMessage added in v0.2.11

func (*Data_InfluxDB) ProtoMessage()

func (*Data_InfluxDB) ProtoReflect added in v0.2.11

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

func (*Data_InfluxDB) Reset added in v0.2.11

func (x *Data_InfluxDB) Reset()

func (*Data_InfluxDB) String added in v0.2.11

func (x *Data_InfluxDB) String() string

type Data_Kafka added in v0.2.7

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 added in v0.2.7

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

Deprecated: Use Data_Kafka.ProtoReflect.Descriptor instead.

func (*Data_Kafka) GetAddrs added in v0.2.7

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

func (*Data_Kafka) GetAllowAutoTopicCreation added in v0.2.23

func (x *Data_Kafka) GetAllowAutoTopicCreation() bool

func (*Data_Kafka) GetAsync added in v0.2.23

func (x *Data_Kafka) GetAsync() bool

func (*Data_Kafka) GetBatchBytes added in v0.2.23

func (x *Data_Kafka) GetBatchBytes() int64

func (*Data_Kafka) GetBatchSize added in v0.2.23

func (x *Data_Kafka) GetBatchSize() int32

func (*Data_Kafka) GetBatchTimeout added in v0.2.23

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

func (*Data_Kafka) GetCodec added in v0.2.7

func (x *Data_Kafka) GetCodec() string

func (*Data_Kafka) GetReadTimeout added in v0.2.23

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

func (*Data_Kafka) GetWriteTimeout added in v0.2.23

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

func (*Data_Kafka) ProtoMessage added in v0.2.7

func (*Data_Kafka) ProtoMessage()

func (*Data_Kafka) ProtoReflect added in v0.2.7

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

func (*Data_Kafka) Reset added in v0.2.7

func (x *Data_Kafka) Reset()

func (*Data_Kafka) String added in v0.2.7

func (x *Data_Kafka) String() string

type Data_MongoDB added in v0.2.11

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 added in v0.2.11

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

Deprecated: Use Data_MongoDB.ProtoReflect.Descriptor instead.

func (*Data_MongoDB) GetAddress added in v0.2.17

func (x *Data_MongoDB) GetAddress() string

func (*Data_MongoDB) GetPassword added in v0.2.23

func (x *Data_MongoDB) GetPassword() string

func (*Data_MongoDB) GetUsername added in v0.2.23

func (x *Data_MongoDB) GetUsername() string

func (*Data_MongoDB) ProtoMessage added in v0.2.11

func (*Data_MongoDB) ProtoMessage()

func (*Data_MongoDB) ProtoReflect added in v0.2.11

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

func (*Data_MongoDB) Reset added in v0.2.11

func (x *Data_MongoDB) Reset()

func (*Data_MongoDB) String added in v0.2.11

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 added in v0.2.21

func (x *Data_Redis) GetEnableMetrics() bool

func (*Data_Redis) GetEnableTracing added in v0.2.21

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 added in v0.2.17

func (x *Server) GetActivemq() *Server_ActiveMQ

func (*Server) GetAsynq

func (x *Server) GetAsynq() *Server_Asynq

func (*Server) GetGraphql added in v0.2.11

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 added in v0.2.17

func (x *Server) GetNats() *Server_NATS

func (*Server) GetNsq added in v0.2.17

func (x *Server) GetNsq() *Server_NSQ

func (*Server) GetPulsar added in v0.2.17

func (x *Server) GetPulsar() *Server_Pulsar

func (*Server) GetRabbitmq

func (x *Server) GetRabbitmq() *Server_RabbitMQ

func (*Server) GetRedis added in v0.2.17

func (x *Server) GetRedis() *Server_Redis

func (*Server) GetRest

func (x *Server) GetRest() *Server_REST

func (*Server) GetRocketmq added in v0.2.17

func (x *Server) GetRocketmq() *Server_RocketMQ

func (*Server) GetSignalr added in v0.2.11

func (x *Server) GetSignalr() *Server_SignalR

func (*Server) GetSocketio added in v0.2.11

func (x *Server) GetSocketio() *Server_SocketIO

func (*Server) GetSse added in v0.2.11

func (x *Server) GetSse() *Server_SSE

func (*Server) GetThrift added in v0.2.11

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 added in v0.2.17

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 added in v0.2.17

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

Deprecated: Use Server_ActiveMQ.ProtoReflect.Descriptor instead.

func (*Server_ActiveMQ) GetCodec added in v0.2.17

func (x *Server_ActiveMQ) GetCodec() string

func (*Server_ActiveMQ) GetEndpoint added in v0.2.17

func (x *Server_ActiveMQ) GetEndpoint() string

func (*Server_ActiveMQ) ProtoMessage added in v0.2.17

func (*Server_ActiveMQ) ProtoMessage()

func (*Server_ActiveMQ) ProtoReflect added in v0.2.17

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

func (*Server_ActiveMQ) Reset added in v0.2.17

func (x *Server_ActiveMQ) Reset()

func (*Server_ActiveMQ) String added in v0.2.17

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 added in v0.2.22

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 added in v0.2.11

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 added in v0.2.11

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

Deprecated: Use Server_GraphQL.ProtoReflect.Descriptor instead.

func (*Server_GraphQL) GetAddr added in v0.2.17

func (x *Server_GraphQL) GetAddr() string

func (*Server_GraphQL) GetCodec added in v0.2.17

func (x *Server_GraphQL) GetCodec() string

func (*Server_GraphQL) GetNetwork added in v0.2.17

func (x *Server_GraphQL) GetNetwork() string

func (*Server_GraphQL) GetPath added in v0.2.17

func (x *Server_GraphQL) GetPath() string

func (*Server_GraphQL) GetStrictSlash added in v0.2.17

func (x *Server_GraphQL) GetStrictSlash() bool

func (*Server_GraphQL) GetTimeout added in v0.2.17

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

func (*Server_GraphQL) ProtoMessage added in v0.2.11

func (*Server_GraphQL) ProtoMessage()

func (*Server_GraphQL) ProtoReflect added in v0.2.11

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

func (*Server_GraphQL) Reset added in v0.2.11

func (x *Server_GraphQL) Reset()

func (*Server_GraphQL) String added in v0.2.11

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 added in v0.2.17

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 added in v0.2.17

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

Deprecated: Use Server_NATS.ProtoReflect.Descriptor instead.

func (*Server_NATS) GetCodec added in v0.2.17

func (x *Server_NATS) GetCodec() string

func (*Server_NATS) GetEndpoint added in v0.2.17

func (x *Server_NATS) GetEndpoint() string

func (*Server_NATS) ProtoMessage added in v0.2.17

func (*Server_NATS) ProtoMessage()

func (*Server_NATS) ProtoReflect added in v0.2.17

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

func (*Server_NATS) Reset added in v0.2.17

func (x *Server_NATS) Reset()

func (*Server_NATS) String added in v0.2.17

func (x *Server_NATS) String() string

type Server_NSQ added in v0.2.17

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 added in v0.2.17

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

Deprecated: Use Server_NSQ.ProtoReflect.Descriptor instead.

func (*Server_NSQ) GetCodec added in v0.2.17

func (x *Server_NSQ) GetCodec() string

func (*Server_NSQ) GetEndpoint added in v0.2.17

func (x *Server_NSQ) GetEndpoint() string

func (*Server_NSQ) ProtoMessage added in v0.2.17

func (*Server_NSQ) ProtoMessage()

func (*Server_NSQ) ProtoReflect added in v0.2.17

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

func (*Server_NSQ) Reset added in v0.2.17

func (x *Server_NSQ) Reset()

func (*Server_NSQ) String added in v0.2.17

func (x *Server_NSQ) String() string

type Server_Pulsar added in v0.2.17

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 added in v0.2.17

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

Deprecated: Use Server_Pulsar.ProtoReflect.Descriptor instead.

func (*Server_Pulsar) GetCodec added in v0.2.17

func (x *Server_Pulsar) GetCodec() string

func (*Server_Pulsar) GetEndpoint added in v0.2.17

func (x *Server_Pulsar) GetEndpoint() string

func (*Server_Pulsar) ProtoMessage added in v0.2.17

func (*Server_Pulsar) ProtoMessage()

func (*Server_Pulsar) ProtoReflect added in v0.2.17

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

func (*Server_Pulsar) Reset added in v0.2.17

func (x *Server_Pulsar) Reset()

func (*Server_Pulsar) String added in v0.2.17

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 added in v0.2.19

func (x *Server_REST) GetEnablePprof() bool

func (*Server_REST) GetEnableSwagger added in v0.2.8

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 added in v0.2.17

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 added in v0.2.17

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

Deprecated: Use Server_Redis.ProtoReflect.Descriptor instead.

func (*Server_Redis) GetCodec added in v0.2.17

func (x *Server_Redis) GetCodec() string

func (*Server_Redis) GetEndpoint added in v0.2.17

func (x *Server_Redis) GetEndpoint() string

func (*Server_Redis) ProtoMessage added in v0.2.17

func (*Server_Redis) ProtoMessage()

func (*Server_Redis) ProtoReflect added in v0.2.17

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

func (*Server_Redis) Reset added in v0.2.17

func (x *Server_Redis) Reset()

func (*Server_Redis) String added in v0.2.17

func (x *Server_Redis) String() string

type Server_RocketMQ added in v0.2.17

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 added in v0.2.17

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

Deprecated: Use Server_RocketMQ.ProtoReflect.Descriptor instead.

func (*Server_RocketMQ) GetAccessKey added in v0.2.17

func (x *Server_RocketMQ) GetAccessKey() string

func (*Server_RocketMQ) GetCodec added in v0.2.17

func (x *Server_RocketMQ) GetCodec() string

func (*Server_RocketMQ) GetEnableTrace added in v0.2.17

func (x *Server_RocketMQ) GetEnableTrace() bool

func (*Server_RocketMQ) GetGroupName added in v0.2.17

func (x *Server_RocketMQ) GetGroupName() string

func (*Server_RocketMQ) GetInstanceName added in v0.2.17

func (x *Server_RocketMQ) GetInstanceName() string

func (*Server_RocketMQ) GetNameServerDomain added in v0.2.17

func (x *Server_RocketMQ) GetNameServerDomain() string

func (*Server_RocketMQ) GetNameServers added in v0.2.17

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

func (*Server_RocketMQ) GetNamespace added in v0.2.17

func (x *Server_RocketMQ) GetNamespace() string

func (*Server_RocketMQ) GetSecretKey added in v0.2.17

func (x *Server_RocketMQ) GetSecretKey() string

func (*Server_RocketMQ) GetSecurityToken added in v0.2.17

func (x *Server_RocketMQ) GetSecurityToken() string

func (*Server_RocketMQ) GetVersion added in v0.2.17

func (x *Server_RocketMQ) GetVersion() string

func (*Server_RocketMQ) ProtoMessage added in v0.2.17

func (*Server_RocketMQ) ProtoMessage()

func (*Server_RocketMQ) ProtoReflect added in v0.2.17

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

func (*Server_RocketMQ) Reset added in v0.2.17

func (x *Server_RocketMQ) Reset()

func (*Server_RocketMQ) String added in v0.2.17

func (x *Server_RocketMQ) String() string

type Server_SSE added in v0.2.11

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 added in v0.2.11

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

Deprecated: Use Server_SSE.ProtoReflect.Descriptor instead.

func (*Server_SSE) GetAddr added in v0.2.11

func (x *Server_SSE) GetAddr() string

func (*Server_SSE) GetAutoReply added in v0.2.17

func (x *Server_SSE) GetAutoReply() bool

func (*Server_SSE) GetAutoStream added in v0.2.17

func (x *Server_SSE) GetAutoStream() bool

func (*Server_SSE) GetCodec added in v0.2.11

func (x *Server_SSE) GetCodec() string

func (*Server_SSE) GetEncodeBase64 added in v0.2.17

func (x *Server_SSE) GetEncodeBase64() bool

func (*Server_SSE) GetEventTtl added in v0.2.17

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

func (*Server_SSE) GetNetwork added in v0.2.11

func (x *Server_SSE) GetNetwork() string

func (*Server_SSE) GetPath added in v0.2.11

func (x *Server_SSE) GetPath() string

func (*Server_SSE) GetSplitData added in v0.2.17

func (x *Server_SSE) GetSplitData() bool

func (*Server_SSE) GetTimeout added in v0.2.11

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

func (*Server_SSE) ProtoMessage added in v0.2.11

func (*Server_SSE) ProtoMessage()

func (*Server_SSE) ProtoReflect added in v0.2.11

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

func (*Server_SSE) Reset added in v0.2.11

func (x *Server_SSE) Reset()

func (*Server_SSE) String added in v0.2.11

func (x *Server_SSE) String() string

type Server_SignalR added in v0.2.11

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 added in v0.2.11

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

Deprecated: Use Server_SignalR.ProtoReflect.Descriptor instead.

func (*Server_SignalR) GetAddr added in v0.2.17

func (x *Server_SignalR) GetAddr() string

func (*Server_SignalR) GetChanReceiveTimeout added in v0.2.17

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

func (*Server_SignalR) GetCodec added in v0.2.17

func (x *Server_SignalR) GetCodec() string

func (*Server_SignalR) GetDebug added in v0.2.17

func (x *Server_SignalR) GetDebug() bool

func (*Server_SignalR) GetKeepAliveInterval added in v0.2.17

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

func (*Server_SignalR) GetNetwork added in v0.2.17

func (x *Server_SignalR) GetNetwork() string

func (*Server_SignalR) GetStreamBufferCapacity added in v0.2.17

func (x *Server_SignalR) GetStreamBufferCapacity() uint32

func (*Server_SignalR) ProtoMessage added in v0.2.11

func (*Server_SignalR) ProtoMessage()

func (*Server_SignalR) ProtoReflect added in v0.2.11

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

func (*Server_SignalR) Reset added in v0.2.11

func (x *Server_SignalR) Reset()

func (*Server_SignalR) String added in v0.2.11

func (x *Server_SignalR) String() string

type Server_SocketIO added in v0.2.11

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 added in v0.2.11

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

Deprecated: Use Server_SocketIO.ProtoReflect.Descriptor instead.

func (*Server_SocketIO) GetAddr added in v0.2.17

func (x *Server_SocketIO) GetAddr() string

func (*Server_SocketIO) GetCodec added in v0.2.17

func (x *Server_SocketIO) GetCodec() string

func (*Server_SocketIO) GetNetwork added in v0.2.17

func (x *Server_SocketIO) GetNetwork() string

func (*Server_SocketIO) GetPath added in v0.2.17

func (x *Server_SocketIO) GetPath() string

func (*Server_SocketIO) ProtoMessage added in v0.2.11

func (*Server_SocketIO) ProtoMessage()

func (*Server_SocketIO) ProtoReflect added in v0.2.11

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

func (*Server_SocketIO) Reset added in v0.2.11

func (x *Server_SocketIO) Reset()

func (*Server_SocketIO) String added in v0.2.11

func (x *Server_SocketIO) String() string

type Server_Thrift added in v0.2.11

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 added in v0.2.11

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

Deprecated: Use Server_Thrift.ProtoReflect.Descriptor instead.

func (*Server_Thrift) GetAddr added in v0.2.17

func (x *Server_Thrift) GetAddr() string

func (*Server_Thrift) GetBufferSize added in v0.2.17

func (x *Server_Thrift) GetBufferSize() bool

func (*Server_Thrift) GetBuffered added in v0.2.17

func (x *Server_Thrift) GetBuffered() bool

func (*Server_Thrift) GetFramed added in v0.2.17

func (x *Server_Thrift) GetFramed() bool

func (*Server_Thrift) GetNetwork added in v0.2.17

func (x *Server_Thrift) GetNetwork() string

func (*Server_Thrift) GetProtocol added in v0.2.17

func (x *Server_Thrift) GetProtocol() string

func (*Server_Thrift) ProtoMessage added in v0.2.11

func (*Server_Thrift) ProtoMessage()

func (*Server_Thrift) ProtoReflect added in v0.2.11

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

func (*Server_Thrift) Reset added in v0.2.11

func (x *Server_Thrift) Reset()

func (*Server_Thrift) String added in v0.2.11

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 added in v0.2.12

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 added in v0.2.10

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

Jump to

Keyboard shortcuts

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