health

package
v1.16.0-rc1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 10, 2023 License: MPL-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewMaterializerRequest added in v1.13.0

func NewMaterializerRequest(srvReq structs.ServiceSpecificRequest) func(index uint64) *pbsubscribe.SubscribeRequest

Types

type Client

type Client struct {
	rpcclient.Client
}

Client provides access to service health data.

func (*Client) IsReadyForStreaming added in v1.12.7

func (c *Client) IsReadyForStreaming() bool

IsReadyForStreaming will indicate if the underlying gRPC connection is ready.

func (*Client) Notify added in v1.10.0

func (c *Client) Notify(
	ctx context.Context,
	req structs.ServiceSpecificRequest,
	correlationID string,
	cb cache.Callback,
) error

type HealthView added in v1.13.0

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 added in v1.13.0

func NewHealthView(req structs.ServiceSpecificRequest) (*HealthView, error)

func (*HealthView) Reset added in v1.13.0

func (s *HealthView) Reset()

func (*HealthView) Result added in v1.13.0

func (s *HealthView) Result(index uint64) interface{}

Result returns the structs.IndexedCheckServiceNodes stored by this view.

func (*HealthView) Update added in v1.13.0

func (s *HealthView) Update(events []*pbsubscribe.Event) error

Update implements View

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL