Documentation
¶
Index ¶
- func GetFanoutTerminate(ctx context.Context, fn func(context.Context) ([]context.Context, error), ...) (chan<- context.Context, <-chan context.Context)
- func GetPipeTerminate(ctx context.Context, fn func(context.Context) (context.Context, error), ...) (chan<- context.Context, <-chan context.Context)
- func Terminate(ctx context.Context) (context.Context, error)
- type TerminateGetContexter
- type TopicContextContext
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetFanoutTerminate ¶
func GetFanoutTerminate( ctx context.Context, fn func(context.Context) ([]context.Context, error), fnErr func(context.Context, error) bool, ) ( chan<- context.Context, <-chan context.Context, )
GetFanoutTerminate returns new input(chan<- ContextContext)/output(<-chan ContextContext) channels that embedded the given 'func(ContextContext) ContextContext'.
func GetPipeTerminate ¶
func GetPipeTerminate( ctx context.Context, fn func(context.Context) (context.Context, error), fnErr func(context.Context, error) bool, ) ( chan<- context.Context, <-chan context.Context, )
GetPipeTerminate returns new input(chan<- ContextContext)/output(<-chan ContextContext) channels that embedded the given 'func(ContextContext) ContextContext'.
Types ¶
type TerminateGetContexter ¶
type TopicContextContext ¶
type TopicContextContext interface {
// Publish returns a '<-chan ContextContext' that joins to the given topic.
Publish(ctx context.Context, c <-chan context.Context)
// Publisher returns a 'chan<- ContextContext' that joins to the given topic.
Publisher(ctx context.Context) chan<- context.Context
// Subscribe returns a 'chan<- ContextContext' that joins to the given topic.
Subscribe(c chan<- context.Context)
}
TopicContextContext is a topic.
func GetTopicContextContext ¶
func GetTopicContextContext(topic interface{}) TopicContextContext
GetTopicContextContext returns a TopicContextContext of the given topic.
Source Files
Click to show internal directories.
Click to hide internal directories.