connector

type Command[In, Out any] struct {
	// contains filtered or unexported fields
}

type CommandOptions struct {
	Revision       int
	Description    string
	Mode           protocol.CommandMode
	Timeout        time.Duration
	MaxInputBytes  int64
	MaxOutputBytes int64
	Idempotent     bool
}

type Config struct {
	Kind              string
	Contract          Contract
	Name              string
	Description       string
	ArtifactVersion   string
	Targets           []string
	Settings          any
	Validate          func(context.Context) error
	SelfTest          func(context.Context) error
	StateDirectory    string
	InstallationID    string
	HTTPClient        *http.Client
	Operations        Operations
	ServiceMode       ServiceMode
	HeartbeatInterval time.Duration
	MaxConcurrency    int
	AllowInsecureHTTP bool
	Input             io.Reader
	Output            io.Writer
	ErrorOutput       io.Writer
}

type Context interface {
	Deadline() (time.Time, bool)
	Done() <-chan struct{}
	Err() error
	Value(key any) any
	Progress(phase, message string, completed, total int64) error
	JobID() string
	IdempotencyID() string
}

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

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

type DirectoryOptions struct {
	Revision    int
	Description string
	Read        bool
	Write       bool
	List        bool
}

type Handler[In, Out any] func(context Context, input In) (Out, error)

type LocalDirectoryOptions struct {
	MaxReadBytes  int64
	MaxWriteBytes int64
	HTTPClient    *http.Client
}

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

type Operations interface {
	Execute(context.Context, string, ...string) ([]byte, error)
	Executable() (string, error)
}

type Requirement interface {
	// contains filtered or unexported methods
}

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

type Secret string

type ServiceMode string