Retracted: Withdrawn; the module proxy serves these against commits that no longer exist here.

http

package

v1.8.0 Latest Latest Go to latest Published: Sep 3, 2026 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/gsoultan/hermod

Links

Open Source Insights

Documentation ¶

Index ¶

type HttpSink
- func NewHttpSink(url string, formatter hermod.Formatter, headers map[string]string) *HttpSink

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type HttpSink ¶

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

func NewHttpSink ¶

func NewHttpSink(url string, formatter hermod.Formatter, headers map[string]string) *HttpSink

func (*HttpSink) Close ¶

func (s *HttpSink) Close() error

func (*HttpSink) Ping ¶

func (s *HttpSink) Ping(ctx context.Context) error

func (*HttpSink) SetCompressor ¶

func (s *HttpSink) SetCompressor(comp compression.Compressor)

func (*HttpSink) SetPingMethod ¶

func (s *HttpSink) SetPingMethod(method string)

func (*HttpSink) SetTimeout ¶

func (s *HttpSink) SetTimeout(d time.Duration)

SetTimeout bounds every exchange — dial, write, response — replacing the default. Zero disables the bound, which is what it was before this existed: a sink that blocks forever on a server that accepts and never answers.

func (*HttpSink) Write ¶

func (s *HttpSink) Write(ctx context.Context, msg hermod.Message) error

func (*HttpSink) WriteBatch ¶

func (s *HttpSink) WriteBatch(ctx context.Context, msgs []hermod.Message) error

Source Files ¶

View all Source files

http.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL