Documentation
¶
Index ¶
- type Config
- type RegProxy
- func (proxy *RegProxy) C() <-chan *structs.ServiceNode
- func (proxy *RegProxy) Close()
- func (proxy *RegProxy) LoadServiceConfiguration(appName string) (*structs.AppConfiguration, bool)
- func (proxy *RegProxy) Put(ctx context.Context, in *pb.PutRequest) (out *pb.PutResponse, err error)
- func (proxy *RegProxy) SayHello(ctx context.Context, request *helloworld.HelloRequest) (*helloworld.HelloReply, error)
- func (proxy *RegProxy) Start() error
- func (proxy *RegProxy) StoreServiceConfiguration(key string, conf *structs.AppConfiguration)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
EndPoints []string `json:"endpoints"`
Timeout time.Duration
Secure bool
Enable bool // Whether to open the open plug-in
}
Config regConfig
type RegProxy ¶
type RegProxy struct {
pb.KVServer
pb.LeaseServer
pb.WatchServer
*etcdv3.Client
// contains filtered or unexported fields
}
RegProxy ...
func (*RegProxy) LoadServiceConfiguration ¶
func (proxy *RegProxy) LoadServiceConfiguration(appName string) (*structs.AppConfiguration, bool)
LoadServiceConfiguration ...
func (*RegProxy) Put ¶
func (proxy *RegProxy) Put(ctx context.Context, in *pb.PutRequest) (out *pb.PutResponse, err error)
Put Intercept the service registration request, register and rewrite the registration information
func (*RegProxy) SayHello ¶
func (proxy *RegProxy) SayHello(ctx context.Context, request *helloworld.HelloRequest) (*helloworld.HelloReply, error)
SayHello ...
func (*RegProxy) StoreServiceConfiguration ¶
func (proxy *RegProxy) StoreServiceConfiguration(key string, conf *structs.AppConfiguration)
StoreServiceConfiguration ...
Source Files
Click to show internal directories.
Click to hide internal directories.