consumerlife

package

v1.0.0 Latest Latest Go to latest Published: Nov 6, 2026 License: MIT Imports: 3 Imported by: 0

Details

Package consumerlife coordinates explicit consumer cancellation and native cleanup.

This section is empty.

This section is empty.

This section is empty.

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

Session permits one consuming loop and one concurrent, idempotent shutdown.

func (s *Session) Begin(ctx context.Context) (context.Context, func(), error)

Begin registers a cancelable consuming loop. Finish must be deferred after successful acquisition.

func (s *Session) Shutdown(ctx context.Context, cleanup func() error) error

Shutdown cancels and waits for the loop before native cleanup. On deadline, cleanup continues and later calls can await it.