objsender

Documentation

Index

• type Model
• type Session
  • func Root(agent rpcdef.Agent, objectType string) (*Session, error)
  • func RootTracking(agent rpcdef.Agent, trackingName string) (*Session, error)
  • func (s *Session) Done() error
  • func (s *Session) DoneLastProcessed(lastProcess string) error
  • func (s *Session) IncProgress() error
  • func (s *Session) LastProcessed() string
  • func (s *Session) LastProcessedTime() time.Time
  • func (s *Session) Rollback() error
  • func (s *Session) Send(obj Model) error
  • func (s *Session) SendMap(m map[string]interface{}) error
  • func (par *Session) Session(objectType string, parentObjectID string, parentObjectName string) (*Session, error)
  • func (par *Session) SessionTracking(objectType string, parentObjectID string, parentObjectName string) (*Session, error)
  • func (s *Session) SetNoAutoProgress(v bool)
  • func (s *Session) SetTotal(total int) error
• type SessionTracking

Types

type Model

type Model interface {
	ToMap() map[string]interface{}
}

type Session

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

func Root

func Root(agent rpcdef.Agent, objectType string) (*Session, error)

func RootTracking

func RootTracking(agent rpcdef.Agent, trackingName string) (*Session, error)

func (*Session) Done

func (s *Session) Done() error

func (*Session) DoneLastProcessed

func (s *Session) DoneLastProcessed(lastProcess string) error

func (*Session) IncProgress

func (s *Session) IncProgress() error

func (*Session) LastProcessed

func (s *Session) LastProcessed() string

func (*Session) LastProcessedTime

func (s *Session) LastProcessedTime() time.Time

func (*Session) Rollback

func (s *Session) Rollback() error

func (*Session) Send

func (s *Session) Send(obj Model) error

func (*Session) SendMap

func (s *Session) SendMap(m map[string]interface{}) error

func (*Session) Session

func (par *Session) Session(objectType string, parentObjectID string, parentObjectName string) (*Session, error)

func (*Session) SessionTracking

func (par *Session) SessionTracking(objectType string, parentObjectID string, parentObjectName string) (*Session, error)

func (*Session) SetNoAutoProgress

func (s *Session) SetNoAutoProgress(v bool)

func (*Session) SetTotal

func (s *Session) SetTotal(total int) error

type SessionTracking

type SessionTracking struct {
	Session
}