Versions in this module Expand all Collapse all v0 v0.2.0 Jun 6, 2023 Changes in this version + func WithServerURL(ctx context.Context, u *url.URL) context.Context + type ClientOption interface type Error + func (s *Error) GetMessage() string + func (s *Error) MarshalJSON() ([]byte, error) + func (s *Error) SetMessage(val string) + func (s *Error) UnmarshalJSON(data []byte) error + type ErrorHandler = ogenerrors.ErrorHandler type ErrorStatusCode + func (s *ErrorStatusCode) GetResponse() Error + func (s *ErrorStatusCode) GetStatusCode() int + func (s *ErrorStatusCode) SetResponse(val Error) + func (s *ErrorStatusCode) SetStatusCode(val int) type Job + JobProcess JobProcess + func NewJobProcessJob(v JobProcess) Job + func (s *Job) SetJobProcess(v JobProcess) + func (s *Job) UnmarshalJSON(data []byte) error + func (s Job) GetJobProcess() (v JobProcess, ok bool) + func (s Job) IsJobProcess() bool + func (s Job) MarshalJSON() ([]byte, error) type JobDownload + func (s *JobDownload) GetDate() string + func (s *JobDownload) MarshalJSON() ([]byte, error) + func (s *JobDownload) SetDate(val string) + func (s *JobDownload) UnmarshalJSON(data []byte) error type JobNothing + func (s *JobNothing) MarshalJSON() ([]byte, error) + func (s *JobNothing) UnmarshalJSON(data []byte) error + type JobProcess struct + Clickhouse string + Keys []string + func (s *JobProcess) Decode(d *jx.Decoder) error + func (s *JobProcess) Encode(e *jx.Encoder) + func (s *JobProcess) GetClickhouse() string + func (s *JobProcess) GetKeys() []string + func (s *JobProcess) MarshalJSON() ([]byte, error) + func (s *JobProcess) SetClickhouse(val string) + func (s *JobProcess) SetKeys(val []string) + func (s *JobProcess) UnmarshalJSON(data []byte) error + func (s *JobProcess) Validate() error type JobType + const JobProcessJob + type Middleware = middleware.Middleware type OptInt64 + func (o OptInt64) Or(d int64) int64 + func (s *OptInt64) UnmarshalJSON(data []byte) error + func (s OptInt64) MarshalJSON() ([]byte, error) type OptString + func (o OptString) Or(d string) string + func (s *OptString) UnmarshalJSON(data []byte) error + func (s OptString) MarshalJSON() ([]byte, error) type Option + func WithMeterProvider(provider metric.MeterProvider) Option type Progress + func (s *Progress) GetContentSizeBytes() OptInt64 + func (s *Progress) GetEvent() ProgressEvent + func (s *Progress) GetInputReadyBytes() OptInt64 + func (s *Progress) GetInputSizeBytes() OptInt64 + func (s *Progress) GetKey() string + func (s *Progress) GetOutputSizeBytes() OptInt64 + func (s *Progress) GetSHA256Content() OptString + func (s *Progress) GetSHA256Input() OptString + func (s *Progress) GetSHA256Output() OptString + func (s *Progress) MarshalJSON() ([]byte, error) + func (s *Progress) SetContentSizeBytes(val OptInt64) + func (s *Progress) SetEvent(val ProgressEvent) + func (s *Progress) SetInputReadyBytes(val OptInt64) + func (s *Progress) SetInputSizeBytes(val OptInt64) + func (s *Progress) SetKey(val string) + func (s *Progress) SetOutputSizeBytes(val OptInt64) + func (s *Progress) SetSHA256Content(val OptString) + func (s *Progress) SetSHA256Input(val OptString) + func (s *Progress) SetSHA256Output(val OptString) + func (s *Progress) UnmarshalJSON(data []byte) error type ProgressEvent + const ProgressEventProcessed + const ProgressEventReady + func (s *ProgressEvent) UnmarshalJSON(data []byte) error + func (s *ProgressEvent) UnmarshalText(data []byte) error + func (s ProgressEvent) MarshalJSON() ([]byte, error) + func (s ProgressEvent) MarshalText() ([]byte, error) + type Route struct + func (r Route) Args() []string + func (r Route) Name() string + func (r Route) OperationID() string + func (r Route) PathPattern() string type Server + func (s *Server) FindPath(method string, u *url.URL) (r Route, _ bool) + func (s *Server) FindRoute(method, path string) (Route, bool) + type ServerOption interface + func WithErrorHandler(h ErrorHandler) ServerOption + func WithMaxMultipartMemory(max int64) ServerOption + func WithMethodNotAllowed(methodNotAllowed func(w http.ResponseWriter, r *http.Request, allowed string)) ServerOption + func WithMiddleware(m ...Middleware) ServerOption + func WithNotFound(notFound http.HandlerFunc) ServerOption + func WithPathPrefix(prefix string) ServerOption type Status + func (s *Status) GetMessage() string + func (s *Status) MarshalJSON() ([]byte, error) + func (s *Status) SetMessage(val string) + func (s *Status) UnmarshalJSON(data []byte) error + type UnimplementedHandler struct + func (UnimplementedHandler) NewError(ctx context.Context, err error) (r *ErrorStatusCode) + func (UnimplementedHandler) Poll(ctx context.Context, params PollParams) (r Job, _ error) + func (UnimplementedHandler) Progress(ctx context.Context, req *Progress, params ProgressParams) (r *Status, _ error) + func (UnimplementedHandler) Status(ctx context.Context) (r *Status, _ error) v0.1.0 Nov 25, 2021 Changes in this version + type Client struct + func NewClient(serverURL string, opts ...Option) (*Client, error) + func (c *Client) Poll(ctx context.Context, params PollParams) (res Job, err error) + func (c *Client) Progress(ctx context.Context, request Progress, params ProgressParams) (res Status, err error) + func (c *Client) Status(ctx context.Context) (res Status, err error) + type Error struct + Message string + func (s *Error) Decode(d *jx.Decoder) error + func (s Error) Encode(e *jx.Encoder) + type ErrorStatusCode struct + Response Error + StatusCode int + func (s *ErrorStatusCode) Decode(d *jx.Decoder) error + func (s *ErrorStatusCode) Error() string + func (s ErrorStatusCode) Encode(e *jx.Encoder) + type Handler interface + NewError func(ctx context.Context, err error) ErrorStatusCode + Poll func(ctx context.Context, params PollParams) (Job, error) + Progress func(ctx context.Context, req Progress, params ProgressParams) (Status, error) + Status func(ctx context.Context) (Status, error) + type Job struct + JobDownload JobDownload + JobInventory JobInventory + JobNothing JobNothing + Type JobType + func NewJobDownloadJob(v JobDownload) Job + func NewJobInventoryJob(v JobInventory) Job + func NewJobNothingJob(v JobNothing) Job + func (s *Job) Decode(d *jx.Decoder) error + func (s *Job) SetJobDownload(v JobDownload) + func (s *Job) SetJobInventory(v JobInventory) + func (s *Job) SetJobNothing(v JobNothing) + func (s Job) Encode(e *jx.Encoder) + func (s Job) GetJobDownload() (v JobDownload, ok bool) + func (s Job) GetJobInventory() (v JobInventory, ok bool) + func (s Job) GetJobNothing() (v JobNothing, ok bool) + func (s Job) IsJobDownload() bool + func (s Job) IsJobInventory() bool + func (s Job) IsJobNothing() bool + func (s Job) Validate() error + type JobDownload struct + Date string + Type string + func (s *JobDownload) Decode(d *jx.Decoder) error + func (s JobDownload) Encode(e *jx.Encoder) + type JobInventory struct + Date []string + Type string + func (s *JobInventory) Decode(d *jx.Decoder) error + func (s JobInventory) Encode(e *jx.Encoder) + func (s JobInventory) Validate() error + type JobNothing struct + Type string + func (s *JobNothing) Decode(d *jx.Decoder) error + func (s JobNothing) Encode(e *jx.Encoder) + type JobType string + const JobDownloadJob + const JobInventoryJob + const JobNothingJob + type OptInt64 struct + Set bool + Value int64 + func NewOptInt64(v int64) OptInt64 + func (o *OptInt64) Decode(d *jx.Decoder) error + func (o *OptInt64) Reset() + func (o *OptInt64) SetTo(v int64) + func (o OptInt64) Encode(e *jx.Encoder) + func (o OptInt64) Get() (v int64, ok bool) + func (o OptInt64) IsSet() bool + type OptString struct + Set bool + Value string + func NewOptString(v string) OptString + func (o *OptString) Decode(d *jx.Decoder) error + func (o *OptString) Reset() + func (o *OptString) SetTo(v string) + func (o OptString) Encode(e *jx.Encoder) + func (o OptString) Get() (v string, ok bool) + func (o OptString) IsSet() bool + type Option interface + func WithClient(client ht.Client) Option + func WithTracerProvider(provider trace.TracerProvider) Option + type PollParams struct + XToken string + type Progress struct + ContentSizeBytes OptInt64 + Event ProgressEvent + InputReadyBytes OptInt64 + InputSizeBytes OptInt64 + Key string + OutputSizeBytes OptInt64 + SHA256Content OptString + SHA256Input OptString + SHA256Output OptString + func (s *Progress) Decode(d *jx.Decoder) error + func (s Progress) Encode(e *jx.Encoder) + func (s Progress) Validate() error + type ProgressEvent string + const ProgressEventDone + const ProgressEventDownloading + const ProgressEventInventory + func (s *ProgressEvent) Decode(d *jx.Decoder) error + func (s ProgressEvent) Encode(e *jx.Encoder) + func (s ProgressEvent) Validate() error + type ProgressParams struct + XToken string + type Server struct + func NewServer(h Handler, opts ...Option) *Server + func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) + type Status struct + Message string + func (s *Status) Decode(d *jx.Decoder) error + func (s Status) Encode(e *jx.Encoder)
Go to main page