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 ¶
Start starts the watch server.
func (*Server) Stop ¶
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 ¶
- 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.