agrirouter

Apr 29, 2026

Changes in this version

+ const EventTypeAuthorizationAdded

+ const EventTypeAuthorizationRevoked

+ const EventTypeEndpointDeleted

+ const EventTypeEndpointsListChanged

+ const EventTypeFileReceived

+ const EventTypeMessageReceived

+ type AuthorizationAddedEventData = internal_models.AuthorizationAddedEventData

+ type AuthorizationRevokedEventData = internal_models.AuthorizationRevokedEventData

type Client

+ func (c *Client) ListAuthorizedTenants(ctx context.Context) ([]TenantInfo, error)

+ func (c *Client) ListTenantEndpoints(ctx context.Context, tenantID uuid.UUID) ([]TenantEndpointInfo, error)

+ func (c *Client) ReceiveAuthorizationAddedEvents(ctx context.Context, ...) error

+ func (c *Client) ReceiveAuthorizationRevokedEvents(ctx context.Context, ...) error

+ func (c *Client) ReceiveEndpointsListChangedEvents(ctx context.Context, ...) error

+ func (c *Client) ReceiveEvents(ctx context.Context, types []EventType, handlers EventHandlers, ...) error

+ type EndpointRouteMap = internal_models.EndpointRouteMap

+ type EndpointsListChangedEventData = internal_models.EndpointsListChangedEventData

+ type EventHandlers struct

+ OnAuthorizationAdded func(ctx context.Context, event *AuthorizationAddedEventData)

+ OnAuthorizationRevoked func(ctx context.Context, event *AuthorizationRevokedEventData)

+ OnEndpointDeleted EndpointDeletionHandler

+ OnEndpointsListChanged func(ctx context.Context, event *EndpointsListChangedEventData)

+ OnFile func(ctx context.Context, file *File)

+ OnMessage MessageHandler

+ type EventType = internal_models.ReceiveEventsParamsTypes

+ type RoutedEndpoints = internal_models.RoutedEndpoints

+ type TenantEndpointCapabilities = internal_models.TenantEndpointCapabilities

+ type TenantEndpointInfo = internal_models.TenantEndpointInfo

+ type TenantInfo = internal_models.TenantInfo

Apr 17, 2026

Changes in this version

type Client

+ func (c *Client) ReceiveEndpointDeletedEvents(ctx context.Context, deletionHandler EndpointDeletionHandler, ...) error

+ type DeletedEndpoint struct

+ ExternalID string

+ ID uuid.UUID

+ type EndpointDeletedEventData = internal_models.EndpointDeletedEventData

+ type EndpointDeletionHandler func(ctx context.Context, deletion *DeletedEndpoint)

Apr 8, 2026

Changes in this version

+ const EndpointNameMaxLength

+ const EndpointNameMinLength

+ var ErrEndpointNameBlank = errors.New("endpoint name is blank or contains no allowed characters")

+ func NormalizeEndpointName(name string) (string, error)

Apr 8, 2026

Changes in this version

+ const CloudSoftware

+ var ErrDeleteEndpointFailed = errors.New("failed to delete endpoint")

type Client

+ func (c *Client) DeleteEndpoint(ctx context.Context, externalID string, params *DeleteEndpointParams) error

+ type DeleteEndpointParams = internal_models.DeleteEndpointParams

Mar 17, 2026

Changes in this version

type File

+ TeamsetContextID *string

type Message

+ TeamsetContextID *string

Mar 2, 2026

Changes in this version

type File

+ TenantID *string

type Message

+ TenantID *string

Feb 27, 2026

Changes in this version

type File

+ MessageIDs []uuid.UUID

Feb 27, 2026

Changes in this version

type Message

+ ID uuid.UUID

Feb 26, 2026

Changes in this version

type Client

+ func (c *Client) ConfirmMessages(ctx context.Context, params *ConfirmMessagesParams, req ConfirmMessagesRequest) error

