buffer

Documentation

Overview

Package buffer is defined below

Index

• type PublisherTask
• type PublisherTaskBuffer
  • func NewChannelBasedPublisherTaskBuffer(capacity int, sharedTaskQueueGetter func() chan core.SendTask) PublisherTaskBuffer

Types

type PublisherTask

type PublisherTask func(chan struct{})

PublisherTask task

type PublisherTaskBuffer

type PublisherTaskBuffer interface {
	// the main executor loop that should be started on a new goroutine
	Run()
	// Call to submit into the buffer, will succeed unless we are terminating
	Submit(task PublisherTask) bool
	// Call to terminate that will attempt to shutdown gracefully
	Terminate(timer *time.Timer) bool
	// Call terminate without waiting for the event loop to complete
	TerminateNow()
}

PublisherTaskBuffer interface

func NewChannelBasedPublisherTaskBuffer

func NewChannelBasedPublisherTaskBuffer(capacity int, sharedTaskQueueGetter func() chan core.SendTask) PublisherTaskBuffer

NewChannelBasedPublisherTaskBuffer function