Versions in this module Expand all Collapse all v0 v0.1.1 Jun 21, 2026 Changes in this version + const DeliveryMethodPoll + const DeliveryMethodPush + const EventTypeVerification + const SETMediaType + const SpecVersion + var ErrInvalidConfig = errors.New("invalid stream configuration") + var ErrMethodReserved = errors.New("delivery method reserved") + var ErrNotImplemented = errors.New("not implemented") + var ErrStreamNotFound = errors.New("stream not found") + var ErrUnauthorized = errors.New("unauthorized") + var ErrUnsupportedDelivery = errors.New("unsupported delivery method") + var ErrUnsupportedEvent = errors.New("unsupported event type") + var ErrVerificationTimeout = errors.New("verification timeout") + func RegisterDeliveryMethod(methodURI string, factory DeliveryMethodFactory) error + type AddSubjectRequest struct + Subject subjectid.SubjectIdentifier + Verified *bool + func (r *AddSubjectRequest) UnmarshalJSON(data []byte) error + type Delivery struct + AuthorizationHeader string + EndpointURL string + Method string + func (d *Delivery) UnmarshalJSON(data []byte) error + func (d Delivery) Known() bool + func (d Delivery) MarshalJSON() ([]byte, error) + func (d Delivery) Unknown() (UnknownDelivery, bool) + type DeliveryMethodFactory func() Delivery + func LookupDeliveryMethod(methodURI string) (DeliveryMethodFactory, bool) + type HTTPError struct + Body []byte + RFC7807 *ProblemDetails + StatusCode int + func (e *HTTPError) Error() string + type JOSESetSigner struct + func NewJOSESetSigner(signer jose.Signer) (*JOSESetSigner, error) + func (s *JOSESetSigner) Sign(payload []byte) (string, error) + type JOSESetVerifier struct + func NewJOSESetVerifier(keys jose.JSONWebKeySet) *JOSESetVerifier + func (v *JOSESetVerifier) Verify(jwsCompact string) ([]byte, error) + type PollRequest struct + Ack []string + MaxEvents *int + ReturnImmediately *bool + SetErrs map[string]SetErr + type PollResponse struct + MoreAvailable *bool + Sets map[string]string + type ProblemDetails struct + Detail string + Extensions json.RawMessage + Instance string + Status int + Title string + Type string + func (p *ProblemDetails) MarshalJSON() ([]byte, error) + func (p *ProblemDetails) UnmarshalJSON(data []byte) error + type RemoveSubjectRequest struct + Subject subjectid.SubjectIdentifier + func (r *RemoveSubjectRequest) UnmarshalJSON(data []byte) error + type SETSigner interface + Sign func(payload []byte) (jwsCompact string, err error) + type SETVerifier interface + Verify func(jwsCompact string) (payload []byte, err error) + type SetErr struct + Description string + Err string + type StatusResponse struct + Reason string + Status StreamStatus + Subject json.RawMessage + type StatusUpdateRequest struct + Reason string + Status StreamStatus + Subject json.RawMessage + type StreamConfig struct + Aud json.RawMessage + Delivery Delivery + EventsDelivered []string + EventsRequested []string + EventsSupported []string + Format string + Iss string + MinVerificationInterval int + StreamID string + type StreamStatus string + const StreamStatusDisabled + const StreamStatusEnabled + const StreamStatusPaused + type StreamStore interface + AddSubject func(ctx context.Context, streamID string, req *AddSubjectRequest) error + CreateStream func(ctx context.Context, cfg *StreamConfig) (*StreamConfig, error) + DeleteStream func(ctx context.Context, streamID string) error + EnqueueSET func(ctx context.Context, streamID, jwsCompact string) error + GetStream func(ctx context.Context, streamID string) (*StreamConfig, error) + GetStreamStatus func(ctx context.Context, streamID string, subject json.RawMessage) (*StatusResponse, error) + ListStreams func(ctx context.Context, pageToken string) (configs []*StreamConfig, nextToken string, err error) + RemoveSubject func(ctx context.Context, streamID string, req *RemoveSubjectRequest) error + SetStreamStatus func(ctx context.Context, streamID string, req *StatusUpdateRequest) (*StatusResponse, error) + UpdateStream func(ctx context.Context, cfg *StreamConfig) (*StreamConfig, error) + type TransmitterConfig struct + AddSubjectEndpoint string + AuthorizationSchemes json.RawMessage + ConfigurationEndpoint string + CriticalSubjectMembers []string + DeliveryMethodsSupported []string + Issuer string + JWKSURI string + RemoveSubjectEndpoint string + SpecVersion string + StatusEndpoint string + VerificationEndpoint string + type UnknownDelivery struct + Method string + Raw json.RawMessage + type ValidationError struct + Field string + Reason string + Rule string + func (e *ValidationError) Error() string + type VerificationEvent struct + State string + type VerificationRequest struct + State string v0.1.0 May 26, 2026
Go to main page