Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type TWithContext ¶
TWithContext is T with context.Context.
func (*TWithContext) GetContext ¶
func (p *TWithContext) GetContext() context.Context
GetContext returns context.Context.
func (*TWithContext) MarshalZerologObject ¶
func (p *TWithContext) MarshalZerologObject(e *zerolog.Event)
MarshalZerologObject writes TWithContext to given zerolog.Event.
func (*TWithContext) String ¶
func (p *TWithContext) String() string
String returns TWithContext as string.
func (*TWithContext) Validate ¶
func (p *TWithContext) Validate() error
Validate returns error if failed validate.
type TopicChanT ¶
type TopicChanT interface {
// Publish returns a '<-chan ChanT' that joins to the given topic.
Publish(ctx context.Context, c <-chan ChanT)
// Publisher returns a 'chan<- ChanT' that joins to the given topic.
Publisher(ctx context.Context) chan<- ChanT
// Subscribe returns a 'chan<- ChanT' that joins to the given topic.
Subscribe(c chan<- ChanT)
}
TopicChanT is a topic.
func GetTopicChanT ¶
func GetTopicChanT(topic interface{}) TopicChanT
GetTopicChanT returns a TopicChanT of the given topic.
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.