servicelog

Documentation

Overview

Package servicelog contains an implementation of Producer interface that can be used to produce (that is send) messages to Service Log.

Index

• type Producer
  • func New(config *conf.ServiceLogConfiguration, ocmClient ocmclient.OCMClient) (*Producer, error)
  • func (producer *Producer) Close() error
  • func (producer *Producer) ProduceMessage(msg types.ProducerMessage) (partitionID int32, offset int64, err error)

Types

type Producer

type Producer struct {
	Configuration              conf.ServiceLogConfiguration
	OCMClient                  ocmclient.OCMClient
	AccessToken                string
	TokenRefreshmentCounter    int
	TokenRefreshmentStartDelay time.Duration
	TokenRefreshmentDelay      time.Duration
	TokenRefreshmentThreshold  time.Duration
}

Producer is an implementation of Producer interface for Service Log

func New

func New(config *conf.ServiceLogConfiguration, ocmClient ocmclient.OCMClient) (*Producer, error)

New constructs a new instance of Producer implementation

func (*Producer) Close

func (producer *Producer) Close() error

Close closes Producer (in case of Service Log implementation, it does not do anything)

func (*Producer) ProduceMessage

func (producer *Producer) ProduceMessage(msg types.ProducerMessage) (partitionID int32, offset int64, err error)

ProduceMessage sends the given message to Service Log