v1

package
v1.0.3 Latest Latest
Warning

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

 Go to latest Published: Dec 1, 2023 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_conf_v1_bootstrap_proto protoreflect.FileDescriptor
View Source 
var File_conf_v1_client_proto protoreflect.FileDescriptor
View Source 
var File_conf_v1_config_proto protoreflect.FileDescriptor
View Source 
var File_conf_v1_data_proto protoreflect.FileDescriptor
View Source 
var File_conf_v1_logger_proto protoreflect.FileDescriptor
View Source 
var File_conf_v1_middleware_proto protoreflect.FileDescriptor
View Source 
var File_conf_v1_registry_proto protoreflect.FileDescriptor
View Source 
var File_conf_v1_server_proto protoreflect.FileDescriptor
View Source 
var File_conf_v1_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"`
	// contains filtered or unexported fields
}

Bootstrap

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) 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 {
	Http *Client_HTTP `protobuf:"bytes,1,opt,name=http,proto3" json:"http,omitempty"`
	Grpc *Client_GRPC `protobuf:"bytes,2,opt,name=grpc,proto3" json:"grpc,omitempty"`
	// contains filtered or unexported fields
}

Client

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) GetHttp 

func (x *Client) GetHttp() *Client_HTTP

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
}

GRPC

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_HTTP 

type Client_HTTP 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
}

HTTP

func (*Client_HTTP) Descriptor deprecated 

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

Deprecated: Use Client_HTTP.ProtoReflect.Descriptor instead.

func (*Client_HTTP) GetMiddleware 

func (x *Client_HTTP) GetMiddleware() *Middleware

func (*Client_HTTP) GetTimeout 

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

func (*Client_HTTP) ProtoMessage 

func (*Client_HTTP) ProtoMessage()

func (*Client_HTTP) ProtoReflect 

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

func (*Client_HTTP) Reset 

func (x *Client_HTTP) Reset()

func (*Client_HTTP) String 

func (x *Client_HTTP) String() string

type Data 

type Data struct {
	Database      *Data_Database      `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`                                 // DatabaseDSN
	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 database
	ElasticSearch *Data_ElasticSearch `protobuf:"bytes,12,opt,name=elastic_search,json=elasticSearch,proto3" json:"elastic_search,omitempty"` // ElasticSearch database
	Cassandra     *Data_Cassandra     `protobuf:"bytes,13,opt,name=cassandra,proto3" json:"cassandra,omitempty"`                              // Cassandra database
	Kafka         *Data_Kafka         `protobuf:"bytes,20,opt,name=kafka,proto3" json:"kafka,omitempty"`                                      // Kafka service
	// contains filtered or unexported fields
}

Data

func (*Data) Descriptor deprecated 

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

Deprecated: Use Data.ProtoReflect.Descriptor instead.

func (*Data) GetCassandra added in v1.0.1 

func (x *Data) GetCassandra() *Data_Cassandra

func (*Data) GetDatabase 

func (x *Data) GetDatabase() *Data_Database

func (*Data) GetElasticSearch 

func (x *Data) GetElasticSearch() *Data_ElasticSearch

func (*Data) GetKafka 

func (x *Data) GetKafka() *Data_Kafka

func (*Data) GetMongodb 

func (x *Data) GetMongodb() *Data_MongoDB

func (*Data) GetRedis 

func (x *Data) GetRedis() *Data_Redis

func (*Data) ProtoMessage 

func (*Data) ProtoMessage()

func (*Data) ProtoReflect 

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

func (*Data) Reset 

func (x *Data) Reset()

func (*Data) String 

func (x *Data) String() string

type Data_Cassandra added in v1.0.1 

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

Cassandra

func (*Data_Cassandra) Descriptor deprecated added in v1.0.1 

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

Deprecated: Use Data_Cassandra.ProtoReflect.Descriptor instead.

func (*Data_Cassandra) GetAddress added in v1.0.1 

func (x *Data_Cassandra) GetAddress() string

func (*Data_Cassandra) GetConnectTimeout added in v1.0.1 

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

func (*Data_Cassandra) GetConsistency added in v1.0.1 

func (x *Data_Cassandra) GetConsistency() uint32

func (*Data_Cassandra) GetDisableInitialHostLookup added in v1.0.1 

func (x *Data_Cassandra) GetDisableInitialHostLookup() bool

func (*Data_Cassandra) GetIgnorePeerAddr added in v1.0.1 

func (x *Data_Cassandra) GetIgnorePeerAddr() bool

func (*Data_Cassandra) GetKeyspace added in v1.0.1 

