mongo

Documentation

Index

• Constants
• type Mongo
  • func New(ctx context.Context, config util.Config) (result *Mongo, err error)
  • func (this *Mongo) Save(incident messages.KafkaIncidentMessage) error

Constants

const TIMEOUT = 2 * time.Second

Types

type Mongo

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

func New

func New(ctx context.Context, config util.Config) (result *Mongo, err error)

func (*Mongo) Save

func (this *Mongo) Save(incident messages.KafkaIncidentMessage) error