transport

Documentation

Index

• Variables
• func ConfigureGraphQLRoute(route httproute.Route) []httproute.Route
• func ConfigurePresignImagesUploadRoute(route httproute.Route) httproute.Route
• func ConfigureUserExportCreateRoute(route httproute.Route) httproute.Route
• func ConfigureUserExportGetRoute(route httproute.Route) httproute.Route
• func ConfigureUserImportCreateRoute(route httproute.Route) httproute.Route
• func ConfigureUserImportGetRoute(route httproute.Route) httproute.Route
• type GraphQLHandler
  • func (h *GraphQLHandler) ServeHTTP(rw http.ResponseWriter, r *http.Request)
• type JSONResponseWriter
• type PresignImagesUploadHandler
  • func (h *PresignImagesUploadHandler) ServeHTTP(resp http.ResponseWriter, req *http.Request)
• type PresignImagesUploadHandlerLogger
  • func NewPresignImagesUploadHandlerLogger(lf *log.Factory) PresignImagesUploadHandlerLogger
• type PresignImagesUploadResponse
• type PresignProvider
• type UIParamMiddleware
  • func (m *UIParamMiddleware) Handle(next http.Handler) http.Handler
• type UserExportCreateHandler
  • func (h *UserExportCreateHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type UserExportCreateHandlerCloudStorage
• type UserExportCreateHandlerUserExportService
• type UserExportCreateProducer
• type UserExportGetHandler
  • func (h *UserExportGetHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type UserExportGetHandlerCloudStorage
• type UserExportGetProducer
• type UserExportUsageLimiter
• type UserImportCreateHandler
  • func (h *UserImportCreateHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type UserImportGetHandler
  • func (h *UserImportGetHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type UserImportJobEnqueuer
• type UserImportJobGetter

Variables

var DependencySet = wire.NewSet(
	wire.Struct(new(UIParamMiddleware), "*"),
	wire.Struct(new(GraphQLHandler), "*"),
	wire.Struct(new(PresignImagesUploadHandler), "*"),
	wire.Struct(new(UserImportCreateHandler), "*"),
	wire.Struct(new(UserImportGetHandler), "*"),
	wire.Struct(new(UserExportCreateHandler), "*"),
	wire.Struct(new(UserExportGetHandler), "*"),
	NewPresignImagesUploadHandlerLogger,
)

Functions

func ConfigureGraphQLRoute

func ConfigureGraphQLRoute(route httproute.Route) []httproute.Route

func ConfigurePresignImagesUploadRoute

func ConfigurePresignImagesUploadRoute(route httproute.Route) httproute.Route

func ConfigureUserExportCreateRoute

func ConfigureUserExportCreateRoute(route httproute.Route) httproute.Route

func ConfigureUserExportGetRoute

func ConfigureUserExportGetRoute(route httproute.Route) httproute.Route

func ConfigureUserImportCreateRoute

func ConfigureUserImportCreateRoute(route httproute.Route) httproute.Route

func ConfigureUserImportGetRoute

func ConfigureUserImportGetRoute(route httproute.Route) httproute.Route

Types

type GraphQLHandler

type GraphQLHandler struct {
	GraphQLContext *graphql.Context
	AppDatabase    *appdb.Handle
}

func (*GraphQLHandler) ServeHTTP

func (h *GraphQLHandler) ServeHTTP(rw http.ResponseWriter, r *http.Request)

type JSONResponseWriter

type JSONResponseWriter interface {
	WriteResponse(rw http.ResponseWriter, resp *api.Response)
}

type PresignImagesUploadHandler

type PresignImagesUploadHandler struct {
	JSON            JSONResponseWriter
	HTTPProto       httputil.HTTPProto
	HTTPHost        httputil.HTTPHost
	AppID           config.AppID
	PresignProvider PresignProvider
	Logger          PresignImagesUploadHandlerLogger
}

func (*PresignImagesUploadHandler) ServeHTTP

func (h *PresignImagesUploadHandler) ServeHTTP(resp http.ResponseWriter, req *http.Request)

type PresignImagesUploadHandlerLogger

type PresignImagesUploadHandlerLogger struct{ *log.Logger }

func NewPresignImagesUploadHandlerLogger

func NewPresignImagesUploadHandlerLogger(lf *log.Factory) PresignImagesUploadHandlerLogger

type PresignImagesUploadResponse

type PresignImagesUploadResponse struct {
	UploadURL string `json:"upload_url"`
}

type PresignProvider

type PresignProvider interface {
	PresignPostRequest(url *url.URL) error
}

type UIParamMiddleware

type UIParamMiddleware struct{}

func (*UIParamMiddleware) Handle

func (m *UIParamMiddleware) Handle(next http.Handler) http.Handler

type UserExportCreateHandler

type UserExportCreateHandler struct {
	AppID                 config.AppID
	AdminAPIFeatureConfig *config.AdminAPIFeatureConfig
	JSON                  JSONResponseWriter
	Producer              UserExportCreateProducer
	UsageLimiter          UserExportUsageLimiter
	CloudStorage          UserExportCreateHandlerCloudStorage
	Service               UserExportCreateHandlerUserExportService
}

func (*UserExportCreateHandler) ServeHTTP

func (h *UserExportCreateHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type UserExportCreateHandlerCloudStorage

type UserExportCreateHandlerCloudStorage interface {
	PresignGetObject(ctx context.Context, name string, expire time.Duration) (*url.URL, error)
}

type UserExportCreateHandlerUserExportService

type UserExportCreateHandlerUserExportService interface {
	ParseExportRequest(w http.ResponseWriter, r *http.Request) (*userexport.Request, error)
}

type UserExportCreateProducer

type UserExportCreateProducer interface {
	NewTask(appID string, input json.RawMessage, taskIDPrefix string) *redisqueue.Task
	EnqueueTask(ctx context.Context, task *redisqueue.Task) error
}

type UserExportGetHandler

type UserExportGetHandler struct {
	AppID        config.AppID
	JSON         JSONResponseWriter
	UserExports  UserExportGetProducer
	CloudStorage UserExportGetHandlerCloudStorage
}

func (*UserExportGetHandler) ServeHTTP

func (h *UserExportGetHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type UserExportGetHandlerCloudStorage

type UserExportGetHandlerCloudStorage interface {
	PresignGetObject(ctx context.Context, name string, expire time.Duration) (*url.URL, error)
}

type UserExportGetProducer

type UserExportGetProducer interface {
	GetTask(ctx context.Context, item *redisqueue.QueueItem) (*redisqueue.Task, error)
}

type UserExportUsageLimiter

type UserExportUsageLimiter interface {
	Reserve(ctx context.Context, name usage.LimitName, config *config.UsageLimitConfig) (*usage.Reservation, error)
}

type UserImportCreateHandler

type UserImportCreateHandler struct {
	JSON        JSONResponseWriter
	UserImports UserImportJobEnqueuer
}

func (*UserImportCreateHandler) ServeHTTP

func (h *UserImportCreateHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type UserImportGetHandler

type UserImportGetHandler struct {
	AppID       config.AppID
	JSON        JSONResponseWriter
	UserImports UserImportJobGetter
}

func (*UserImportGetHandler) ServeHTTP

func (h *UserImportGetHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type UserImportJobEnqueuer

type UserImportJobEnqueuer interface {
	EnqueueJob(ctx context.Context, request *userimport.Request) (*userimport.Response, error)
}

type UserImportJobGetter

type UserImportJobGetter interface {
	GetJob(ctx context.Context, jobID string) (*userimport.Response, error)
}