package watchapi

import "github.com/moby/swarmkit/v2/manager/watchapi"

Index

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

server.go watch.go

Version
v2.0.0-20250103191802-8c1959736554 (latest)
Published
Jan 3, 2025
Platform
linux/amd64
Imports
8 packages
Last checked
1 week ago

Tools for package owners.