vessel

package

v0.3.1 Latest Latest Go to latest Published: Jun 21, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func New(nc *nats.Conn) *Client

func (c *Client) CreateWorker(ctx context.Context, s Service) (uint64, error)

func (c *Client) DestroyWorker(ctx context.Context, s Service, workerID uint64) error

func (c *Client) Discover(ctx context.Context, serviceName string, outputCh chan<- Service) error

func (c *Client) Execute(ctx context.Context, s Service, filePath string, args []string, stdin io.ReadCloser, stdout io.WriteCloser) (int64, error)

func (c *Client) GetInfo(ctx context.Context, id ID) (Service, error)

func (c *Client) GetWorker(ctx context.Context, s Service, workerID uint64) (ID, error)

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

type Error struct {
	Code    string
	Message string
}

func (e *Error) Error() string

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

func NewID(serviceName, id string) ID

func ParseID(s string) (ID, error)

func (i ID) ServiceName() string

func (i ID) String() string

type Service struct {
	ID        ID
	Metadata  map[string]string
	Endpoints map[string]Endpoint
}