constants

Documentation

Overview

Package constants is defined below

Index

• Constants
• Variables

Constants

const APIName = "pubsubplus-go-client"

APIName is the name of the API as it should appear when describing the API connection, ie. broker connection

const BaseModulePath = "solace.dev/go/messaging"

BaseModulePath is the basepath of the module used for version interpolation

const CoreAPIName = "ccsmp"

CoreAPIName is the name of the Core API as it should appear when describing the API connection, ie. broker connection

const CouldNotCompareRGMID = "could not compare ReplicationGroupMessageIDs: %s"

CouldNotCompareRGMID error string

const CouldNotCompareRGMIDBadType = "could not compare with ReplicationGroupMessageID of type %T"

CouldNotCompareRGMIDBadType error string

const CouldNotConfirmProvisionDeprovisionServiceUnavailable = "could not confirm provision/deprovision, the messaging service was terminated"

CouldNotConfirmProvisionDeprovisionServiceUnavailable error string

const CouldNotConfirmSubscriptionServiceUnavailable = "could not confirm subscription, the messaging service was terminated"

CouldNotConfirmSubscriptionServiceUnavailable error string

const CouldNotCreateRGMID = "could not create ReplicationGroupMessageID from string: %s"

CouldNotCreateRGMID error string

const DefaultAuthenticationScheme = config.AuthenticationSchemeBasic

DefaultAuthenticationScheme is the default auth strategy to use

const DirectReceiverBackpressureMustBeGreaterThan0 = "direct receiver backpressure buffer size must be > 0"

DirectReceiverBackpressureMustBeGreaterThan0 error string

const DirectReceiverUnsupportedSubscriptionType = "DirectMessageReceiver does not support subscriptions of type %T"

DirectReceiverUnsupportedSubscriptionType error string

const FailedToAddSubscription = "failed to add subscription to receiver: "

FailedToAddSubscription error string

const FailedToDeprovisionEndpoint = "failed to deprovision endpoint: "

FailedToDeprovisionEndpoint error string

const FailedToProvisionEndpoint = "failed to provision endpoint: "

FailedToProvisionEndpoint error string

const IncompleteMessageDeliveryMessage = "failed to publish messages, publisher terminated with %d undelivered messages"

IncompleteMessageDeliveryMessage error string

const IncompleteMessageDeliveryMessageWithUnacked = "failed to publish messages, publisher terminated with %d undelivered messages and %d unacknowledged messages"

IncompleteMessageDeliveryMessageWithUnacked error string

const IncompleteMessageReceptionMessage = "failed to dispatch messages, receiver terminated with %d undelivered messages"

IncompleteMessageReceptionMessage error string

const InvalidConfiguration = "invalid configuration provided: "

InvalidConfiguration error string

const InvalidInboundMessageType = "got an invalid InboundMessage, was it received with a receiver? backing type %T"

InvalidInboundMessageType error string

const InvalidMessageSettlementOutcome = "invalid message settlement outcome used to settle message"

InvalidMessageSettlementOutcome error string

const InvalidOutboundMessageType = "got an invalid OutboundMessage, was it built by OutboundMessageBuilder? backing type %T"

InvalidOutboundMessageType error string

const InvalidUserPropertyDataType = "type %T at key %s is not supported for user data"

InvalidUserPropertyDataType error string

const LoginFailure = "failed to authenticate with the broker: "

LoginFailure error string

const MissingReplyMessageHandler = "got nil ReplyMessageHandler, ReplyMessageHandler is required for Publish"

MissingReplyMessageHandler error string

const MissingServicePropertiesGivenScheme = "one of properties %s is required when using authentication scheme %s"

MissingServicePropertiesGivenScheme error string

const MissingServiceProperty = "property %s is required to build a messaging service"

MissingServiceProperty error string

const MissingServicePropertyGivenScheme = "property %s is required when using authentication scheme %s"

MissingServicePropertyGivenScheme error string

