package grpcsync

import "google.golang.org/grpc/internal/grpcsync"

Package grpcsync implements additional synchronization primitives built upon the sync package.

Index ¶

• func OnceFunc(f func()) func()
• type CallbackSerializer
• func NewCallbackSerializer(ctx context.Context) *CallbackSerializer
• func (t *CallbackSerializer) Schedule(f func(ctx context.Context))
• type Event
• func NewEvent() *Event
• func (e *Event) Done() <-chan struct{}
• func (e *Event) Fire() bool
• func (e *Event) HasFired() bool

Functions ¶

func OnceFunc ¶

func OnceFunc(f func()) func()

OnceFunc returns a function wrapping f which ensures f is only executed once even if the returned function is executed multiple times.

Types ¶

type CallbackSerializer ¶

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

CallbackSerializer provides a mechanism to schedule callbacks in a synchronized manner. It provides a FIFO guarantee on the order of execution of scheduled callbacks. New callbacks can be scheduled by invoking the Schedule() method.

This type is safe for concurrent access.

func NewCallbackSerializer ¶

func NewCallbackSerializer(ctx context.Context) *CallbackSerializer

NewCallbackSerializer returns a new CallbackSerializer instance. The provided context will be passed to the scheduled callbacks. Users should cancel the provided context to shutdown the CallbackSerializer. It is guaranteed that no callbacks will be executed once this context is canceled.

func (*CallbackSerializer) Schedule ¶

func (t *CallbackSerializer) Schedule(f func(ctx context.Context))

Schedule adds a callback to be scheduled after existing callbacks are run.

Callbacks are expected to honor the context when performing any blocking operations, and should return early when the context is canceled.

type Event ¶

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

Event represents a one-time event that may occur in the future.

func NewEvent ¶

func NewEvent() *Event

NewEvent returns a new, ready-to-use Event.

func (*Event) Done ¶

func (e *Event) Done() <-chan struct{}

Done returns a channel that will be closed when Fire is called.

func (*Event) Fire ¶

func (e *Event) Fire() bool

Fire causes e to complete. It is safe to call multiple times, and concurrently. It returns true iff this call to Fire caused the signaling channel returned by Done to close.

func (*Event) HasFired ¶

func (e *Event) HasFired() bool

HasFired returns true if Fire has been called.

Source Files ¶

callback_serializer.go event.go oncefunc.go