model

package

v1.2.0 Latest Latest Go to latest Published: Jul 14, 2025 License: Apache-2.0 Imports: 3 Imported by: 0

Details

View Source

const (
	GRPCTransport  = "grpc"
	KafkaTransport = "kafka"
)

View Source

var (
	ErrEmptyHandlers      = errors.New("empty handlers")
	ErrInvalidMessageType = errors.New("invalid message type")
)

This section is empty.

type Config struct {
	ServiceName   string
	TransportType string
	GRPCAddresses string
	KafkaTopic    string
	Enabled       bool
}

func NewConfig(cfg *config.Config) *Config

type HandlerFunc func(messageCode string, h json.RawMessage) error

type HandlerTransport func(messageType, messageCode string, payload json.RawMessage) error