Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Item ¶
type Item struct {
Value string // The value of the item; arbitrary.
Priority int64 // The priority of the item in the queue.
// The index is needed by update and is maintained by the heap.Interface methods.
Index int // The index of the item in the heap.
}
An Item is something we manage in a priority queue.
type PriorityQueue ¶
type PriorityQueue []*Item
A PriorityQueue implements heap.Interface and holds Items.
func (PriorityQueue) Len ¶
func (pq PriorityQueue) Len() int
func (PriorityQueue) Less ¶
func (pq PriorityQueue) Less(i, j int) bool
func (*PriorityQueue) Pop ¶
func (pq *PriorityQueue) Pop() interface{}
func (*PriorityQueue) Push ¶
func (pq *PriorityQueue) Push(x interface{})
func (PriorityQueue) Swap ¶
func (pq PriorityQueue) Swap(i, j int)
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
func NewServer ¶
func NewServer(fn ...ServerOption) (*Server, error)
type ServerOption ¶
type ServerOption func(options *serverOptions)
func WithAddr ¶
func WithAddr(v string) ServerOption
func WithCtx ¶
func WithCtx(v context.Context) ServerOption
func WithEndpoints ¶
func WithEndpoints(v []string) ServerOption
func WithId ¶
func WithId(v string) ServerOption
func WithService ¶
func WithService(v string) ServerOption
func WithStopped ¶
func WithStopped(v chan error) ServerOption
Source Files
Click to show internal directories.
Click to hide internal directories.