services

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

type Event struct {
	Topic      string
	Connnector string
	Operation  string
}

type JwtClaims struct {
	AuthorizedParty string `json:"azp,omitempty"`
	jwt.StandardClaims
}

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

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

type MockPublisher struct {
}

type Publisher interface {
	PublishToKafka(string, map[string][]byte, []byte)
}

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