Documentation
¶
Index ¶
- func NewMaterializerRequest(srvReq structs.ServiceSpecificRequest) func(index uint64) *pbsubscribe.SubscribeRequest
- type Client
- func (c *Client) IsReadyForStreaming() bool
- func (c *Client) Notify(ctx context.Context, req structs.ServiceSpecificRequest, correlationID string, ...) error
- func (c *Client) ServiceNodes(ctx context.Context, req structs.ServiceSpecificRequest) (structs.IndexedCheckServiceNodes, cache.ResultMeta, error)
- type HealthView
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewMaterializerRequest ¶
func NewMaterializerRequest(srvReq structs.ServiceSpecificRequest) func(index uint64) *pbsubscribe.SubscribeRequest
Types ¶
type Client ¶
Client provides access to service health data.
func (*Client) IsReadyForStreaming ¶
IsReadyForStreaming will indicate if the underlying gRPC connection is ready.
func (*Client) ServiceNodes ¶
func (c *Client) ServiceNodes( ctx context.Context, req structs.ServiceSpecificRequest, ) (structs.IndexedCheckServiceNodes, cache.ResultMeta, error)
type HealthView ¶
type HealthView struct {
// contains filtered or unexported fields
}
HealthView implements submatview.View for storing the view state of a service health result. We store it as a map to make updates and deletions a little easier but we could just store a result type (IndexedCheckServiceNodes) and update it in place for each event - that involves re-sorting each time etc. though.
func NewHealthView ¶
func NewHealthView(req structs.ServiceSpecificRequest) (*HealthView, error)
func (*HealthView) Reset ¶
func (s *HealthView) Reset()
func (*HealthView) Result ¶
func (s *HealthView) Result(index uint64) interface{}
Result returns the structs.IndexedCheckServiceNodes stored by this view.
func (*HealthView) Update ¶
func (s *HealthView) Update(events []*pbsubscribe.Event) error
Update implements View
Source Files
Click to show internal directories.
Click to hide internal directories.