Documentation
¶
Index ¶
- Constants
- Variables
- type Client
- func (_c Client) CacheLoad(ctx context.Context, relativeURL string) (res *http.Response, err error)
- func (_c Client) CacheStore(ctx context.Context, relativeURL string) (res *http.Response, err error)
- func (_c Client) DefaultQueue(ctx context.Context, relativeURL string) (res *http.Response, err error)
- func (_c Client) ForHost(host string) Client
- func (_c Client) Home(ctx context.Context, relativeURL string) (res *http.Response, err error)
- func (_c Client) NoQueue(ctx context.Context, relativeURL string) (res *http.Response, err error)
- func (_c Client) WithOptions(opts ...pub.Option) Client
- type MulticastClient
- func (_c MulticastClient) CacheLoad(ctx context.Context, relativeURL string) iter.Seq[*pub.Response]
- func (_c MulticastClient) CacheStore(ctx context.Context, relativeURL string) iter.Seq[*pub.Response]
- func (_c MulticastClient) DefaultQueue(ctx context.Context, relativeURL string) iter.Seq[*pub.Response]
- func (_c MulticastClient) ForHost(host string) MulticastClient
- func (_c MulticastClient) Home(ctx context.Context, relativeURL string) iter.Seq[*pub.Response]
- func (_c MulticastClient) NoQueue(ctx context.Context, relativeURL string) iter.Seq[*pub.Response]
- func (_c MulticastClient) WithOptions(opts ...pub.Option) MulticastClient
Constants ¶
const Description = `The Messaging microservice demonstrates service-to-service communication patterns.`
Description is the human-readable summary of the microservice, surfaced in OpenAPI and discovery.
const Hostname = "messaging.example"
Hostname is the default hostname of the microservice.
const Name = "Messaging"
Name is the decorative PascalCase name of the microservice.
const Version = 230
Version is a generation counter bumped on each regeneration, not a semantic version.
Variables ¶
var CacheLoad = define.Web{ Host: Hostname, Method: "GET", Route: "/cache-load", }
CacheLoad looks up an element in the distributed cache of the microservice.
var CacheStore = define.Web{ Host: Hostname, Method: "GET", Route: "/cache-store", }
CacheStore stores an element in the distributed cache of the microservice.
var DefaultQueue = define.Web{ Host: Hostname, Method: "GET", Route: "/default-queue", }
DefaultQueue demonstrates how the DefaultQueue subscription option is used to create a unicast request/response communication pattern. Only one of the instances of this microservice will respond to each request.
var Home = define.Web{ Host: Hostname, Method: "GET", Route: "/home", }
Home demonstrates making requests using multicast and unicast request/response patterns.
var NoQueue = define.Web{ Host: Hostname, Method: "GET", Route: "/no-queue", LoadBalancing: define.None, }
NoQueue demonstrates how the NoQueue subscription option is used to create a multicast request/response communication pattern. All instances of this microservice will respond to each request.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client is a lightweight proxy for making unicast calls to the microservice.
func (Client) CacheLoad ¶
CacheLoad looks up an element in the distributed cache of the microservice.
func (Client) CacheStore ¶
func (_c Client) CacheStore(ctx context.Context, relativeURL string) (res *http.Response, err error)
CacheStore stores an element in the distributed cache of the microservice.
func (Client) DefaultQueue ¶
func (_c Client) DefaultQueue(ctx context.Context, relativeURL string) (res *http.Response, err error)
DefaultQueue demonstrates how the DefaultQueue subscription option is used to create a unicast request/response communication pattern. Only one of the instances of this microservice will respond to each request.
func (Client) ForHost ¶
ForHost returns a copy of the client with a different hostname to be applied to requests.
func (Client) Home ¶
Home demonstrates making requests using multicast and unicast request/response patterns.
type MulticastClient ¶
type MulticastClient struct {
// contains filtered or unexported fields
}
MulticastClient is a lightweight proxy for making multicast calls to the microservice.
func NewMulticastClient ¶
func NewMulticastClient(caller service.Publisher) MulticastClient
NewMulticastClient creates a new multicast client proxy to the microservice.
func (MulticastClient) CacheLoad ¶
func (_c MulticastClient) CacheLoad(ctx context.Context, relativeURL string) iter.Seq[*pub.Response]
CacheLoad looks up an element in the distributed cache of the microservice.
func (MulticastClient) CacheStore ¶
func (_c MulticastClient) CacheStore(ctx context.Context, relativeURL string) iter.Seq[*pub.Response]
CacheStore stores an element in the distributed cache of the microservice.
func (MulticastClient) DefaultQueue ¶
func (_c MulticastClient) DefaultQueue(ctx context.Context, relativeURL string) iter.Seq[*pub.Response]
DefaultQueue demonstrates how the DefaultQueue subscription option is used to create a unicast request/response communication pattern. Only one of the instances of this microservice will respond to each request.
func (MulticastClient) ForHost ¶
func (_c MulticastClient) ForHost(host string) MulticastClient
ForHost returns a copy of the client with a different hostname to be applied to requests.
func (MulticastClient) Home ¶
Home demonstrates making requests using multicast and unicast request/response patterns.
func (MulticastClient) NoQueue ¶
NoQueue demonstrates how the NoQueue subscription option is used to create a multicast request/response communication pattern. All instances of this microservice will respond to each request.
func (MulticastClient) WithOptions ¶ added in v1.13.1
func (_c MulticastClient) WithOptions(opts ...pub.Option) MulticastClient
WithOptions returns a copy of the client with options to be applied to requests.