repository

Documentation

Index

• func Close(ctx context.Context)
• func Conn(ctx context.Context) (e error)
• type Event
  • func NewEvent(aggType string, aggId string, dateTime string, eventId string, ...) *Event
  • func (event *Event) Save(ctx context.Context) error

Functions

func Close

func Close(ctx context.Context)

func Conn

func Conn(ctx context.Context) (e error)

Types

type Event

type Event struct {
	AggType   string `json:"agg_type"`
	AggId     string `json:"agg_id"`
	DateTime  string `json:"date_time"`
	EventId   string `json:"event_id"`
	EventType string `json:"event_type"`
	Data      []byte `json:"data"`
}

{"agg_type":"",agg_id:"",date_time:"",events:[{event_id:"",data:"",type:""},{event_id:"",data:""}]}

func NewEvent

func NewEvent(aggType string, aggId string, dateTime string, eventId string, eventType string, data []byte) *Event

func (*Event) Save

func (event *Event) Save(ctx context.Context) error