service

Documentation

Index

• func AddAdminHandlers(servicesRouter *mux.Router, requestLoggingEnabled bool, log *logger.UPPLogger, ...)
• func Handlers(servicesRouter *mux.Router, wh WriterHandler, rh ReaderHandler, ...)
• type HealthCheck
  • func NewHealthCheck(c messageConsumerHealthcheck, s3API s3iface.S3API, appName string, ...) *HealthCheck
  • func (h *HealthCheck) GTG() gtg.Status
  • func (h *HealthCheck) Health() func(w http.ResponseWriter, r *http.Request)
• type KafkaMsg
• type QProcessor
  • func NewQProcessor(w Writer, log *logger.UPPLogger) QProcessor
• type Reader
  • func NewS3Reader(svc s3iface.S3API, bucketName string, bucketPrefix string, workers int16, ...) Reader
• type ReaderHandler
  • func NewReaderHandler(reader Reader, log *logger.UPPLogger) ReaderHandler
  • func (rh *ReaderHandler) HandleCount(rw http.ResponseWriter, r *http.Request)
  • func (rh *ReaderHandler) HandleGet(rw http.ResponseWriter, r *http.Request)
  • func (rh *ReaderHandler) HandleGetAll(rw http.ResponseWriter, r *http.Request)
  • func (rh *ReaderHandler) HandleIds(rw http.ResponseWriter, r *http.Request)
• type S3QProcessor
  • func (r *S3QProcessor) ProcessMsg(m kafka.FTMessage)
• type S3Reader
  • func (r *S3Reader) Count() (int64, error)
  • func (r *S3Reader) Get(uuid string, path string) (bool, io.ReadCloser, *string, error)
  • func (r *S3Reader) GetAll(path string) (*io.PipeReader, error)
  • func (r *S3Reader) Ids() (*io.PipeReader, error)
• type S3Writer
  • func (w *S3Writer) Delete(uuid string, path string, tid string) error
  • func (w *S3Writer) Write(uuid string, path string, b *[]byte, ct string, tid string, ignoreHash bool) (Status, error)
• type Status
• type Writer
  • func NewS3Writer(svc s3iface.S3API, bucketName string, bucketPrefix string, ...) Writer
• type WriterHandler
  • func NewWriterHandler(writer Writer, reader Reader, log *logger.UPPLogger) WriterHandler
  • func (w *WriterHandler) HandleDelete(rw http.ResponseWriter, r *http.Request)
  • func (w *WriterHandler) HandleWrite(rw http.ResponseWriter, r *http.Request)

Functions

func AddAdminHandlers

func AddAdminHandlers(servicesRouter *mux.Router, requestLoggingEnabled bool, log *logger.UPPLogger, hc *HealthCheck)

func Handlers

func Handlers(servicesRouter *mux.Router, wh WriterHandler, rh ReaderHandler, resourcePath string)

Types

type HealthCheck

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

func NewHealthCheck

func NewHealthCheck(c messageConsumerHealthcheck, s3API s3iface.S3API, appName string, appSystemCode string, bucketName string, log *logger.UPPLogger) *HealthCheck

func (*HealthCheck) GTG

func (h *HealthCheck) GTG() gtg.Status

func (*HealthCheck) Health

func (h *HealthCheck) Health() func(w http.ResponseWriter, r *http.Request)

type KafkaMsg

type KafkaMsg struct {
	Id string `json:"uuid"`
}

type QProcessor

type QProcessor interface {
	ProcessMsg(m kafka.FTMessage)
}

func NewQProcessor

func NewQProcessor(w Writer, log *logger.UPPLogger) QProcessor

type Reader

type Reader interface {
	Get(uuid string, path string) (bool, io.ReadCloser, *string, error)
	Count() (int64, error)
	Ids() (*io.PipeReader, error)
	GetAll(path string) (*io.PipeReader, error)
}

func NewS3Reader

func NewS3Reader(svc s3iface.S3API, bucketName string, bucketPrefix string, workers int16, log *logger.UPPLogger) Reader

type ReaderHandler

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

func NewReaderHandler

func NewReaderHandler(reader Reader, log *logger.UPPLogger) ReaderHandler

func (*ReaderHandler) HandleCount

func (rh *ReaderHandler) HandleCount(rw http.ResponseWriter, r *http.Request)

func (*ReaderHandler) HandleGet

func (rh *ReaderHandler) HandleGet(rw http.ResponseWriter, r *http.Request)

func (*ReaderHandler) HandleGetAll

func (rh *ReaderHandler) HandleGetAll(rw http.ResponseWriter, r *http.Request)

func (*ReaderHandler) HandleIds

func (rh *ReaderHandler) HandleIds(rw http.ResponseWriter, r *http.Request)

type S3QProcessor

type S3QProcessor struct {
	Writer
	// contains filtered or unexported fields
}

func (*S3QProcessor) ProcessMsg

func (r *S3QProcessor) ProcessMsg(m kafka.FTMessage)

type S3Reader

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

func (*S3Reader) Count

func (r *S3Reader) Count() (int64, error)

func (*S3Reader) Get

func (r *S3Reader) Get(uuid string, path string) (bool, io.ReadCloser, *string, error)

func (*S3Reader) GetAll

func (r *S3Reader) GetAll(path string) (*io.PipeReader, error)

func (*S3Reader) Ids

func (r *S3Reader) Ids() (*io.PipeReader, error)

type S3Writer

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

func (*S3Writer) Delete

func (w *S3Writer) Delete(uuid string, path string, tid string) error

func (*S3Writer) Write

func (w *S3Writer) Write(uuid string, path string, b *[]byte, ct string, tid string, ignoreHash bool) (Status, error)

type Status

type Status int

const (
	UNCHANGED Status = iota
	CREATED
	UPDATED
	INTERNAL_ERROR
	SERVICE_UNAVAILABLE
)

type Writer

type Writer interface {
	Write(uuid string, path string, b *[]byte, contentType string, transactionID string, ignoreHash bool) (Status, error)
	Delete(uuid string, path string, transactionID string) error
}

func NewS3Writer

func NewS3Writer(svc s3iface.S3API, bucketName string, bucketPrefix string, onlyUpdatesEnabled bool, log *logger.UPPLogger) Writer

type WriterHandler

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

func NewWriterHandler

func NewWriterHandler(writer Writer, reader Reader, log *logger.UPPLogger) WriterHandler

func (*WriterHandler) HandleDelete

func (w *WriterHandler) HandleDelete(rw http.ResponseWriter, r *http.Request)

func (*WriterHandler) HandleWrite

func (w *WriterHandler) HandleWrite(rw http.ResponseWriter, r *http.Request)