endpoints

Documentation

Index

• func MakeAddDocumentEndpoint(svc watermark.Service) endpoint.Endpoint
• func MakeGetEndpoint(svc watermark.Service) endpoint.Endpoint
• func MakeServiceStatusEndpoint(svc watermark.Service) endpoint.Endpoint
• func MakeStatusEndpoint(svc watermark.Service) endpoint.Endpoint
• func MakeWatermarkEndpoint(svc watermark.Service) endpoint.Endpoint
• type AddDocumentRequest
• type AddDocumentResponse
• type GetRequest
• type GetResponse
• type ServiceStatusRequest
• type ServiceStatusResponse
• type Set
  • func NewEndpointSet(svc watermark.Service) Set
  • func (s *Set) AddDocument(ctx context.Context, doc *internal.Document) (string, error)
  • func (s *Set) Get(ctx context.Context, filters ...internal.Filter) ([]internal.Document, error)
  • func (s *Set) ServiceStatus(ctx context.Context) (int, error)
  • func (s *Set) Status(ctx context.Context, ticketID string) (internal.Status, error)
  • func (s *Set) Watermark(ctx context.Context, ticketID, mark string) (int, error)
• type StatusRequest
• type StatusResponse
• type WatermarkRequest
• type WatermarkResponse

Functions

func MakeAddDocumentEndpoint

func MakeAddDocumentEndpoint(svc watermark.Service) endpoint.Endpoint

func MakeGetEndpoint

func MakeGetEndpoint(svc watermark.Service) endpoint.Endpoint

func MakeServiceStatusEndpoint

func MakeServiceStatusEndpoint(svc watermark.Service) endpoint.Endpoint

func MakeStatusEndpoint

func MakeStatusEndpoint(svc watermark.Service) endpoint.Endpoint

func MakeWatermarkEndpoint

func MakeWatermarkEndpoint(svc watermark.Service) endpoint.Endpoint

Types

type AddDocumentRequest

type AddDocumentRequest struct {
	Document *internal.Document `json:"document"`
}

type AddDocumentResponse

type AddDocumentResponse struct {
	TicketID string `json:"ticketID"`
	Err      string `json:"err,omitempty"`
}

type GetRequest

type GetRequest struct {
	Filters []internal.Filter `json:"filters,omitempty"`
}

type GetResponse

type GetResponse struct {
	Documents []internal.Document `json:"documents"`
	Err       string              `json:"err,omitempty"`
}

type ServiceStatusRequest

type ServiceStatusRequest struct{}

type ServiceStatusResponse

type ServiceStatusResponse struct {
	Code int    `json:"status"`
	Err  string `json:"err,omitempty"`
}

type Set

type Set struct {
	GetEndpoint           endpoint.Endpoint
	AddDocumentEndpoint   endpoint.Endpoint
	StatusEndpoint        endpoint.Endpoint
	ServiceStatusEndpoint endpoint.Endpoint
	WatermarkEndpoint     endpoint.Endpoint
}

func NewEndpointSet

func NewEndpointSet(svc watermark.Service) Set

func (*Set) AddDocument

func (s *Set) AddDocument(ctx context.Context, doc *internal.Document) (string, error)

func (*Set) Get

func (s *Set) Get(ctx context.Context, filters ...internal.Filter) ([]internal.Document, error)

func (*Set) ServiceStatus

func (s *Set) ServiceStatus(ctx context.Context) (int, error)

func (*Set) Status

func (s *Set) Status(ctx context.Context, ticketID string) (internal.Status, error)

func (*Set) Watermark

func (s *Set) Watermark(ctx context.Context, ticketID, mark string) (int, error)

type StatusRequest

type StatusRequest struct {
	TicketID string `json:"ticketID"`
}

type StatusResponse

type StatusResponse struct {
	Status internal.Status `json:"status"`
	Err    string          `json:"err,omitempty"`
}

type WatermarkRequest

type WatermarkRequest struct {
	TicketID string `json:"ticketID"`
	Mark     string `json:"mark"`
}

type WatermarkResponse

type WatermarkResponse struct {
	Code int    `json:"code"`
	Err  string `json:"err"`
}