watcherservice

Documentation

Index

• func GetAnnotationVal(key string, annotations map[string]string) (string, error)
• type Client
  • func NewClient(ctx context.Context, logger logr.Logger, addr, port string, ...) (*Client, error)
  • func (c *Client) GetServerParams() (addr, port string)
  • func (c *Client) SendEvent(ctx context.Context, params watcher.EventParameters) (pb.ResponseType, error)

Functions

func GetAnnotationVal

func GetAnnotationVal(key string, annotations map[string]string) (
	string, error)

Types

type Client

type Client struct {
	Cancel context.CancelFunc

	Addr, Port string
	pb.WatcherServiceClient
	// contains filtered or unexported fields
}

func NewClient

func NewClient(ctx context.Context, logger logr.Logger, addr,
	port string, opts ...grpc.DialOption) (*Client, error)

func (*Client) GetServerParams

func (c *Client) GetServerParams() (addr, port string)

func (*Client) SendEvent

func (c *Client) SendEvent(ctx context.Context, params watcher.EventParameters) (
	pb.ResponseType, error)

SendEvent takes the event params from watcherStore and sends a pb.EventRequest to edgewatcher server