v1

package
v1.0.1 Latest Latest
Warning

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

 Go to latest Published: Oct 26, 2023 License: MIT Imports: 6 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_config_v1_config_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Broker 

type Broker struct {
	Name      string     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`           // broker名
	Addrs     []string   `protobuf:"bytes,2,rep,name=addrs,proto3" json:"addrs,omitempty"`         // broker地址
	Publish   *Publish   `protobuf:"bytes,3,opt,name=publish,proto3" json:"publish,omitempty"`     // broker发布配置
	Subscribe *Subscribe `protobuf:"bytes,4,opt,name=subscribe,proto3" json:"subscribe,omitempty"` // broker订阅配置
	// contains filtered or unexported fields
}

config service

func (*Broker) Descriptor deprecated 

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

Deprecated: Use Broker.ProtoReflect.Descriptor instead.

func (*Broker) GetAddrs 

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

func (*Broker) GetName 

func (x *Broker) GetName() string

func (*Broker) GetPublish 

func (x *Broker) GetPublish() *Publish

func (*Broker) GetSubscribe 

func (x *Broker) GetSubscribe() *Subscribe

func (*Broker) ProtoMessage 

func (*Broker) ProtoMessage()

func (*Broker) ProtoReflect 

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

func (*Broker) Reset 

func (x *Broker) Reset()

func (*Broker) String 

func (x *Broker) String() string

type GRPCClient 

type GRPCClient struct {
	Endpoint    string               `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"` // http client endpoint
	Timeout     *durationpb.Duration `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Middlewares []*Middleware        `protobuf:"bytes,4,rep,name=middlewares,proto3" json:"middlewares,omitempty"`
	// contains filtered or unexported fields
}

grpc client config

func (*GRPCClient) Descriptor deprecated 

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

Deprecated: Use GRPCClient.ProtoReflect.Descriptor instead.

func (*GRPCClient) GetEndpoint 

func (x *GRPCClient) GetEndpoint() string

func (*GRPCClient) GetMiddlewares 

func (x *GRPCClient) GetMiddlewares() []*Middleware

func (*GRPCClient) GetTimeout 

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

func (*GRPCClient) ProtoMessage 

func (*GRPCClient) ProtoMessage()

func (*GRPCClient) ProtoReflect 

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

func (*GRPCClient) Reset 

func (x *GRPCClient) Reset()

func (*GRPCClient) String 

func (x *GRPCClient) String() string

type GRPCServer 

type GRPCServer 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"`
	Middlewares []*Middleware        `protobuf:"bytes,4,rep,name=middlewares,proto3" json:"middlewares,omitempty"`
	// contains filtered or unexported fields
}

grpc server config

func (*GRPCServer) Descriptor deprecated 

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

Deprecated: Use GRPCServer.ProtoReflect.Descriptor instead.

func (*GRPCServer) GetAddr 

func (x *GRPCServer) GetAddr() string

func (*GRPCServer) GetMiddlewares 

func (x *GRPCServer) GetMiddlewares() []*Middleware

func (*GRPCServer) GetNetwork 

func (x *GRPCServer) GetNetwork() string

func (*GRPCServer) GetTimeout 

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

func (*GRPCServer) ProtoMessage 

func (*GRPCServer) ProtoMessage()

func (*GRPCServer) ProtoReflect 

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

func (*GRPCServer) Reset 

func (x *GRPCServer) Reset()

func (*GRPCServer) String 

func (x *GRPCServer) String() string

type HTTPClient 

type HTTPClient struct {
	Endpoint    string               `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"` // http client endpoint
	Timeout     *durationpb.Duration `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Middlewares []*Middleware        `protobuf:"bytes,4,rep,name=middlewares,proto3" json:"middlewares,omitempty"`
	// contains filtered or unexported fields
}

http client config

func (*HTTPClient) Descriptor deprecated 

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

Deprecated: Use HTTPClient.ProtoReflect.Descriptor instead.

func (*HTTPClient) GetEndpoint 

func (x *HTTPClient) GetEndpoint() string

func (*HTTPClient) GetMiddlewares 

func (x *HTTPClient) GetMiddlewares() []*Middleware

func (*HTTPClient) GetTimeout 

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

func (*HTTPClient) ProtoMessage 

func (*HTTPClient) ProtoMessage()

func (*HTTPClient) ProtoReflect 

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

func (*HTTPClient) Reset 

func (x *HTTPClient) Reset()

func (*HTTPClient) String 

func (x *HTTPClient) String() string

type HTTPServer 

type HTTPServer 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"`
	Middlewares []*Middleware        `protobuf:"bytes,4,rep,name=middlewares,proto3" json:"middlewares,omitempty"`
	// contains filtered or unexported fields
}

http server config

func (*HTTPServer) Descriptor deprecated 

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

Deprecated: Use HTTPServer.ProtoReflect.Descriptor instead.

func (*HTTPServer) GetAddr 

func (x *HTTPServer) GetAddr() string

func (*HTTPServer) GetMiddlewares 

func (x *HTTPServer) GetMiddlewares() []*Middleware

