Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func IsServiceNotReadyError ¶
IsServiceNotReadyError evaluates if the given error is ServiceNotReadyError
Types ¶
type ExternalCmdService ¶
type ExternalCmdService struct {
// contains filtered or unexported fields
}
func CreateExternalCmdService ¶
func CreateExternalCmdService(service *S3DataWatcherService) (*ExternalCmdService, error)
CreateExternalCmdService creates a ExternalCmd service object
func (*ExternalCmdService) Release ¶
func (externalCmdService *ExternalCmdService) Release()
Release releases all resources
func (*ExternalCmdService) S3EventHandler ¶
func (externalCmdService *ExternalCmdService) S3EventHandler(msg []byte)
type MinIOS3Event ¶
type MinIOS3Event struct { EventName string `json:"EventName"` Key string `json:"Key"` Records []events.S3EventRecord `json:"Records"` }
MinIOS3Event which wrap an array of S3EventRecord
type NatsService ¶
type NatsService struct {
// contains filtered or unexported fields
}
func CreateNatsService ¶
func CreateNatsService(service *S3DataWatcherService, config *commons.NatsConfig, hander S3EventHandler) (*NatsService, error)
CreateNatsService creates a Nats service object and connects to Nats
func (*NatsService) Release ¶
func (natsService *NatsService) Release()
Release releases all resources, disconnecting from Nats
type S3DataWatcherService ¶
type S3DataWatcherService struct {
// contains filtered or unexported fields
}
S3DataWatcherService is a service object
func NewService ¶
func NewService(config *commons.Config) (*S3DataWatcherService, error)
NewService creates a new Service
func (*S3DataWatcherService) Release ¶
func (svc *S3DataWatcherService) Release()
Release releases the service
type S3EventHandler ¶
type S3EventHandler func([]byte)
type ServiceNotReadyError ¶
type ServiceNotReadyError struct {
// contains filtered or unexported fields
}
ServiceNotReadyError ...
func NewServiceNotReadyError ¶
func NewServiceNotReadyError(message string) *ServiceNotReadyError
NewServiceNotReadyError creates ServiceNotReadyError struct
func NewServiceNotReadyErrorf ¶
func NewServiceNotReadyErrorf(format string, v ...interface{}) *ServiceNotReadyError
NewServiceNotReadyErrorf creates ServiceNotReadyError struct
func (*ServiceNotReadyError) Error ¶
func (e *ServiceNotReadyError) Error() string
Click to show internal directories.
Click to hide internal directories.