replicate

Oct 11, 2024

Changes in this version

type Client

+ func (r *Client) StreamPredictionFiles(prediction *Prediction) (streaming.FileStreamer, error)

+ func (r *Client) StreamPredictionText(ctx context.Context, prediction *Prediction) (io.ReadCloser, error)

Sep 23, 2024

Changes in this version

type RunOption

+ func WithBlockUntilDone() RunOption

Sep 19, 2024

Changes in this version

+ const SSETypeDefault

Sep 13, 2024

Changes in this version

type Client

+ func (r *Client) RunWithOptions(ctx context.Context, identifier string, input PredictionInput, ...) (PredictionOutput, error)

+ type FileOutput struct

+ URL string

+ type RunOption func(*runOptions)

+ func WithFileOutput() RunOption

Aug 22, 2024

Changes in this version

+ type ModelError struct

+ Prediction *Prediction

+ func (e *ModelError) Error() string

Jul 25, 2024

Changes in this version

type Client

+ func (r *Client) SearchModels(ctx context.Context, query string) (*Page[Model], error)

Jul 1, 2024

Changes in this version

type Client

+ func (c *Client) DeleteDeployment(ctx context.Context, deploymentOwner string, deploymentName string) error

Jun 20, 2024

Changes in this version

+ var ErrEnvVarEmpty = fmt.Errorf("%s environment variable is empty", envAuthToken)

+ var ErrEnvVarNotSet = fmt.Errorf("%s environment variable not set", envAuthToken)

type Client

+ func (r *Client) DeleteModel(ctx context.Context, modelOwner string, modelName string) error

Jun 10, 2024

Changes in this version

type Client

+ func (c *Client) CreateDeployment(ctx context.Context, options CreateDeploymentOptions) (*Deployment, error)

+ func (c *Client) ListDeployments(ctx context.Context) (*Page[Deployment], error)

+ func (c *Client) UpdateDeployment(ctx context.Context, deploymentOwner string, deploymentName string, ...) (*Deployment, error)

+ type CreateDeploymentOptions struct

+ Hardware string

+ MaxInstances int

+ MinInstances int

+ Model string

+ Name string

+ Version string

+ type UpdateDeploymentOptions struct

+ Hardware *string

+ MaxInstances *int

+ MinInstances *int

+ Model *string

+ Version *string

May 24, 2024

Changes in this version

type Account

+ func (a *Account) RawJSON() json.RawMessage

type Collection

+ func (c *Collection) RawJSON() json.RawMessage

type Deployment

+ func (d *Deployment) RawJSON() json.RawMessage

type File

+ func (f *File) RawJSON() json.RawMessage

+ func (f *File) UnmarshalJSON(data []byte) error

type Hardware

+ func (h *Hardware) RawJSON() json.RawMessage

type Model

+ func (m *Model) RawJSON() json.RawMessage

type ModelVersion

+ func (m *ModelVersion) RawJSON() json.RawMessage

type Page

+ func (p *Page[T]) RawJSON() json.RawMessage

type Prediction

+ func (p *Prediction) RawJSON() json.RawMessage

type WebhookSigningSecret

+ func (wss *WebhookSigningSecret) RawJSON() json.RawMessage

+ func (wss *WebhookSigningSecret) UnmarshalJSON(data []byte) error

Mar 11, 2024

Changes in this version

type Client

+ func (r *Client) DeleteModelVersion(ctx context.Context, modelOwner string, modelName string, versionID string) error

+ type PredictionMetrics struct

+ InputTokenCount *int

+ OutputTokenCount *int

+ PredictTime *float64

+ TimeToFirstToken *float64

+ TokensPerSecond *float64

+ TotalTime *float64

Feb 27, 2024

Changes in this version

type Client

+ func (r *Client) CancelPrediction(ctx context.Context, id string) (*Prediction, error)

Feb 16, 2024

Changes in this version

+ func ValidateWebhookRequest(req *http.Request, secret WebhookSigningSecret) (bool, error)

type Client

+ func (r *Client) GetDefaultWebhookSecret(ctx context.Context) (*WebhookSigningSecret, error)

+ func (r *Client) GetDeployment(ctx context.Context, deployment_owner string, deployment_name string) (*Deployment, error)

+ type Deployment struct

+ CurrentRelease DeploymentRelease

+ Name string

+ Owner string

+ func (d *Deployment) UnmarshalJSON(data []byte) error

+ func (d Deployment) MarshalJSON() ([]byte, error)

+ type DeploymentConfiguration struct

+ Hardware string

+ MaxInstances int

+ MinInstances int

+ type DeploymentRelease struct

+ Configuration DeploymentConfiguration

+ CreatedAt string

+ CreatedBy Account

+ Model string

+ Number int

+ Version string

+ type WebhookSigningSecret struct

+ Key string

Jan 31, 2024

Changes in this version

+ type Account struct

+ GithubURL string