func (*HTTPServer) GetNetwork 

func (x *HTTPServer) GetNetwork() string

func (*HTTPServer) GetTimeout 

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

func (*HTTPServer) ProtoMessage 

func (*HTTPServer) ProtoMessage()

func (*HTTPServer) ProtoReflect 

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

func (*HTTPServer) Reset 

func (x *HTTPServer) Reset()

func (*HTTPServer) String 

func (x *HTTPServer) String() string

type Logger 

type Logger struct {
	Path     string            `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Level    string            `protobuf:"bytes,2,opt,name=level,proto3" json:"level,omitempty"`
	Console  bool              `protobuf:"varint,3,opt,name=console,proto3" json:"console,omitempty"`
	File     bool              `protobuf:"varint,4,opt,name=file,proto3" json:"file,omitempty"`
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

logger config

func (*Logger) Descriptor deprecated 

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

Deprecated: Use Logger.ProtoReflect.Descriptor instead.

func (*Logger) GetConsole 

func (x *Logger) GetConsole() bool

func (*Logger) GetFile 

func (x *Logger) GetFile() bool

func (*Logger) GetLevel 

func (x *Logger) GetLevel() string

func (*Logger) GetMetadata 

func (x *Logger) GetMetadata() map[string]string

func (*Logger) GetPath 

func (x *Logger) GetPath() string

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 Middleware 

type Middleware struct {
	Name    string     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Options *anypb.Any `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

middleware config

func (*Middleware) Descriptor deprecated 

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

Deprecated: Use Middleware.ProtoReflect.Descriptor instead.

func (*Middleware) GetName 

func (x *Middleware) GetName() string

func (*Middleware) GetOptions 

func (x *Middleware) GetOptions() *anypb.Any

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 Nacos 

type Nacos struct {

	// nacos server address
	Address []string `protobuf:"bytes,1,rep,name=address,proto3" json:"address,omitempty"`
	// nacos config data id
	DataId string `protobuf:"bytes,2,opt,name=data_id,json=dataId,proto3" json:"data_id,omitempty"`
	// nacos config group
	Group string `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`
	// nacos config namespace
	Namespaces string `protobuf:"bytes,4,opt,name=namespaces,proto3" json:"namespaces,omitempty"`
	// nacos config username
	Username string `protobuf:"bytes,5,opt,name=username,proto3" json:"username,omitempty"`
	// nacos config password
	Password string `protobuf:"bytes,6,opt,name=password,proto3" json:"password,omitempty"`
	// nacos config log dir
	LogDir string `protobuf:"bytes,7,opt,name=log_dir,json=logDir,proto3" json:"log_dir,omitempty"`
	// nacos config cache dir
	CacheDir string `protobuf:"bytes,8,opt,name=cache_dir,json=cacheDir,proto3" json:"cache_dir,omitempty"`
	// nacos timeout(ms). default 5000
	Timeout *durationpb.Duration `protobuf:"bytes,10,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// nacos logger level. default info
	LogLevel string `protobuf:"bytes,11,opt,name=log_level,json=logLevel,proto3" json:"log_level,omitempty"`
	// contains filtered or unexported fields
}

nacos config

func (*Nacos) Descriptor deprecated 

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

Deprecated: Use Nacos.ProtoReflect.Descriptor instead.

func (*Nacos) GetAddress 

func (x *Nacos) GetAddress() []string

func (*Nacos) GetCacheDir 

func (x *Nacos) GetCacheDir() string

func (*Nacos) GetDataId 

func (x *Nacos) GetDataId() string

func (*Nacos) GetGroup 

func (x *Nacos) GetGroup() string

func (*Nacos) GetLogDir 

func (x *Nacos) GetLogDir() string

func (*Nacos) GetLogLevel 

func (x *Nacos) GetLogLevel() string

func (*Nacos) GetNamespaces 

func (x *Nacos) GetNamespaces() string

func (*Nacos) GetPassword 

func (x *Nacos) GetPassword() string

func (*Nacos) GetTimeout 

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

func (*Nacos) GetUsername 

func (x *Nacos) GetUsername() string

func (*Nacos) ProtoMessage 

func (*Nacos) ProtoMessage()

func (*Nacos) ProtoReflect 

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

func (*Nacos) Reset 

func (x *Nacos) Reset()

func (*Nacos) String 

func (x *Nacos) String() string

type Next 

type Next struct {

	// service id
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// service name
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// service version
	Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// service metadata
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// registry config
	Registry *Registry `protobuf:"bytes,5,opt,name=registry,proto3" json:"registry,omitempty"`
	// server config
	Server *Server `protobuf:"bytes,6,opt,name=server,proto3" json:"server,omitempty"`
	// logger config
	Logger *Logger `protobuf:"bytes,10,opt,name=logger,proto3" json:"logger,omitempty"`
	// tracing config
	Tracing *Tracing `protobuf:"bytes,11,opt,name=tracing,proto3" json:"tracing,omitempty"`
	// nacos config
	Nacos *Nacos `protobuf:"bytes,12,opt,name=nacos,proto3" json:"nacos,omitempty"`
	// broker config
	Broker *Broker `protobuf:"bytes,13,opt,name=broker,proto3" json:"broker,omitempty"`
	// contains filtered or unexported fields
}

next micro global config

func (*Next) Descriptor deprecated 

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

Deprecated: Use Next.ProtoReflect.Descriptor instead.

func (*Next) GetBroker 

func (x *Next) GetBroker() *Broker

func (*Next) GetId 

func (x *Next) GetId() string

func (*Next) GetLogger 

func (x *Next) GetLogger() *Logger

func (*Next) GetMetadata 

func (x *Next) GetMetadata() map[string]string

func (*Next) GetNacos 

func (x *Next) GetNacos() *Nacos

func (*Next) GetName 

func (x *Next) GetName() string

func (*Next) GetRegistry 

func (x *Next) GetRegistry() *Registry

func (*Next) GetServer 

func (x *Next) GetServer() *Server

func (*Next) GetTracing 

func (x *Next) GetTracing() *Tracing

func (*Next) GetVersion 

func (x *Next) GetVersion() string

func (*Next) ProtoMessage 

func (*Next) ProtoMessage()

func (*Next) ProtoReflect 

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

func (*Next) Reset 

func (x *Next) Reset()

func (*Next) String 

func (x *Next) String() string

type Publish 

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

broker publish config

func (*Publish) Descriptor deprecated 

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

Deprecated: Use Publish.ProtoReflect.Descriptor instead.

func (*Publish) ProtoMessage 

func (*Publish) ProtoMessage()

func (*Publish) ProtoReflect 

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

func (*Publish) Reset 

func (x *Publish) Reset()

func (*Publish) String 

func (x *Publish) String() string

type Registry 

type Registry struct {
	Name    string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`       // 注册中心类型: etcd，consul
	Addrs   string               `protobuf:"bytes,2,opt,name=addrs,proto3" json:"addrs,omitempty"`     // 注册中心地址，多个用逗号隔开
	Timeout *durationpb.Duration `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"` // 注册中心超时时间
	// contains filtered or unexported fields
}

func (*Registry) Descriptor deprecated 

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

Deprecated: Use Registry.ProtoReflect.Descriptor instead.

func (*Registry) GetAddrs 

func (x *Registry) GetAddrs() string

func (*Registry) GetName 

func (x *Registry) GetName() string

func (*Registry) GetTimeout 

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

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 Server 

type Server struct {
	Http *HTTPServer `protobuf:"bytes,1,opt,name=http,proto3" json:"http,omitempty"`
	Grpc *GRPCServer `protobuf:"bytes,2,opt,name=grpc,proto3" json:"grpc,omitempty"`
	// contains filtered or unexported fields
}

server config

func (*Server) Descriptor deprecated 

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

Deprecated: Use Server.ProtoReflect.Descriptor instead.

func (*Server) GetGrpc 

func (x *Server) GetGrpc() *GRPCServer

func (*Server) GetHttp 

func (x *Server) GetHttp() *HTTPServer

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 Subscribe 

type Subscribe struct {
	Queue   string `protobuf:"bytes,1,opt,name=queue,proto3" json:"queue,omitempty"`                     // queue name
	AutoAck bool   `protobuf:"varint,2,opt,name=auto_ack,json=autoAck,proto3" json:"auto_ack,omitempty"` // auto ack
	// contains filtered or unexported fields
}

broker subscribe config

func (*Subscribe) Descriptor deprecated 

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

Deprecated: Use Subscribe.ProtoReflect.Descriptor instead.

func (*Subscribe) GetAutoAck 

func (x *Subscribe) GetAutoAck() bool

func (*Subscribe) GetQueue 

func (x *Subscribe) GetQueue() string

func (*Subscribe) ProtoMessage 

func (*Subscribe) ProtoMessage()

func (*Subscribe) ProtoReflect 

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

func (*Subscribe) Reset 

func (x *Subscribe) Reset()

func (*Subscribe) String 

func (x *Subscribe) String() string

type Tracing 

type Tracing struct {

	// disable tracing
	Disable bool `protobuf:"varint,1,opt,name=disable,proto3" json:"disable,omitempty"`
	// tracing endpoint
	Endpoint string `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// tracing sampler: 0-1, 1 means full sampling, 0 means no sampling
	Sampler float64 `protobuf:"fixed64,3,opt,name=sampler,proto3" json:"sampler,omitempty"`
	// contains filtered or unexported fields
}

tracing config

func (*Tracing) Descriptor deprecated 

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

Deprecated: Use Tracing.ProtoReflect.Descriptor instead.

func (*Tracing) GetDisable 

func (x *Tracing) GetDisable() bool

func (*Tracing) GetEndpoint 

func (x *Tracing) GetEndpoint() string

func (*Tracing) GetSampler 

func (x *Tracing) GetSampler() float64

func (*Tracing) ProtoMessage 

func (*Tracing) ProtoMessage()

func (*Tracing) ProtoReflect 

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

func (*Tracing) Reset 

func (x *Tracing) Reset()

func (*Tracing) String 

func (x *Tracing) 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.