func (x *Data_Cassandra) GetKeyspace() string

func (*Data_Cassandra) GetPassword added in v1.0.1 

func (x *Data_Cassandra) GetPassword() string

func (*Data_Cassandra) GetTimeout added in v1.0.1 

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

func (*Data_Cassandra) GetUsername added in v1.0.1 

func (x *Data_Cassandra) GetUsername() string

func (*Data_Cassandra) ProtoMessage added in v1.0.1 

func (*Data_Cassandra) ProtoMessage()

func (*Data_Cassandra) ProtoReflect added in v1.0.1 

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

func (*Data_Cassandra) Reset added in v1.0.1 

func (x *Data_Cassandra) Reset()

func (*Data_Cassandra) String added in v1.0.1 

func (x *Data_Cassandra) String() string

type Data_ClickHouse 

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

ClickHouse

func (*Data_ClickHouse) Descriptor deprecated 

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

Deprecated: Use Data_ClickHouse.ProtoReflect.Descriptor instead.

func (*Data_ClickHouse) GetAddress 

func (x *Data_ClickHouse) GetAddress() string

func (*Data_ClickHouse) GetBlockBufferSize added in v1.0.1 

func (x *Data_ClickHouse) GetBlockBufferSize() int32

func (*Data_ClickHouse) GetCompressionMethod added in v1.0.1 

func (x *Data_ClickHouse) GetCompressionMethod() string

func (*Data_ClickHouse) GetConnMaxLifeTime added in v1.0.1 

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

func (*Data_ClickHouse) GetConnOpenStrategy added in v1.0.1 

func (x *Data_ClickHouse) GetConnOpenStrategy() string

func (*Data_ClickHouse) GetConnectionMaxLifetime added in v1.0.1 

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

func (*Data_ClickHouse) GetDatabase added in v1.0.1 

func (x *Data_ClickHouse) GetDatabase() string

func (*Data_ClickHouse) GetDebug added in v1.0.1 

func (x *Data_ClickHouse) GetDebug() bool

func (*Data_ClickHouse) GetDialTimeout added in v1.0.1 

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

func (*Data_ClickHouse) GetMaxCompressionBuffer added in v1.0.1 

func (x *Data_ClickHouse) GetMaxCompressionBuffer() int32

func (*Data_ClickHouse) GetMaxExecutionTime added in v1.0.1 

func (x *Data_ClickHouse) GetMaxExecutionTime() int32

func (*Data_ClickHouse) GetMaxIdleConnections added in v1.0.1 

func (x *Data_ClickHouse) GetMaxIdleConnections() int32

func (*Data_ClickHouse) GetMaxIdleConns added in v1.0.1 

func (x *Data_ClickHouse) GetMaxIdleConns() int32

func (*Data_ClickHouse) GetMaxOpenConnections added in v1.0.1 

func (x *Data_ClickHouse) GetMaxOpenConnections() int32

func (*Data_ClickHouse) GetMaxOpenConns added in v1.0.1 

func (x *Data_ClickHouse) GetMaxOpenConns() int32

func (*Data_ClickHouse) GetPassword added in v1.0.1 

func (x *Data_ClickHouse) GetPassword() string

func (*Data_ClickHouse) GetProtocol added in v1.0.1 

func (x *Data_ClickHouse) GetProtocol() string

func (*Data_ClickHouse) GetUsername added in v1.0.1 

func (x *Data_ClickHouse) GetUsername() string

func (*Data_ClickHouse) ProtoMessage 

func (*Data_ClickHouse) ProtoMessage()

func (*Data_ClickHouse) ProtoReflect 

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

func (*Data_ClickHouse) Reset 

func (x *Data_ClickHouse) Reset()

func (*Data_ClickHouse) String 

func (x *Data_ClickHouse) String() string

type Data_Database 