const PersistentReceiverCannotPauseBadState = "cannot pause message receiption when not in started state"

PersistentReceiverCannotPauseBadState error string

const PersistentReceiverCannotUnpauseBadState = "cannot resume message receiption when not in started state"

PersistentReceiverCannotUnpauseBadState error string

const PersistentReceiverMissingQueue = "queue must be provided when building a new PersistentMessageReceiver"

PersistentReceiverMissingQueue error string

const PersistentReceiverMustSpecifyRGMID = "" /* 132-byte string literal not displayed */

PersistentReceiverMustSpecifyRGMID error string

const PersistentReceiverMustSpecifyTime = "must specify ReceiverPropertyPersistentMessageReplayStrategyTimeBasedStartTime when replay from time is selected"

PersistentReceiverMustSpecifyTime error string

const PersistentReceiverUnsupportedSubscriptionType = "PersistentMessageReceiver does not support subscriptions of type %T"

PersistentReceiverUnsupportedSubscriptionType error string

const ReceiverCannotReceiveAlreadyTerminated = "receiver has been terminated, no messages to receive"

ReceiverCannotReceiveAlreadyTerminated error string

const ReceiverCannotReceiveNotStarted = "receiver has not yet been started, no messages to receive"

ReceiverCannotReceiveNotStarted error string

const ReceiverTimedOutWaitingForMessage = "timed out waiting for message on call to Receive"

ReceiverTimedOutWaitingForMessage error string

const ReplierFailureToPublishReply = "Publish Reply Error: "

ReplierFailureToPublishReply error string

const RequestReplyPublisherCannotReceiveReplyAlreadyTerminated = "publisher has been terminated, no reply messages to receive"

RequestReplyPublisherCannotReceiveReplyAlreadyTerminated error string

const RequestReplyPublisherTimedOutWaitingForReply = "timed out waiting for reply message for request publish"

RequestReplyPublisherTimedOutWaitingForReply error string

const ShareNameMustNotBeEmpty = "share name must not be empty"

ShareNameMustNotBeEmpty error string

const ShareNameMustNotContainInvalidCharacters = "share name must not contain literals '*' or '>'"

ShareNameMustNotContainInvalidCharacters error string

const TerminatedOnMessagingServiceShutdown = "terminated due to MessagingService disconnect"

TerminatedOnMessagingServiceShutdown error string

const UnableToConnectAlreadyDisconnectedService = "unable to connect messaging service in state %s"

UnableToConnectAlreadyDisconnectedService error string

const UnableToConnectAlreadyDisposedService = "unable to connect messaging service after it has already been disposed of"

UnableToConnectAlreadyDisposedService error string

const UnableToDeprovisionParentServiceNotStarted = "cannot deprovision endpoint unless parent MessagingService is connected"

UnableToDeprovisionParentServiceNotStarted error string

const UnableToDisconnectUnstartedService = "unable to disconnect messaging service in state %s"

UnableToDisconnectUnstartedService error string

const UnableToModifyNonModifiableGivenServiceProperty = "unable to modify the non-modifiable given service property: %s"

UnableToModifyNonModifiableGivenServiceProperty error string

const UnableToModifyPropertyOfDisconnectedService = "unable to modify a property of a service that is disconnected"

UnableToModifyPropertyOfDisconnectedService error string

const UnableToModifySubscriptionBadState = "unable to modify subscriptions in state %s"

UnableToModifySubscriptionBadState error string

const UnableToProvisionParentServiceNotStarted = "cannot provision endpoint unless parent MessagingService is connected"

UnableToProvisionParentServiceNotStarted error string

const UnableToPublishAlreadyTerminated = "unable to publish message: message publisher has been terminated"

UnableToPublishAlreadyTerminated error string

const UnableToPublishNotStarted = "unable to publish message: message publisher is not started. current state: "

UnableToPublishNotStarted error string

const UnableToRegisterCallbackReceiverTerminating = "cannot register message handler, receiver is not running"