+ Name string

+ Type string

+ Username string

+ func (a *Account) UnmarshalJSON(data []byte) error

+ func (a Account) MarshalJSON() ([]byte, error)

type Client

+ func (r *Client) CreateFileFromBuffer(ctx context.Context, buf *bytes.Buffer, options *CreateFileOptions) (*File, error)

+ func (r *Client) CreateFileFromBytes(ctx context.Context, data []byte, options *CreateFileOptions) (*File, error)

+ func (r *Client) CreateFileFromPath(ctx context.Context, filePath string, options *CreateFileOptions) (*File, error)

+ func (r *Client) DeleteFile(ctx context.Context, fileID string) error

+ func (r *Client) GetCurrentAccount(ctx context.Context) (*Account, error)

+ func (r *Client) GetFile(ctx context.Context, fileID string) (*File, error)

+ func (r *Client) ListFiles(ctx context.Context) (*Page[File], error)

+ type CreateFileOptions struct

+ ContentType string

+ Filename string

+ Metadata map[string]string

+ type File struct

+ Checksums map[string]string

+ ContentType string

+ CreatedAt string

+ Etag string

+ ExpiresAt string

+ ID string

+ Metadata map[string]string

+ Name string

+ Size int

+ URLs map[string]string

Dec 4, 2023

Changes in this version

+ const SSETypeDone

+ const SSETypeError

+ const SSETypeLogs

+ const SSETypeOutput

Dec 4, 2023

Changes in this version

type SSEEvent

+ func (e *SSEEvent) String() string

Dec 4, 2023

Changes in this version

type APIError

+ Instance string

+ Status int

+ Title string

+ Type string

+ func (e *APIError) WriteHTTPResponse(w http.ResponseWriter)

Dec 3, 2023

Changes in this version

type Client

+ func (r *Client) StreamPrediction(ctx context.Context, prediction *Prediction) (<-chan SSEEvent, <-chan error)

type Identifier

+ func (i *Identifier) String() string

Dec 3, 2023

Changes in this version

+ var ErrInvalidIdentifier = errors.New(...)

+ var ErrInvalidUTF8Data = errors.New("invalid UTF-8 data")

type Client

+ func (r *Client) CreatePredictionWithModel(ctx context.Context, modelOwner string, modelName string, ...) (*Prediction, error)

+ func (r *Client) Stream(ctx context.Context, identifier string, input PredictionInput, ...) (<-chan SSEEvent, <-chan error)

+ type Identifier struct

+ Name string

+ Owner string

+ Version *string

+ func ParseIdentifier(identifier string) (*Identifier, error)

+ type SSEEvent struct

+ Data string

+ ID string

+ Type string

Nov 16, 2023

Changes in this version

type Prediction

+ Model string

Nov 6, 2023

Changes in this version

type Client

+ func (r *Client) CreateModel(ctx context.Context, modelOwner string, modelName string, ...) (*Model, error)

+ func (r *Client) ListHardware(ctx context.Context) (*[]Hardware, error)

+ type CreateModelOptions struct

+ CoverImageURL *string

+ Description *string

+ GithubURL *string

+ Hardware string

+ LicenseURL *string

+ PaperURL *string

+ Visibility string

+ type Hardware struct

+ Name string

+ SKU string

+ func (h *Hardware) UnmarshalJSON(data []byte) error

+ func (h Hardware) MarshalJSON() ([]byte, error)

Oct 4, 2023

Changes in this version

type Client

+ func (r *Client) ListModels(ctx context.Context) (*Page[Model], error)

Sep 11, 2023

Changes in this version

type Client

+ func (r *Client) CreatePredictionWithDeployment(ctx context.Context, deployment_owner string, deployment_name string, ...) (*Prediction, error)

Sep 5, 2023

Changes in this version

type Collection

+ func (c *Collection) UnmarshalJSON(data []byte) error

+ func (c Collection) MarshalJSON() ([]byte, error)

type Model

+ func (m *Model) UnmarshalJSON(data []byte) error

+ func (m Model) MarshalJSON() ([]byte, error)

type ModelVersion

+ func (m *ModelVersion) UnmarshalJSON(data []byte) error

+ func (m ModelVersion) MarshalJSON() ([]byte, error)

type Page

+ func (p *Page[T]) UnmarshalJSON(data []byte) error

+ func (p Page[T]) MarshalJSON() ([]byte, error)

type Prediction

+ func (p *Prediction) UnmarshalJSON(data []byte) error

+ func (p Prediction) MarshalJSON() ([]byte, error)

Aug 11, 2023

Changes in this version

type Prediction

+ func (p Prediction) Progress() *PredictionProgress

+ type PredictionProgress struct

+ Current int

+ Percentage float64

+ Total int

Aug 7, 2023

Changes in this version

+ type Backoff interface

+ NextDelay func(retries int) time.Duration

type Client

