history

Documentation

Index

• Constants
• type Failure
  • func (self *Failure) DeleteFailure(req *request.Request)
  • func (self *Failure) PullFailure() map[string]*request.Request
  • func (self *Failure) UpsertFailure(req *request.Request) bool
• type Historier
  • func New(name string, subName string) Historier
• type History
  • func (self *History) Empty()
  • func (self *History) FlushFailure(provider string)
  • func (self *History) FlushSuccess(provider string)
  • func (self *History) ReadFailure(provider string, inherit bool)
  • func (self *History) ReadSuccess(provider string, inherit bool)
• type Success
  • func (self *Success) DeleteSuccess(reqUnique string)
  • func (self *Success) HasSuccess(reqUnique string) bool
  • func (self *Success) UpsertSuccess(reqUnique string) bool

Constants

const (
	SUCCESS_SUFFIX = config.HISTORY_TAG + "__y"
	FAILURE_SUFFIX = config.HISTORY_TAG + "__n"
	SUCCESS_FILE   = config.HISTORY_DIR + "/" + SUCCESS_SUFFIX
	FAILURE_FILE   = config.HISTORY_DIR + "/" + FAILURE_SUFFIX
)

Types

type Failure

type Failure struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*Failure) DeleteFailure

func (self *Failure) DeleteFailure(req *request.Request)

func (*Failure) PullFailure

func (self *Failure) PullFailure() map[string]*request.Request

func (*Failure) UpsertFailure

func (self *Failure) UpsertFailure(req *request.Request) bool

type Historier

type Historier interface {
	ReadSuccess(provider string, inherit bool)
	UpsertSuccess(string) bool
	HasSuccess(string) bool
	DeleteSuccess(string)
	FlushSuccess(provider string)

	ReadFailure(provider string, inherit bool)
	PullFailure() map[string]*request.Request
	UpsertFailure(*request.Request) bool
	DeleteFailure(*request.Request)
	FlushFailure(provider string)

	Empty()
}

func New

func New(name string, subName string) Historier

type History

type History struct {
	*Success
	*Failure

	sync.RWMutex
	// contains filtered or unexported fields
}

func (*History) Empty

func (self *History) Empty()

func (*History) FlushFailure

func (self *History) FlushFailure(provider string)

func (*History) FlushSuccess

func (self *History) FlushSuccess(provider string)

func (*History) ReadFailure

func (self *History) ReadFailure(provider string, inherit bool)

func (*History) ReadSuccess

func (self *History) ReadSuccess(provider string, inherit bool)

type Success

type Success struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*Success) DeleteSuccess

func (self *Success) DeleteSuccess(reqUnique string)

func (*Success) HasSuccess

func (self *Success) HasSuccess(reqUnique string) bool

func (*Success) UpsertSuccess

func (self *Success) UpsertSuccess(reqUnique string) bool