type Data_Database struct {
	Driver                string               `protobuf:"bytes,1,opt,name=driver,proto3" json:"driver,omitempty"`                                                      // Support：mysql, postgresql, mongodb, sqlite...
	Source                string               `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`                                                      // Data source (DSN string)
	Migrate               bool                 `protobuf:"varint,3,opt,name=migrate,proto3" json:"migrate,omitempty"`                                                   // Data migration
	Debug                 bool                 `protobuf:"varint,4,opt,name=debug,proto3" json:"debug,omitempty"`                                                       // Debug
	MaxIdleConnections    int32                `protobuf:"varint,5,opt,name=max_idle_connections,json=maxIdleConnections,proto3" json:"max_idle_connections,omitempty"` // Maximum number of idle connections in the connection pool
	MaxOpenConnections    int32                `protobuf:"varint,6,opt,name=max_open_connections,json=maxOpenConnections,proto3" json:"max_open_connections,omitempty"` // Maximum number of open connections in the connection pool
	ConnectionMaxLifetime *durationpb.Duration ``                                                                                                                       // The maximum length of time a connection can be reused
	/* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

Database

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_ElasticSearch 

type Data_ElasticSearch 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"`
	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
}

ElasticSearch

func (*Data_ElasticSearch) Descriptor deprecated 

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

Deprecated: Use Data_ElasticSearch.ProtoReflect.Descriptor instead.

func (*Data_ElasticSearch) GetAddress 

func (x *Data_ElasticSearch) GetAddress() string

func (*Data_ElasticSearch) GetEnableGzip added in v1.0.1 

func (x *Data_ElasticSearch) GetEnableGzip() bool

func (*Data_ElasticSearch) GetEnableSniffer added in v1.0.1 

func (x *Data_ElasticSearch) GetEnableSniffer() bool

func (*Data_ElasticSearch) GetHealthCheckInterval added in v1.0.1 

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

func (*Data_ElasticSearch) GetPassword added in v1.0.1 

func (x *Data_ElasticSearch) GetPassword() string

func (*Data_ElasticSearch) GetUsername added in v1.0.1 

func (x *Data_ElasticSearch) GetUsername() string

func (*Data_ElasticSearch) ProtoMessage 

func (*Data_ElasticSearch) ProtoMessage()

func (*Data_ElasticSearch) ProtoReflect 

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

func (*Data_ElasticSearch) Reset 

func (x *Data_ElasticSearch) Reset()

func (*Data_ElasticSearch) String 

func (x *Data_ElasticSearch) String() string

type Data_Kafka 

type Data_Kafka struct {
	Addrs                  []string             `protobuf:"bytes,1,rep,name=addrs,proto3" json:"addrs,omitempty"`
	Codec                  string               `protobuf:"bytes,2,opt,name=codec,proto3" json:"codec,omitempty"`
	Async                  bool                 `protobuf:"varint,3,opt,name=async,proto3" json:"async,omitempty"`
	AllowAutoTopicCreation bool                 `` /* 132-byte string literal not displayed */
	BatchSize              int32                `protobuf:"varint,5,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	BatchTimeout           *durationpb.Duration `protobuf:"bytes,6,opt,name=batch_timeout,json=batchTimeout,proto3" json:"batch_timeout,omitempty"`
	ReadTimeout            *durationpb.Duration `protobuf:"bytes,7,opt,name=read_timeout,json=readTimeout,proto3" json:"read_timeout,omitempty"`
	WriteTimeout           *durationpb.Duration `protobuf:"bytes,8,opt,name=write_timeout,json=writeTimeout,proto3" json:"write_timeout,omitempty"`
	BatchBytes             int64                `protobuf:"varint,9,opt,name=batch_bytes,json=batchBytes,proto3" json:"batch_bytes,omitempty"`
	// contains filtered or unexported fields
}

Kafka

func (*Data_Kafka) Descriptor deprecated 

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

Deprecated: Use Data_Kafka.ProtoReflect.Descriptor instead.

func (*Data_Kafka) GetAddrs 

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

func (*Data_Kafka) GetAllowAutoTopicCreation added in v1.0.1 

func (x *Data_Kafka) GetAllowAutoTopicCreation() bool

func (*Data_Kafka) GetAsync added in v1.0.1 

func (x *Data_Kafka) GetAsync() bool

func (*Data_Kafka) GetBatchBytes added in v1.0.1 

func (x *Data_Kafka) GetBatchBytes() int64

func (*Data_Kafka) GetBatchSize added in v1.0.1 

func (x *Data_Kafka) GetBatchSize() int32

func (*Data_Kafka) GetBatchTimeout added in v1.0.1 

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

func (*Data_Kafka) GetCodec 

func (x *Data_Kafka) GetCodec() string

func (*Data_Kafka) GetReadTimeout added in v1.0.1 

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

func (*Data_Kafka) GetWriteTimeout added in v1.0.1 

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

func (*Data_Kafka) ProtoMessage 

func (*Data_Kafka) ProtoMessage()

func (*Data_Kafka) ProtoReflect 

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

func (*Data_Kafka) Reset 

func (x *Data_Kafka) Reset()

func (*Data_Kafka) String 

func (x *Data_Kafka) String() string

type Data_MongoDB 

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

MongoDB

func (*Data_MongoDB) Descriptor deprecated 

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

Deprecated: Use Data_MongoDB.ProtoReflect.Descriptor instead.

func (*Data_MongoDB) GetAddress 

func (x *Data_MongoDB) GetAddress() string

func (*Data_MongoDB) GetPassword added in v1.0.1 

func (x *Data_MongoDB) GetPassword() string

func (*Data_MongoDB) GetUsername added in v1.0.1 

func (x *Data_MongoDB) GetUsername() string

func (*Data_MongoDB) ProtoMessage 

func (*Data_MongoDB) ProtoMessage()

func (*Data_MongoDB) ProtoReflect 

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

func (*Data_MongoDB) Reset 

func (x *Data_MongoDB) Reset()

func (*Data_MongoDB) String 

func (x *Data_MongoDB) String() string

type Data_Redis 

type Data_Redis struct {
	Network       string               `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"`
	Addr          string               `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	Password      string               `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	Db            int32                `protobuf:"varint,4,opt,name=db,proto3" json:"db,omitempty"` // Database index
	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 v1.0.1 

func (x *Data_Redis) GetEnableMetrics() bool

func (*Data_Redis) GetEnableTracing added in v1.0.1 

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"`
	// contains filtered or unexported fields
}

