type entry … type channelMap … func newChannelMap() *channelMap { … } func (c *channelMap) addServer(id int64, s *Server) { … } func (c *channelMap) addChannel(id int64, cn *Channel, isTopChannel bool, pid int64) { … } func (c *channelMap) addSubChannel(id int64, sc *SubChannel, pid int64) { … } func (c *channelMap) addSocket(s *Socket) { … } // removeEntry triggers the removal of an entry, which may not indeed delete the // entry, if it has to wait on the deletion of its children and until no other // entity's channel trace references it. It may lead to a chain of entry // deletion. For example, deleting the last socket of a gracefully shutting down // server will lead to the server being also deleted. func (c *channelMap) removeEntry(id int64) { … } type tracedChannel … // c.mu must be held by the caller func (c *channelMap) decrTraceRefCount(id int64) { … } // c.mu must be held by the caller. func (c *channelMap) findEntry(id int64) entry { … } // c.mu must be held by the caller // // deleteEntry deletes an entry from the channelMap. Before calling this method, // caller must check this entry is ready to be deleted, i.e removeEntry() has // been called on it, and no children still exist. func (c *channelMap) deleteEntry(id int64) entry { … } func (c *channelMap) traceEvent(id int64, desc *TraceEvent) { … } type int64Slice … func (s int64Slice) Len() int { … } func (s int64Slice) Swap(i, j int) { … } func (s int64Slice) Less(i, j int) bool { … } func copyMap(m map[int64]string) map[int64]string { … } func min(a, b int) int { … } func (c *channelMap) getTopChannels(id int64, maxResults int) ([]*Channel, bool) { … } func (c *channelMap) getServers(id int64, maxResults int) ([]*Server, bool) { … } func (c *channelMap) getServerSockets(id int64, startID int64, maxResults int) ([]*Socket, bool) { … } func (c *channelMap) getChannel(id int64) *Channel { … } func (c *channelMap) getSubChannel(id int64) *SubChannel { … } func (c *channelMap) getSocket(id int64) *Socket { … } func (c *channelMap) getServer(id int64) *Server { … } type dummyEntry … func (d *dummyEntry) String() string { … } func (d *dummyEntry) ID() int64 { … } func (d *dummyEntry) addChild(id int64, e entry) { … } func (d *dummyEntry) deleteChild(id int64) { … } func (d *dummyEntry) triggerDelete() { … } func (*dummyEntry) deleteSelfIfReady() { … } func (*dummyEntry) getParentID() int64 { … } type Entity …
Codebase Browser
kubernetes