+ type ConfirmMessagesParams = internal_models.ConfirmMessagesParams

+ type ConfirmMessagesRequest = internal_models.ConfirmMessagesRequest

+ type MessageConfirmation = internal_models.MessageConfirmation

Feb 4, 2026

Changes in this version

type File

+ Size int64

Feb 4, 2026

Changes in this version

type File

+ MessageType string

Jan 22, 2026

Changes in this version

type ClientOption

+ func WithPayloadsHTTPClient(httpClient PayloadsHTTPClient) ClientOption

+ type PayloadsHTTPClient interface

+ Do func(req *http.Request) (*http.Response, error)

Jan 21, 2026

Changes in this version

type Client

+ func (c *Client) ReceiveFiles(ctx context.Context, fileHandler func(ctx context.Context, file *File), ...) error

+ type File struct

+ Filename *string

+ Payload io.Reader

+ ReceivingEndpointID uuid.UUID

type Message

+ Filename *string

Sep 29, 2025

Changes in this version

+ type EndpointCapabilityDirection = internal_models.EndpointCapabilityDirection

+ type EndpointType = internal_models.EndpointType

Sep 24, 2025

Changes in this version

type Message

+ ReceivingEndpointID uuid.UUID

Sep 22, 2025

Changes in this version

+ var ErrMissingPayload = errors.New("missing payload: no embedded payload and no payload URI")

Sep 17, 2025

Changes in this version

+ var ErrFailedToFetchPayload = errors.New("failed to fetch payload")

+ var ErrFailedToReadPayload = errors.New("failed to read payload")

+ var ErrToCloseResponseBody = errors.New("failed to close response body")

+ var ErrURLIsInvalid = errors.New("provided URL is invalid")

+ var ErrUnexpectedStatusCodeWhenFetchingPayload = errors.New("unexpected status code when fetching payload")

type Client

+ func (c *Client) ReceiveMessages(ctx context.Context, messageHandler MessageHandler, ...) error

+ type Message struct

+ AppMessageID string

+ MessageType string

+ Payload []byte

+ type MessageHandler func(message *Message)

+ type MessageReceivedEventData = internal_models.MessageReceivedEventData

Aug 27, 2025

Changes in this version

type Client

+ func (c *Client) SendMessages(ctx context.Context, params *SendMessagesParams, body io.Reader) error

+ type SendMessagesParams = internal_models.SendMessagesParams

Aug 21, 2025

Changes in this version

+ const CapabilityDirectionReceive

+ const CapabilityDirectionSend

+ const CapabilityDirectionSendReceive

+ const CommunicationUnit

+ const FarmingSoftware

+ const VirtualCommunicationUnit

+ var ErrAPICallFailed = errors.New("API call failed")

+ var ErrFailedStatusCode = errors.New("unexpected status code received from agrirouter API")

+ var ErrPutEndpointFailed = errors.New("failed to put endpoint")

+ type Client struct

+ func NewClient(serverURL string, opts ...ClientOption) (*Client, error)

+ func (c *Client) PutEndpoint(ctx context.Context, externalID string, params *PutEndpointParams, ...) (*Endpoint, error)

+ func (c *Client) SendMessage(ctx context.Context, params *SendMessageParams, body io.Reader) error

+ type ClientOption = oapi.ClientOption

+ func WithHTTPClient(doer HTTPRequestDoer) ClientOption

+ func WithRequestEditorFn(fn RequestEditorFn) ClientOption

+ type Endpoint = internal_models.Endpoint

+ type EndpointCapability = internal_models.EndpointCapability

+ type EndpointSubscription = internal_models.EndpointSubscription

+ type HTTPRequestDoer = oapi.HttpRequestDoer

+ type PutEndpointParams = internal_models.PutEndpointParams

+ type PutEndpointRequest = internal_models.PutEndpointRequest

+ type RequestEditorFn = oapi.RequestEditorFn

+ type SendMessageParams = internal_models.SendMessagesParams