Documentation ¶
Index ¶
- Variables
- func Run(c *cli.Context) error
- func Watch(id string) (*watcher, error)
- func Watcher(ctx context.Context, ch *pb.WatchResponse) error
- type Config
- func (c *Config) Create(ctx context.Context, req *pb.CreateRequest, rsp *pb.CreateResponse) error
- func (c *Config) Delete(ctx context.Context, req *pb.DeleteRequest, rsp *pb.DeleteResponse) error
- func (c *Config) List(ctx context.Context, req *pb.ListRequest, rsp *pb.ListResponse) (err error)
- func (c *Config) Read(ctx context.Context, req *pb.ReadRequest, rsp *pb.ReadResponse) error
- func (c *Config) Update(ctx context.Context, req *pb.UpdateRequest, rsp *pb.UpdateResponse) error
- func (c *Config) Watch(ctx context.Context, req *pb.WatchRequest, stream pb.Config_WatchStream) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // Flags specific to the config service Flags = []cli.Flag{ &cli.StringFlag{ Name: "watch_topic", EnvVars: []string{"MICRO_CONFIG_WATCH_TOPIC"}, Usage: "watch the change event.", }, } )
Functions ¶
Types ¶
type Config ¶
type Config struct{}
func (*Config) Create ¶
func (c *Config) Create(ctx context.Context, req *pb.CreateRequest, rsp *pb.CreateResponse) error
func (*Config) Delete ¶
func (c *Config) Delete(ctx context.Context, req *pb.DeleteRequest, rsp *pb.DeleteResponse) error
func (*Config) List ¶
func (c *Config) List(ctx context.Context, req *pb.ListRequest, rsp *pb.ListResponse) (err error)
func (*Config) Read ¶
func (c *Config) Read(ctx context.Context, req *pb.ReadRequest, rsp *pb.ReadResponse) error
func (*Config) Update ¶
func (c *Config) Update(ctx context.Context, req *pb.UpdateRequest, rsp *pb.UpdateResponse) error
func (*Config) Watch ¶
func (c *Config) Watch(ctx context.Context, req *pb.WatchRequest, stream pb.Config_WatchStream) error
Click to show internal directories.
Click to hide internal directories.