+ func (r *Client) WaitAsync(ctx context.Context, prediction *Prediction, opts ...WaitOption) (<-chan *Prediction, <-chan error)

type ClientOption

+ func WithRetryPolicy(maxRetries int, backoff Backoff) ClientOption

+ type ConstantBackoff struct

+ Base time.Duration

+ Jitter time.Duration

+ func (b *ConstantBackoff) NextDelay(retries int) time.Duration

+ type ExponentialBackoff struct

+ Base time.Duration

+ Jitter time.Duration

+ Multiplier float64

+ func (b *ExponentialBackoff) NextDelay(retries int) time.Duration

+ type WaitOption func(*waitOptions) error

+ func WithPollingInterval(interval time.Duration) WaitOption

Aug 6, 2023

Changes in this version

+ var ErrNoAuth = errors.New(...)

type ClientOption

+ func WithToken(token string) ClientOption

+ func WithTokenFromEnv() ClientOption

Jul 31, 2023

Changes in this version

type Prediction

+ URLs map[string]string

Jul 17, 2023

Changes in this version

+ var WebhookEventAll = []WebhookEventType

+ func Paginate(ctx context.Context, client *Client, initialPage *Page[T]) (<-chan []T, <-chan error)

+ type APIError struct

+ Detail string

+ func (e APIError) Error() string

+ type Client struct

+ Auth string

+ BaseURL string

+ HTTPClient *http.Client

+ UserAgent *string

+ func NewClient(auth string, options ...ClientOption) *Client

+ func (r *Client) CancelTraining(ctx context.Context, trainingID string) (*Training, error)

+ func (r *Client) CreatePrediction(ctx context.Context, version string, input PredictionInput, webhook *Webhook) (*Prediction, error)

+ func (r *Client) CreateTraining(ctx context.Context, model_owner string, model_name string, version string, ...) (*Training, error)

+ func (r *Client) GetCollection(ctx context.Context, slug string) (*Collection, error)

+ func (r *Client) GetModel(ctx context.Context, modelOwner string, modelName string) (*Model, error)

+ func (r *Client) GetModelVersion(ctx context.Context, modelOwner string, modelName string, versionID string) (*ModelVersion, error)

+ func (r *Client) GetPrediction(ctx context.Context, id string) (*Prediction, error)

+ func (r *Client) GetTraining(ctx context.Context, trainingID string) (*Training, error)

+ func (r *Client) ListCollections(ctx context.Context) (*Page[Collection], error)

+ func (r *Client) ListModelVersions(ctx context.Context, modelOwner string, modelName string) (*Page[ModelVersion], error)

+ func (r *Client) ListPredictions(ctx context.Context) (*Page[Prediction], error)

+ func (r *Client) ListTrainings(ctx context.Context) (*Page[Training], error)

+ func (r *Client) Run(ctx context.Context, identifier string, input PredictionInput, ...) (PredictionOutput, error)

+ func (r *Client) Wait(ctx context.Context, prediction Prediction, interval time.Duration, ...) (*Prediction, error)

+ type ClientOption func(*Client)

+ func WithBaseURL(baseURL string) ClientOption

+ func WithHTTPClient(httpClient *http.Client) ClientOption

+ func WithUserAgent(userAgent string) ClientOption

+ type Collection struct

+ Description string

+ Models *[]Model

+ Name string

+ Slug string

+ type Model struct

+ CoverImageURL string

+ DefaultExample *Prediction

+ Description string

+ GithubURL string

+ LatestVersion *ModelVersion

+ LicenseURL string

+ Name string

+ Owner string

+ PaperURL string

+ RunCount int

+ URL string

+ Visibility string

+ type ModelVersion struct

+ CogVersion string

+ CreatedAt string

+ ID string

+ OpenAPISchema interface{}

+ type Page struct

+ Next *string

+ Previous *string

+ Results []T

+ type Prediction struct

+ CompletedAt *string

+ CreatedAt string

+ Error interface{}

+ ID string

+ Input PredictionInput

+ Logs *string

+ Metrics ...

+ Output PredictionOutput

+ Source Source

+ StartedAt *string

+ Status Status

+ UpdatedAt string

+ Version string

+ Webhook *string

+ WebhookEventsFilter []WebhookEventType

+ type PredictionInput map[string]interface

+ type PredictionOutput interface

+ type Source string

+ const SourceAPI

+ const SourceWeb

+ type Status string

+ const Canceled

+ const Failed

+ const Processing

+ const Starting

+ const Succeeded

+ func (s Status) String() string

+ func (s Status) Terminated() bool

+ type Training Prediction

+ type TrainingInput PredictionInput

+ type Webhook struct

+ Events []WebhookEventType

+ URL string

+ type WebhookEventType string

+ const WebhookEventCompleted

+ const WebhookEventLogs

+ const WebhookEventOutput

+ const WebhookEventStart

+ func (w WebhookEventType) String() string