Logger

func (*Logger) Descriptor deprecated 

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

Deprecated: Use Logger.ProtoReflect.Descriptor instead.

func (*Logger) GetFluent 

func (x *Logger) GetFluent() *Logger_Fluent

func (*Logger) GetLogrus 

func (x *Logger) GetLogrus() *Logger_Logrus

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_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"`                                    // Output format: text, json.
	TimestampFormat  string `protobuf:"bytes,3,opt,name=timestamp_format,json=timestampFormat,proto3" json:"timestamp_format,omitempty"` // Define the timestamp format, for example: "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_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
}

Middleware

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 signature algorithm, supported algorithm: HS256
	Key    string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`       // JWT key
	// contains filtered or unexported fields
}

JWT Auth

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
}

Metrics

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"` // Current limiter name, supported: l-bbr.
	// contains filtered or unexported fields
}

RateLimiter

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 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"`
	Etcd       *Registry_Etcd       `protobuf:"bytes,3,opt,name=etcd,proto3" json:"etcd,omitempty"`
	Zookeeper  *Registry_ZooKeeper  `protobuf:"bytes,4,opt,name=zookeeper,proto3" json:"zookeeper,omitempty"`
	Kubernetes *Registry_Kubernetes `protobuf:"bytes,5,opt,name=kubernetes,proto3" json:"kubernetes,omitempty"`
	// contains filtered or unexported fields
}

Registry

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) GetKubernetes 

func (x *Registry) GetKubernetes() *Registry_Kubernetes

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_Kubernetes 

type Registry_Kubernetes struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	MasterUrl string `protobuf:"bytes,2,opt,name=masterUrl,proto3" json:"masterUrl,omitempty"`
	// 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) GetMasterUrl 

func (x *Registry_Kubernetes) GetMasterUrl() string

func (*Registry_Kubernetes) GetNamespace 

func (x *Registry_Kubernetes) GetNamespace() string

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_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"`
	Kubernetes *RemoteConfig_Kubernetes `protobuf:"bytes,4,opt,name=kubernetes,proto3" json:"kubernetes,omitempty"`
	// contains filtered or unexported fields
}

RemoteConfig

func (*RemoteConfig) Descriptor deprecated 

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

Deprecated: Use RemoteConfig.ProtoReflect.Descriptor instead.

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) 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_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
}

Consul

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
}

Etcd

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"`
	MasterUrl     string `protobuf:"bytes,2,opt,name=master_url,json=masterUrl,proto3" json:"master_url,omitempty"`
	LabelSelector string `protobuf:"bytes,3,opt,name=label_selector,json=labelSelector,proto3" json:"label_selector,omitempty"`
	FieldSelector string `protobuf:"bytes,4,opt,name=field_selector,json=fieldSelector,proto3" json:"field_selector,omitempty"`
	// contains filtered or unexported fields
}

Kubernetes

func (*RemoteConfig_Kubernetes) Descriptor deprecated 

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

Deprecated: Use RemoteConfig_Kubernetes.ProtoReflect.Descriptor instead.

func (*RemoteConfig_Kubernetes) GetFieldSelector 

func (x *RemoteConfig_Kubernetes) GetFieldSelector() string

func (*RemoteConfig_Kubernetes) GetLabelSelector 

