rprt

type Factory interface {
	CreateRedialSleepTime() time.Duration
	CreateLog(Stream) (Log, error)
	CreateStream(brokers []string, r Rprt) (Stream, error)
	CreateUserMethods() (UserMethods, error)
	CreateUsers(UserMethods, Factory) (Users, error)
	CreateUser(login string, membership Membership, rights []Rights) (User, error)
	CreateReports() (Reports, error)
}

type Group struct {
	Domain string
	Name   string
}

type Log interface {
	// Close closes the service.
	Close()

	// Subscribe creates a subscription to log-messages.
	Subscribe() (LogSubscription, error)

	// Fatal formats and sends error message in the queue and prints to the standard logger and calls to os.Exit(1).
	Fatal(format string, args ...interface{})
	// Error formats and sends error message in the queue and prints to the standard logger.
	Error(format string, args ...interface{})
	// Warn formats and sends warning message in the queue and prints to the standard logger.
	Warn(format string, args ...interface{})
	// Info formats and sends information message in the queue and prints to the standard logger.
	Info(format string, args ...interface{})
	// Debug formats and sends debug message in the queue and prints to the standard logger.
	Debug(format string, args ...interface{})
}

type LogRecord interface {
	// GetSequenceNumber returns record sequence number.
	GetSequenceNumber() int64
	// GetTime returns record time.
	GetTime() time.Time
	// GetText returns record text.
	GetText() string
	// GetSeverity returns record severity.
	GetSeverity() string
	// GetNodeType returns author node type name.
	GetNodeType() string
	// GetNodeName returns author node instance name.
	GetNodeName() string
}

type LogSubscription interface {
	Subscription
	// GetChan resturns incoming records channel.
	GetChan() <-chan LogRecord
}

type Member interface {
	// GetMembership returns user membership.
	GetMembership() Membership
}

type Membership interface {
	// Get returns group info.
	Get() Group
	// IsAvailable returns true if one or more given groups are accessible for the membership.
	IsAvailable([]Rights) bool
}

type Report interface {
	Member

	// GetID returns report ID.
	GetID() ReportID
	// GetTitle returns report title.
	GetTitle() string
	// GetDesc returns report description.
	GetDesc() string
	// GetAuthorLogin returns report login of report author.
	GetAuthorLogin() string
}

type ReportID uint64

type Reports interface {
	// Close closes the collection.
	Close()

	// Add adds new report to the collection.
	Add(title string, desc string, user User) (Report, error)

	// GetAllAllowed returns list of all reports witch is allowed by given rights.
	GetAllAllowed([]Rights) ([]Report, error)

	// Subscribe creates a subscription to report collection modifications.
	Subscribe([]Rights) (ReportsSubscription, error)
}

type ReportsSubscription interface {
	Subscription

	// GetChan resturns updates channel.
	GetChan() <-chan Report
}

type Rights interface {
	// Get returns group info.
	Get() Group
}

type Rprt interface {
	// Close closes connection to rprt-service.
	Close()

	// GetNodeType returns node type name.
	GetNodeType() string
	// GetNodeName returns node name.
	GetNodeName() string

	// Log returns log service.
	Log() Log

	// GetFactory returns default objects factory.
	GetFactory() Factory

	// InitUsers inits users service.
	InitUsers() error
	// GetUsers returns users service.
	GetUsers() Users

	// InitReports inits reports service.
	InitReports() error
	// GetReports returns reports service.
	GetReports() Reports
}

type Stream interface {
	Close()
	GetRprt() Rprt
	GetClient() sarama.Client
}

type Subscription interface {
	// Close closes the subscription.
	Close()
}

type User interface {
	Member

	// GetLogin returns user login.
	GetLogin() string
	//GetRights returns groups with which user allows to work.
	GetRights() []Rights
}

type UserMethod interface {
	Member

	// GetName returns method name.
	GetName() string
}

type UserMethods interface {
	// Close closes database.
	Close()
	// Get returns a method by name.
	Get(method string) (UserMethod, error)
}

type Users interface {
	// Close closes database.
	Close()
	// Find tries to find a user by the login. Returns nil if the user isn't found.
	Find(login string) (User, error)
	// GetMethods returns user methods database.
	GetMethods() UserMethods
	// GetAll returns all users from the database.
	GetAll() []User
}