vnf_kafka

Documentation

Overview

* PPPOE VNF main file * * Created by João Correia(Altice Labs) on 20/03/2023

* PPPOE VNF main file * * Created by João Correia(Altice Labs) on 20/03/2023

Index

• func StartKafkaConnection(config KafkaConnectionConfig, handler KafkaHandler)
• type KafkaConnectionConfig
• type KafkaHandler
• type UnimplementedKafkaHandler
  • func (*UnimplementedKafkaHandler) Action(*kafka.Producer, *pb.Msg)
  • func (*UnimplementedKafkaHandler) GetData(*kafka.Producer, *pb.Msg)
  • func (*UnimplementedKafkaHandler) Hello(*kafka.Producer, *pb.Msg)
  • func (*UnimplementedKafkaHandler) Notification(*kafka.Producer, *pb.Msg)
  • func (*UnimplementedKafkaHandler) RPC(*kafka.Producer, *pb.Msg)
  • func (*UnimplementedKafkaHandler) ReplaceConfig(*kafka.Producer, *pb.Msg)
  • func (*UnimplementedKafkaHandler) UpdateConfig(*kafka.Producer, *pb.Msg)

Functions

func StartKafkaConnection

func StartKafkaConnection(config KafkaConnectionConfig, handler KafkaHandler)

Types

type KafkaConnectionConfig

type KafkaConnectionConfig struct {
	PConfigMap *kafka.ConfigMap
	CConfigMap *kafka.ConfigMap
	CTopics    []string
}

type KafkaHandler

type KafkaHandler interface {
	//request
	Hello(*kafka.Producer, *pb.Msg)
	GetData(*kafka.Producer, *pb.Msg)
	ReplaceConfig(*kafka.Producer, *pb.Msg)
	UpdateConfig(*kafka.Producer, *pb.Msg)
	RPC(*kafka.Producer, *pb.Msg)
	Action(*kafka.Producer, *pb.Msg)

	Notification(*kafka.Producer, *pb.Msg)
}

type UnimplementedKafkaHandler

type UnimplementedKafkaHandler struct{}

func (*UnimplementedKafkaHandler) Action

func (*UnimplementedKafkaHandler) Action(*kafka.Producer, *pb.Msg)

func (*UnimplementedKafkaHandler) GetData

func (*UnimplementedKafkaHandler) GetData(*kafka.Producer, *pb.Msg)

func (*UnimplementedKafkaHandler) Hello

func (*UnimplementedKafkaHandler) Hello(*kafka.Producer, *pb.Msg)

func (*UnimplementedKafkaHandler) Notification

func (*UnimplementedKafkaHandler) Notification(*kafka.Producer, *pb.Msg)

func (*UnimplementedKafkaHandler) RPC

func (*UnimplementedKafkaHandler) RPC(*kafka.Producer, *pb.Msg)

func (*UnimplementedKafkaHandler) ReplaceConfig

func (*UnimplementedKafkaHandler) ReplaceConfig(*kafka.Producer, *pb.Msg)

func (*UnimplementedKafkaHandler) UpdateConfig

func (*UnimplementedKafkaHandler) UpdateConfig(*kafka.Producer, *pb.Msg)