monza

README

monza

A friendly event rounting library to multiple destinations.

Destination Implementation

• Opensearch

Middlewares

• gin-gonic

Documentation

Index

• type Client
  • func Get(ctx context.Context, config Config) Client
• type Config
• type Destination
• type Event
  • func (e Event) JSON() []byte
• type ServiceID

Types

type Client

type Client interface {
	RegisterDestination(ctx context.Context, destination Destination) error
	Record(events Event)
	Teardown(ctx context.Context)
}

func Get

func Get(ctx context.Context, config Config) Client

type Config

type Config struct {
	IpAddress    string
	Destinations []Destination
}

type Destination

type Destination interface {
	Setup(ctx context.Context) error
	Record(ctx context.Context, event Event)
	Teardown(ctx context.Context)
}

type Event

type Event struct {
	Event      string      `json:"event,omitempty"`
	Data       interface{} `json:"data,omitempty"`
	ID         int64       `json:"id,omitempty"`
	ClientTime time.Time   `json:"client_time,omitempty"`
	IPAddr     string      `json:"ip_addr"`
	ServiceID  ServiceID   `json:"service_id"`
}

func (Event) JSON

func (e Event) JSON() []byte

type ServiceID

type ServiceID string