watchapi

package
v1.12.1-0...-676f45f Latest Latest
Warning

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

 Go to latest Published: Apr 14, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Server 

type Server struct {
	// contains filtered or unexported fields
}

Server is the store API gRPC server.

func NewServer 

func NewServer(store *store.MemoryStore) *Server

NewServer creates a store API server.

func (*Server) Start 

func (s *Server) Start(ctx context.Context) error

Start starts the watch server.

func (*Server) Stop 

func (s *Server) Stop() error

Stop stops the watch server.

func (*Server) Watch 

func (s *Server) Watch(request *api.WatchRequest, stream api.Watch_WatchServer) error

Watch starts a stream that returns any changes to objects that match the specified selectors. When the stream begins, it immediately sends an empty message back to the client. It is important to wait for this message before taking any actions that depend on an established stream of changes for consistency.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.