Versions in this module Expand all Collapse all v0 v0.1.0 Feb 1, 2021 Changes in this version + type Encoder interface + Encode func(t time.Time) []byte + type MockEncoder struct + func NewMockEncoder(ctrl *gomock.Controller) *MockEncoder + func (m *MockEncoder) EXPECT() *MockEncoderMockRecorder + func (m *MockEncoder) Encode(t time.Time) []byte + type MockEncoderMockRecorder struct + func (mr *MockEncoderMockRecorder) Encode(t interface{}) *gomock.Call + type MockWriter struct + func NewMockWriter(ctrl *gomock.Controller) *MockWriter + func (m *MockWriter) EXPECT() *MockWriterMockRecorder + func (m *MockWriter) WriteMessage(ctx context.Context, message []byte) error + type MockWriterMockRecorder struct + func (mr *MockWriterMockRecorder) WriteMessage(ctx, message interface{}) *gomock.Call + type Producer struct + func New(writer Writer, encoder Encoder) *Producer + func (p *Producer) Run(ctx context.Context, interval time.Duration) error + type Writer interface + WriteMessage func(ctx context.Context, message []byte) error