client

package

v1.11.0-rc.6 Latest Latest Go to latest Published: Mar 22, 2024 License: LGPL-3.0 Imports: 15 Imported by: 1

Details

This section is empty.

View Source

var (
	ErrEmptyServerURL   = errors.New("empty contentserver url provided")
	ErrInvalidServerURL = errors.New("invalid contentserver url provided")
)

This section is empty.

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

Client a content server client

func New(transport Transport) *Client

func NewHTTPClient(url string) (c *Client, err error)

NewHTTPClient constructs a new client to talk to the contentserver. It returns an error if the provided url is empty or invalid.

func (c *Client) Close()

func (c *Client) GetContent(ctx context.Context, request *requests.Content) (*content.SiteContent, error)

GetContent request site content

func (c *Client) GetNodes(ctx context.Context, env *requests.Env, nodes map[string]*requests.Node) (map[string]*content.Node, error)

GetNodes request nodes

func (c *Client) GetRepo(ctx context.Context) (map[string]*content.RepoNode, error)

GetRepo get the whole repo

func (c *Client) GetURIs(ctx context.Context, dimension string, ids []string) (map[string]string, error)

GetURIs resolve uris for ids in a dimension

func (c *Client) Update(ctx context.Context) (*responses.Update, error)

Update tell the server to update itself

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

func NewHTTPTransport(server string, opts ...HTTPTransportOption) *HTTPTransport

NewHTTPTransport will create a new http transport for the given server and client. Caution: the provided server url is not validated!

func (t *HTTPTransport) Call(ctx context.Context, route handler.Route, request interface{}, response interface{}) error

func (t *HTTPTransport) Close()

type HTTPTransportOption func(*HTTPTransport)

func HTTPTransportWithHTTPClient(v *http.Client) HTTPTransportOption

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

func NewSocketTransport(url string, connectionPoolSize int, waitTimeout time.Duration) *SocketTransport

func (t *SocketTransport) Call(ctx context.Context, route handler.Route, request interface{}, response interface{}) error

func (t *SocketTransport) Close()

type Transport interface {
	Call(ctx context.Context, route handler.Route, request interface{}, response interface{}) error
	Close()
}