()
| 121 | } |
| 122 | |
| 123 | func ExampleService_AddGroup() { |
| 124 | nc, err := nats.Connect("127.0.0.1:4222") |
| 125 | if err != nil { |
| 126 | log.Fatal(err) |
| 127 | } |
| 128 | defer nc.Close() |
| 129 | |
| 130 | echoHandler := func(req micro.Request) { |
| 131 | req.Respond(req.Data()) |
| 132 | } |
| 133 | |
| 134 | config := micro.Config{ |
| 135 | Name: "EchoService", |
| 136 | Version: "1.0.0", |
| 137 | } |
| 138 | |
| 139 | srv, err := micro.AddService(nc, config) |
| 140 | if err != nil { |
| 141 | log.Fatal(err) |
| 142 | } |
| 143 | |
| 144 | v1 := srv.AddGroup("v1") |
| 145 | |
| 146 | // endpoint will be registered under "v1.Echo" subject |
| 147 | err = v1.AddEndpoint("Echo", micro.HandlerFunc(echoHandler)) |
| 148 | if err != nil { |
| 149 | log.Fatal(err) |
| 150 | } |
| 151 | } |
| 152 | |
| 153 | func ExampleService_Info() { |
| 154 | nc, err := nats.Connect("127.0.0.1:4222") |
nothing calls this directly
no test coverage detected