journal

Documentation

Index

• Constants
• type Index
  • func (index Index) AddJournalEntry(entry *JournalEntry)
• type Journal
  • func NewJournal() *Journal
  • func (this *Journal) AddIndex(indexKey string) error
  • func (this *Journal) DeleteEntries() error
  • func (this *Journal) DeleteIndex(indexKey string)
  • func (this *Journal) GetAllIndexes() []v2.JournalIndexView
  • func (this *Journal) GetEntries(offset int, limit int, from *time.Time, to *time.Time, sort string) (v2.JournalView, error)
  • func (this *Journal) GetFilteredEntries(journalEntryFilterView v2.JournalEntryFilterView) ([]v2.JournalEntryView, error)
  • func (this *Journal) NewEntry(request *http.Request, response *http.Response, mode string, started time.Time) (string, error)
  • func (journal *Journal) UpdatePostServeActionDetailsInJournal(id string, actionName, correlationID string, ...)
• type JournalEntry
• type PostServeActionEntry
• type Request

Constants

const RFC3339Milli = "2006-01-02T15:04:05.000Z07:00"

Types

type Index

type Index struct {
	Name string

	Entries map[string]*JournalEntry
	// contains filtered or unexported fields
}

func (Index) AddJournalEntry

func (index Index) AddJournalEntry(entry *JournalEntry)

type Journal

type Journal struct {
	Indexes    []Index
	EntryLimit int
	// contains filtered or unexported fields
}

func NewJournal

func NewJournal() *Journal

func (*Journal) AddIndex

func (this *Journal) AddIndex(indexKey string) error

func (*Journal) DeleteEntries

func (this *Journal) DeleteEntries() error

func (*Journal) DeleteIndex

func (this *Journal) DeleteIndex(indexKey string)

func (*Journal) GetAllIndexes

func (this *Journal) GetAllIndexes() []v2.JournalIndexView

func (*Journal) GetEntries

func (this *Journal) GetEntries(offset int, limit int, from *time.Time, to *time.Time, sort string) (v2.JournalView, error)

func (*Journal) GetFilteredEntries

func (this *Journal) GetFilteredEntries(journalEntryFilterView v2.JournalEntryFilterView) ([]v2.JournalEntryView, error)

func (*Journal) NewEntry

func (this *Journal) NewEntry(request *http.Request, response *http.Response, mode string, started time.Time) (string, error)

func (*Journal) UpdatePostServeActionDetailsInJournal

func (journal *Journal) UpdatePostServeActionDetailsInJournal(id string, actionName, correlationID string, invokedTime, completedTime time.Time, httpStatus int)

type JournalEntry

type JournalEntry struct {
	Request              *models.RequestDetails
	Response             *models.ResponseDetails
	Mode                 string
	TimeStarted          time.Time
	Latency              time.Duration
	Id                   string
	PostServeActionEntry *PostServeActionEntry
}

type PostServeActionEntry

type PostServeActionEntry struct {
	ActionName    string
	InvokedTime   time.Time
	CompletedTime time.Time
	CorrelationId string
	HttpStatus    int
}

type Request

type Request struct {
	QueryParam map[string][]string
	Header     map[string][]string
	Path       []string
	Scheme     string
	FormData   map[string][]string
	Body       func(queryType, query string, options *raymond.Options) interface{}
	BodyStr    string
	Method     string
}