UnableToRegisterCallbackReceiverTerminating error string

const UnableToRetrieveMessageID = "unable to retrieve message ID from message, was the message received by a persistent receiver?"

UnableToRetrieveMessageID error string

const UnableToSettleAlreadyTerminated = "unable to settle message: message receiver has been terminated"

UnableToSettleAlreadyTerminated error string

const UnableToSettleNotStarted = "unable to settle meessage: message receiver is not yet started"

UnableToSettleNotStarted error string

const UnableToStartPublisher = "cannot start the publisher as it has already been terminated"

UnableToStartPublisher error string

const UnableToStartPublisherParentServiceNotStarted = "cannot start publisher unless parent MessagingService is connected"

UnableToStartPublisherParentServiceNotStarted error string

const UnableToStartReceiver = "cannot start the receiver as it has already been terminated"

UnableToStartReceiver error string

const UnableToStartReceiverParentServiceNotStarted = "cannot start receiver unless parent MessagingService is connected"

UnableToStartReceiverParentServiceNotStarted error string

const UnableToTerminatePublisher = "cannot terminate the publisher as it has not been started"

UnableToTerminatePublisher error string

const UnableToTerminateReceiver = "cannot terminate the receiver as it has not been started"

UnableToTerminateReceiver error string

const UnresolvedSession = "requested service is unreachable: "

UnresolvedSession error string

const WouldBlock = "buffer is full, cannot queue additional messages"

WouldBlock error string

Variables

var DefaultCcsmpProperties = map[string]string{
	ccsmp.SolClientSessionPropTopicDispatch:              ccsmp.SolClientPropEnableVal,
	ccsmp.SolClientSessionPropSendBlocking:               ccsmp.SolClientPropDisableVal,
	ccsmp.SolClientSessionPropReapplySubscriptions:       ccsmp.SolClientPropEnableVal,
	ccsmp.SolClientSessionPropIgnoreDupSubscriptionError: ccsmp.SolClientPropEnableVal,
	ccsmp.SolClientSessionPropReconnectRetries:           "3",
	ccsmp.SolClientSessionPropGuaranteedWithWebTransport: ccsmp.SolClientPropEnableVal,
	ccsmp.SolClientSessionPropPubWindowSize:              "255",
}

DefaultCcsmpProperties contains the default properties to use when building a new session

var DefaultConfiguration = config.ServicePropertyMap{}

DefaultConfiguration refers to any default configuration values that should override the default CCSMP values here

var DefaultDirectPublisherProperties = config.PublisherPropertyMap{
	config.PublisherPropertyBackPressureBufferCapacity: 50,
	config.PublisherPropertyBackPressureStrategy:       config.PublisherPropertyBackPressureStrategyBufferWaitWhenFull,
}

DefaultDirectPublisherProperties contains the default properties for a DirectPublisher

var DefaultDirectReceiverProperties = config.ReceiverPropertyMap{
	config.ReceiverPropertyDirectBackPressureStrategy:       config.ReceiverBackPressureStrategyDropLatest,
	config.ReceiverPropertyDirectBackPressureBufferCapacity: 50,
}

DefaultDirectReceiverProperties contains the default properties for a DirectReceiver

var DefaultEndpointProperties = config.EndpointPropertyMap{
	config.EndpointPropertyDurable: true,
}

DefaultEndpointProperties contains the default properties to provision an Endpoint

var DefaultPersistentPublisherProperties = config.PublisherPropertyMap{
	config.PublisherPropertyBackPressureBufferCapacity: 50,
	config.PublisherPropertyBackPressureStrategy:       config.PublisherPropertyBackPressureStrategyBufferWaitWhenFull,
}

DefaultPersistentPublisherProperties contains the default properties for a PersistentPublisher

var DefaultPersistentReceiverProperties = config.ReceiverPropertyMap{}

DefaultPersistentReceiverProperties contains the default properties for a PersistentReceiver