interfaces

type Broker interface {
	Run() error
	Endpoint() string
	Connect() error
	Publish(string, interface{}) error
	Subscribe(string, nats.MsgHandler) error
	Unsubscribe(string) error
	Close()
}

type Cache interface {
	Put(string, interface{}) error
	Get(string) (interface{}, error)
}

type Processor interface {
	Init(service Service) error
	Close() error
	Process(interface{}) (interface{}, error)
}

type Registry interface {
	Register() error
}

type Service interface {
	//Modules
	Transport() Transport
	Registry() Registry
	Broker() Broker
	Store() Store
	Cache() Cache

	Running() bool
	HookShutDown(func())
	//Configuration
	Config(path string, defaultValue interface{}) interface{}

	//Log
	Error(string)
	Errorf(string, ...interface{})
	Info(string)
	Infof(string, ...interface{})
	Warn(string)
	Warnf(string, ...interface{})
	Fatal(string)
	Fatalf(string, ...interface{})
	Debug(string)
	Debugf(string, ...interface{})
}

type Store interface {
	Create(string, interface{}) error
	Read(string) (interface{}, error)
	Update(string, interface{}) error
	Delete(string) error
	List() ([]interface{}, error)
}

type Transport interface {
	Run() error
	Stop() error
	GetHandler(string, interface{})
	PostHandler(string, interface{})
	PutHandler(string, interface{})
	DeleteHandler(string, interface{})
	Middleware(interface{})
	StaticFilesFolder(string, string)
}