eventstore

Documentation

Index

• type Config
• type EventStore
  • func NewEventStore(log *zap.Logger, config *Config, eventsStreaming *event.EventsStreaming, ...) *EventStore
  • func (eventStore *EventStore) Listen()

Types

type Config

type Config struct {
	ListenAddress          string `toml:"listen_address"`
	DatabaseAddress        string `toml:"database_address"`
	DatabaseName           string `toml:"database_name"`
	NATSClusterID          string `toml:"nats_cluster_id"`
	NATSURL                string `toml:"nats_url"`
	GRPCTLSCertificateFile string `toml:"grpc_tls_certificate_file"`
	GRPCTLSKeyFile         string `toml:"grpc_tls_key_file"`
}

Config of EventStore service.

type EventStore

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

EventStore defines gRPC handler for REST API and NATS events propagator.

func NewEventStore

func NewEventStore(
	log *zap.Logger,
	config *Config,
	eventsStreaming *event.EventsStreaming,
	authDelivery *authDelivery.AuthenticateDelivery,
	employeeRepository employee.Repository,
	roleRepository role.Repository,
) *EventStore

NewEventStore returns new event store service.

func (*EventStore) Listen

func (eventStore *EventStore) Listen()

Listen to gRPC calls.