inoltralog

Documentation

Index

• func InviaRecordRedisRemoto(ctx context.Context, record string) (err error)
• func LocalKafkaProducer(ctx context.Context, topic string, s []string) (err error)
• func RemoteKafkaProducer(ctx context.Context, remotekafkaserver, topic string, s []string) (err error)
• func TestRemoteRedisServer(ctx context.Context) (err error)
• func VerificaLocalKafka(ctx context.Context) (err error)
• func VerificaRemoteKafka(ctx context.Context, remotekafkaserver string) (err error)

Functions

func InviaRecordRedisRemoto

func InviaRecordRedisRemoto(ctx context.Context, record string) (err error)

InviaRecordRedisRemoto invia un record al Redis Server Remoto.

func LocalKafkaProducer

func LocalKafkaProducer(ctx context.Context, topic string, s []string) (err error)

LocalKafkaProducer invia records a una istanza kafka locale.

func RemoteKafkaProducer

func RemoteKafkaProducer(ctx context.Context, remotekafkaserver, topic string, s []string) (err error)

RemoteKafkaProducer invia records a una istanza kafka locale.

func TestRemoteRedisServer

func TestRemoteRedisServer(ctx context.Context) (err error)

TestRemoteRedisServer verifica la raggiungibilità del server Redis remoto.

func VerificaLocalKafka

func VerificaLocalKafka(ctx context.Context) (err error)

VerificaLocalKafka verifica se l'instanza è raggiungibile.

func VerificaRemoteKafka

func VerificaRemoteKafka(ctx context.Context, remotekafkaserver string) (err error)

VerificaRemoteKafka verifica se l'instanza è raggiungibile.