Documentation ¶
Index ¶
- Variables
- type Consul
- func (*Consul) Descriptor() ([]byte, []int)deprecated
- func (x *Consul) GetAddress() string
- func (x *Consul) GetDatacenter() string
- func (x *Consul) GetPath() string
- func (x *Consul) GetScheme() string
- func (*Consul) ProtoMessage()
- func (x *Consul) ProtoReflect() protoreflect.Message
- func (x *Consul) Reset()
- func (x *Consul) String() string
- type Database
- func (*Database) Descriptor() ([]byte, []int)deprecated
- func (x *Database) GetConnMaxLifetime() *duration.Duration
- func (x *Database) GetMaxIdleConn() uint32
- func (x *Database) GetMaxOpenConn() uint32
- func (x *Database) GetSource() string
- func (*Database) ProtoMessage()
- func (x *Database) ProtoReflect() protoreflect.Message
- func (x *Database) Reset()
- func (x *Database) String() string
- type Email
- func (*Email) Descriptor() ([]byte, []int)deprecated
- func (x *Email) GetHost() string
- func (x *Email) GetPassword() string
- func (x *Email) GetPort() uint32
- func (x *Email) GetUsername() string
- func (*Email) ProtoMessage()
- func (x *Email) ProtoReflect() protoreflect.Message
- func (x *Email) Reset()
- func (x *Email) String() string
- type GRPC
- type HTTP
- func (*HTTP) Descriptor() ([]byte, []int)deprecated
- func (x *HTTP) GetAddr() string
- func (x *HTTP) GetMaxBodySize() uint32
- func (x *HTTP) GetNetwork() string
- func (x *HTTP) GetRequiredBodySize() uint32
- func (x *HTTP) GetTimeout() *duration.Duration
- func (*HTTP) ProtoMessage()
- func (x *HTTP) ProtoReflect() protoreflect.Message
- func (x *HTTP) Reset()
- func (x *HTTP) String() string
- type ObjectStorage
- func (*ObjectStorage) Descriptor() ([]byte, []int)deprecated
- func (x *ObjectStorage) GetAccessKeyId() string
- func (x *ObjectStorage) GetDomain() string
- func (x *ObjectStorage) GetLocation() string
- func (x *ObjectStorage) GetSecretAccessKey() string
- func (x *ObjectStorage) GetSecure() bool
- func (x *ObjectStorage) GetToken() string
- func (*ObjectStorage) ProtoMessage()
- func (x *ObjectStorage) ProtoReflect() protoreflect.Message
- func (x *ObjectStorage) Reset()
- func (x *ObjectStorage) String() string
- type Queue
- func (*Queue) Descriptor() ([]byte, []int)deprecated
- func (x *Queue) GetDelayLevel() uint32
- func (x *Queue) GetGroupName() string
- func (x *Queue) GetNameServerAddr() string
- func (x *Queue) GetNameServerDomain() string
- func (x *Queue) GetRetry() uint32
- func (x *Queue) GetSendMsgTimeout() *duration.Duration
- func (x *Queue) GetWithCompressLevel() uint32
- func (*Queue) ProtoMessage()
- func (x *Queue) ProtoReflect() protoreflect.Message
- func (x *Queue) Reset()
- func (x *Queue) String() string
- type Redis
- func (*Redis) Descriptor() ([]byte, []int)deprecated
- func (x *Redis) GetAddr() string
- func (x *Redis) GetDelayDeleteTime() *duration.Duration
- func (x *Redis) GetNetwork() string
- func (x *Redis) GetPassword() string
- func (x *Redis) GetReadTimeout() *duration.Duration
- func (x *Redis) GetWriteTimeout() *duration.Duration
- func (*Redis) ProtoMessage()
- func (x *Redis) ProtoReflect() protoreflect.Message
- func (x *Redis) Reset()
- func (x *Redis) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var File_consul_proto protoreflect.FileDescriptor
View Source
var File_database_proto protoreflect.FileDescriptor
View Source
var File_email_proto protoreflect.FileDescriptor
View Source
var File_grpc_proto protoreflect.FileDescriptor
View Source
var File_http_proto protoreflect.FileDescriptor
View Source
var File_object_storage_proto protoreflect.FileDescriptor
View Source
var File_queue_proto protoreflect.FileDescriptor
View Source
var File_redis_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type Consul ¶
type Consul struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` // Consul 服务器地址 Scheme string `protobuf:"bytes,2,opt,name=scheme,proto3" json:"scheme,omitempty"` // Consul 服务器的 URI 方案 ("http" or "grpc") Datacenter string `protobuf:"bytes,3,opt,name=datacenter,proto3" json:"datacenter,omitempty"` // 数据中心 Path string `protobuf:"bytes,4,opt,name=path,proto3" json:"path,omitempty"` // 配置文件路径 // contains filtered or unexported fields }
func (*Consul) Descriptor
deprecated
func (*Consul) GetAddress ¶
func (*Consul) GetDatacenter ¶
func (*Consul) ProtoMessage ¶
func (*Consul) ProtoMessage()
func (*Consul) ProtoReflect ¶
func (x *Consul) ProtoReflect() protoreflect.Message
type Database ¶
type Database struct { Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` MaxIdleConn uint32 `protobuf:"varint,2,opt,name=max_idle_conn,json=maxIdleConn,proto3" json:"max_idle_conn,omitempty"` MaxOpenConn uint32 `protobuf:"varint,3,opt,name=max_open_conn,json=maxOpenConn,proto3" json:"max_open_conn,omitempty"` ConnMaxLifetime *duration.Duration `protobuf:"bytes,4,opt,name=conn_max_lifetime,json=connMaxLifetime,proto3" json:"conn_max_lifetime,omitempty"` // contains filtered or unexported fields }
func (*Database) Descriptor
deprecated
func (*Database) GetConnMaxLifetime ¶
func (*Database) GetMaxIdleConn ¶
func (*Database) GetMaxOpenConn ¶
func (*Database) ProtoMessage ¶
func (*Database) ProtoMessage()
func (*Database) ProtoReflect ¶
func (x *Database) ProtoReflect() protoreflect.Message
type Email ¶
type Email struct { Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,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"` // contains filtered or unexported fields }
func (*Email) Descriptor
deprecated
func (*Email) GetPassword ¶
func (*Email) GetUsername ¶
func (*Email) ProtoMessage ¶
func (*Email) ProtoMessage()
func (*Email) ProtoReflect ¶
func (x *Email) ProtoReflect() protoreflect.Message
type GRPC ¶
type 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 *duration.Duration `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"` // contains filtered or unexported fields }
func (*GRPC) Descriptor
deprecated
func (*GRPC) GetNetwork ¶
func (*GRPC) GetTimeout ¶
func (*GRPC) ProtoMessage ¶
func (*GRPC) ProtoMessage()
func (*GRPC) ProtoReflect ¶
func (x *GRPC) ProtoReflect() protoreflect.Message
type HTTP ¶
type 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 *duration.Duration `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"` RequiredBodySize uint32 `protobuf:"varint,4,opt,name=required_body_size,json=requiredBodySize,proto3" json:"required_body_size,omitempty"` MaxBodySize uint32 `protobuf:"varint,5,opt,name=max_body_size,json=maxBodySize,proto3" json:"max_body_size,omitempty"` // contains filtered or unexported fields }
func (*HTTP) Descriptor
deprecated
func (*HTTP) GetMaxBodySize ¶
func (*HTTP) GetNetwork ¶
func (*HTTP) GetRequiredBodySize ¶
func (*HTTP) GetTimeout ¶
func (*HTTP) ProtoMessage ¶
func (*HTTP) ProtoMessage()
func (*HTTP) ProtoReflect ¶
func (x *HTTP) ProtoReflect() protoreflect.Message
type ObjectStorage ¶
type ObjectStorage struct { Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"` // 域名 AccessKeyId string `protobuf:"bytes,2,opt,name=access_key_id,json=accessKeyId,proto3" json:"access_key_id,omitempty"` SecretAccessKey string `protobuf:"bytes,3,opt,name=secret_access_key,json=secretAccessKey,proto3" json:"secret_access_key,omitempty"` Location string `protobuf:"bytes,4,opt,name=location,proto3" json:"location,omitempty"` // 地域 Secure bool `protobuf:"varint,5,opt,name=secure,proto3" json:"secure,omitempty"` // 是否使用https Token string `protobuf:"bytes,6,opt,name=token,proto3" json:"token,omitempty"` // contains filtered or unexported fields }
func (*ObjectStorage) Descriptor
deprecated
func (*ObjectStorage) Descriptor() ([]byte, []int)
Deprecated: Use ObjectStorage.ProtoReflect.Descriptor instead.
func (*ObjectStorage) GetAccessKeyId ¶
func (x *ObjectStorage) GetAccessKeyId() string
func (*ObjectStorage) GetDomain ¶
func (x *ObjectStorage) GetDomain() string
func (*ObjectStorage) GetLocation ¶
func (x *ObjectStorage) GetLocation() string
func (*ObjectStorage) GetSecretAccessKey ¶
func (x *ObjectStorage) GetSecretAccessKey() string
func (*ObjectStorage) GetSecure ¶
func (x *ObjectStorage) GetSecure() bool
func (*ObjectStorage) GetToken ¶
func (x *ObjectStorage) GetToken() string
func (*ObjectStorage) ProtoMessage ¶
func (*ObjectStorage) ProtoMessage()
func (*ObjectStorage) ProtoReflect ¶
func (x *ObjectStorage) ProtoReflect() protoreflect.Message
func (*ObjectStorage) Reset ¶
func (x *ObjectStorage) Reset()
func (*ObjectStorage) String ¶
func (x *ObjectStorage) String() string
type Queue ¶
type Queue struct { NameServerAddr string `protobuf:"bytes,1,opt,name=name_server_addr,json=nameServerAddr,proto3" json:"name_server_addr,omitempty"` // NameServer地址 NameServerDomain string `protobuf:"bytes,2,opt,name=name_server_domain,json=nameServerDomain,proto3" json:"name_server_domain,omitempty"` // NameServer域 GroupName string `protobuf:"bytes,3,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"` // 组名地址 SendMsgTimeout *duration.Duration `protobuf:"bytes,4,opt,name=send_msg_timeout,json=sendMsgTimeout,proto3" json:"send_msg_timeout,omitempty"` // 发送消息超时时间 WithCompressLevel uint32 `protobuf:"varint,5,opt,name=with_compress_level,json=withCompressLevel,proto3" json:"with_compress_level,omitempty"` // 设置压缩级别(0~9),0 代表最佳速度,9 代表最佳压缩比 Retry uint32 `protobuf:"varint,6,opt,name=retry,proto3" json:"retry,omitempty"` // 消费者失败重试次数 DelayLevel uint32 `protobuf:"varint,7,opt,name=delay_level,json=delayLevel,proto3" json:"delay_level,omitempty"` // 设置重新消费的延迟级别,共支持(0-18)种延迟级别 // contains filtered or unexported fields }
func (*Queue) Descriptor
deprecated
func (*Queue) GetDelayLevel ¶
func (*Queue) GetGroupName ¶
func (*Queue) GetNameServerAddr ¶
func (*Queue) GetNameServerDomain ¶
func (*Queue) GetSendMsgTimeout ¶
func (*Queue) GetWithCompressLevel ¶
func (*Queue) ProtoMessage ¶
func (*Queue) ProtoMessage()
func (*Queue) ProtoReflect ¶
func (x *Queue) ProtoReflect() protoreflect.Message
type Redis ¶
type 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"` ReadTimeout *duration.Duration `protobuf:"bytes,4,opt,name=read_timeout,json=readTimeout,proto3" json:"read_timeout,omitempty"` WriteTimeout *duration.Duration `protobuf:"bytes,5,opt,name=write_timeout,json=writeTimeout,proto3" json:"write_timeout,omitempty"` DelayDeleteTime *duration.Duration `protobuf:"bytes,6,opt,name=delay_delete_time,json=delayDeleteTime,proto3" json:"delay_delete_time,omitempty"` // contains filtered or unexported fields }
func (*Redis) Descriptor
deprecated
func (*Redis) GetDelayDeleteTime ¶
func (*Redis) GetNetwork ¶
func (*Redis) GetPassword ¶
func (*Redis) GetReadTimeout ¶
func (*Redis) GetWriteTimeout ¶
func (*Redis) ProtoMessage ¶
func (*Redis) ProtoMessage()
func (*Redis) ProtoReflect ¶
func (x *Redis) ProtoReflect() protoreflect.Message
Click to show internal directories.
Click to hide internal directories.