func (x *RemoteConfig_Kubernetes) GetLabelSelector() string

func (*RemoteConfig_Kubernetes) GetMasterUrl 

func (x *RemoteConfig_Kubernetes) GetMasterUrl() string

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 Server 

type Server struct {

	// RPC
	Http *Server_HTTP `protobuf:"bytes,1,opt,name=http,proto3" json:"http,omitempty"`
	Grpc *Server_GRPC `protobuf:"bytes,2,opt,name=grpc,proto3" json:"grpc,omitempty"`
	// contains filtered or unexported fields
}

Server

func (*Server) Descriptor deprecated 

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

Deprecated: Use Server.ProtoReflect.Descriptor instead.

func (*Server) GetGrpc 

func (x *Server) GetGrpc() *Server_GRPC

func (*Server) GetHttp 

func (x *Server) GetHttp() *Server_HTTP

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_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
}

GRPC

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_HTTP 

type Server_HTTP 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_HTTP_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"`
	EnablePprof   bool                 `protobuf:"varint,7,opt,name=enable_pprof,json=enablePprof,proto3" json:"enable_pprof,omitempty"`
	// contains filtered or unexported fields
}

HTTP

func (*Server_HTTP) Descriptor deprecated 

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

Deprecated: Use Server_HTTP.ProtoReflect.Descriptor instead.

func (*Server_HTTP) GetAddr 

func (x *Server_HTTP) GetAddr() string

func (*Server_HTTP) GetCors 

func (x *Server_HTTP) GetCors() *Server_HTTP_CORS

func (*Server_HTTP) GetEnablePprof added in v1.0.1 

func (x *Server_HTTP) GetEnablePprof() bool

func (*Server_HTTP) GetEnableSwagger 

func (x *Server_HTTP) GetEnableSwagger() bool

func (*Server_HTTP) GetMiddleware 

func (x *Server_HTTP) GetMiddleware() *Middleware

func (*Server_HTTP) GetNetwork 

func (x *Server_HTTP) GetNetwork() string

func (*Server_HTTP) GetTimeout 

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

func (*Server_HTTP) ProtoMessage 

func (*Server_HTTP) ProtoMessage()

func (*Server_HTTP) ProtoReflect 

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

func (*Server_HTTP) Reset 

func (x *Server_HTTP) Reset()

func (*Server_HTTP) String 

func (x *Server_HTTP) String() string

type Server_HTTP_CORS 

type Server_HTTP_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
}

CORS

func (*Server_HTTP_CORS) Descriptor deprecated 

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

Deprecated: Use Server_HTTP_CORS.ProtoReflect.Descriptor instead.

func (*Server_HTTP_CORS) GetHeaders 

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

func (*Server_HTTP_CORS) GetMethods 

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

func (*Server_HTTP_CORS) GetOrigins 

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

func (*Server_HTTP_CORS) ProtoMessage 

func (*Server_HTTP_CORS) ProtoMessage()

func (*Server_HTTP_CORS) ProtoReflect 

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

func (*Server_HTTP_CORS) Reset 

func (x *Server_HTTP_CORS) Reset()

func (*Server_HTTP_CORS) String 

func (x *Server_HTTP_CORS) String() string

type Tracer 

type Tracer struct {
	Batcher  string  `protobuf:"bytes,1,opt,name=batcher,proto3" json:"batcher,omitempty"` // jaeger or 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"` // Sampling rate, default: 1.0
	Env      string  `protobuf:"bytes,4,opt,name=env,proto3" json:"env,omitempty"`           // Operating environment: dev, debug, product
	Insecure bool    `protobuf:"varint,5,opt,name=insecure,proto3" json:"insecure,omitempty"`
	// contains filtered or unexported fields
}

Tracer

func (*Tracer) Descriptor deprecated 

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

Deprecated: Use Tracer.ProtoReflect.Descriptor instead.

func (*Tracer) GetBatcher 

func (x *Tracer) GetBatcher() string

func (*Tracer) GetEndpoint 

func (x *Tracer) GetEndpoint() string

func (*Tracer) GetEnv 

func (x *Tracer) GetEnv() string

func (*Tracer) GetInsecure 

func (x *Tracer) GetInsecure() bool

func (*Tracer) GetSampler 

func (x *Tracer) GetSampler() float64

func (*Tracer) ProtoMessage 

func (*Tracer) ProtoMessage()

func (*Tracer) ProtoReflect 

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

func (*Tracer) Reset 

func (x *Tracer) Reset()

func (*Tracer) String 

func (x *Tracer) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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