core

package

Go to main page

Versions in this module

v1

v1.10.0

Apr 28, 2025

v1.9.1

Apr 7, 2025

Changes in this version

+ func NewCacheResponseProcessor(callback func(solace.CacheResponse)) cacheResponseProcessor

+ type AggregatedMetric int

+ const CacheRequestsSucceeded

+ type CacheRequest interface

+ CacheSession func() CoreCacheSession

+ ID func() apimessage.CacheRequestID

+ Index func() CacheRequestMapIndex

+ MessageFilter func() *ReceivedMessageFilter

+ Processor func() CacheResponseProcessor

+ RequestConfig func() resource.CachedMessageSubscriptionRequest

+ UsesLocalDispatch func() bool

+ func NewCacheRequest(cachedMessageSubscriptionRequest resource.CachedMessageSubscriptionRequest, ...) CacheRequest

+ type CacheRequestImpl struct

+ func (cacheRequest *CacheRequestImpl) CacheSession() ccsmp.SolClientCacheSession

+ func (cacheRequest *CacheRequestImpl) ID() apimessage.CacheRequestID

+ func (cacheRequest *CacheRequestImpl) Index() CacheRequestMapIndex

+ func (cacheRequest *CacheRequestImpl) MessageFilter() *ReceivedMessageFilter

+ func (cacheRequest *CacheRequestImpl) Processor() CacheResponseProcessor

+ func (cacheRequest *CacheRequestImpl) RequestConfig() resource.CachedMessageSubscriptionRequest

+ func (cacheRequest *CacheRequestImpl) UsesLocalDispatch() bool

+ type CacheRequestMapIndex = ccsmp.SolClientCacheSessionPt

+ func GetCacheRequestMapIndexFromCacheSession(cacheSession ccsmp.SolClientCacheSession) CacheRequestMapIndex

+ type CacheRequestor interface

+ CancelPendingCacheRequests func(CacheRequestMapIndex, CacheRequest) *CoreCacheEventInfo

+ CleanupCacheRequestSubscriptions func(CacheRequest) error

+ CreateCacheRequest func(resource.CachedMessageSubscriptionRequest, apimessage.CacheRequestID, ...) (CacheRequest, error)

+ DestroyCacheRequest func(CacheRequest) error

+ ProcessCacheEvent func(*sync.Map, CoreCacheEventInfo)

+ SendCacheRequest func(CacheRequest, CoreCacheEventCallback, uintptr) error

+ type CacheResponseProcessor interface

+ ProcessCacheResponse func(solace.CacheResponse)

+ type CoreCacheEventCallback = ccsmp.SolClientCacheEventCallback

+ type CoreCacheEventInfo = ccsmp.CacheEventInfo

+ type CoreCacheSession = ccsmp.SolClientCacheSession

+ func GetCacheSessionFromCacheRequestIndex(cacheRequestMapIndex CacheRequestMapIndex) CoreCacheSession

+ type MessageFilterConfig = ccsmp.SolClientMessageFilteringConfigPt

+ type ReceivedMessageFilter interface

+ CleanupFiltering func()

+ Filter func() MessageFilterConfig

+ SetupFiltering func()

type Receiver

+ CacheRequestor func() CacheRequestor

v1.9.0

Dec 20, 2024

v1.8.1

Dec 20, 2024

v1.8.0

Dec 13, 2024

Changes in this version

+ type MessageSettlementOutcome = ccsmp.SolClientMessageSettlementOutcome

type PersistentReceiver

+ Settle func(msgID MessageID, msgSettlementOutcome MessageSettlementOutcome) ErrorInfo

type Receiver

+ IncrementDuplicateAckCount func()

v1.7.0

Oct 24, 2024

Changes in this version

+ type EndpointProvisioner interface

+ ClearProvisionCorrelation func(id ProvisionCorrelationID)

+ Deprovision func(properties []string, ignoreMissingErrors bool) (ProvisionCorrelationID, <-chan ProvisionEvent, ErrorInfo)

+ Events func() Events

+ IsRunning func() bool

+ Provision func(properties []string, ignoreExistErrors bool) (ProvisionCorrelationID, <-chan ProvisionEvent, ErrorInfo)

type Event

+ const SolClientProvisionError

+ const SolClientProvisionOk

+ type ProvisionCorrelationID = uintptr

+ type ProvisionEvent interface

+ GetError func() error

+ GetID func() ProvisionCorrelationID

type Transport

+ EndpointProvisioner func() EndpointProvisioner

v1.6.1

May 6, 2024

v1.6.0

Apr 29, 2024

Changes in this version

+ var RequestCorrelationPrefix = ccsmp.SolClientGoPropCorrelationPrefix

type Publisher

+ Requestor func() Requestor

type Receiver

+ Replier func() Replier

+ type Repliable = ccsmp.SolClientMessagePt

+ type Replier interface

+ SendReply func(replyMsg ReplyPublishable) ErrorInfo

+ type ReplyPublishable = ccsmp.SolClientMessagePt

+ type Requestor interface

+ AddRequestorReplyHandler func(replyHandler RequestorReplyHandler) (string, func() (messageId uint64, correlationId string), ErrorInfo)

+ CreateReplyToTopic func(publisherID string) string

+ RemoveRequestorReplyHandler func(replyToTopic string) ErrorInfo

+ type RequestorReplyCorrelationEntry = *ccsmpReplyCorrelation

+ type RequestorReplyHandler func(message Repliable, correlationId string) bool

v1.5.0

Jan 22, 2024

v1.4.0

Jun 30, 2023

v1.3.0

Apr 14, 2023

v1.2.0

Jan 16, 2023

Changes in this version

type Transport

+ ModifySessionProperties func([]string) error

v1.1.0

Oct 31, 2022

v1.0.1

Apr 14, 2022

v1.0.0

Mar 31, 2022

Changes in this version

+ func GetVersion() (version, buildTime, variant string)

+ func SetLogLevel(level logging.LogLevel)

+ func SetNativeLogLevel(level logging.LogLevel)

+ func SetVersion(defaultVersion string)

+ func ToNativeError(err ErrorInfo, args ...string) error

+ type AcknowledgementHandler func(correlationMsgId uint64, persisted bool, err error)

+ type Acknowledgements interface

+ AddAcknowledgementHandler func(ackHandler AcknowledgementHandler) (uint64, func() (messageId uint64, correlationTag []byte))

+ RemoveAcknowledgementHandler func(pubID uint64)

+ type ErrorInfo = *ccsmp.SolClientErrorInfoWrapper

+ type Event int

+ const SolClientEventAcknowledgement

+ const SolClientEventCanSend

+ const SolClientEventDown

+ const SolClientEventReconnect

+ const SolClientEventReconnectAttempt

+ const SolClientEventRejected

+ const SolClientEventUp

+ const SolClientSubscriptionError

+ const SolClientSubscriptionOk

+ type EventHandler func(SessionEventInfo)

+ type EventInfo interface

+ GetError func() error

+ GetInfoString func() string

+ type Events interface

+ AddEventHandler func(sessionEvent Event, responseCode EventHandler) uint

+ RemoveEventHandler func(id uint)

+ type FlowEventInfo interface

+ type MessageID = ccsmp.SolClientMessageID

+ type Metrics interface

+ GetStat func(metric metrics.Metric) uint64

+ IncrementMetric func(metric NextGenMetric, amount uint64)

+ ResetStats func()

+ type NextGenMetric int

+ const MetricInternalDiscardNotifications

+ const MetricPublishMessagesBackpressureDiscarded

+ const MetricPublishMessagesTerminationDiscarded

+ const MetricReceivedMessagesBackpressureDiscarded

+ const MetricReceivedMessagesTerminationDiscarded

+ type PersistentEventCallback func(event ccsmp.SolClientFlowEvent, eventInfo FlowEventInfo)

+ type PersistentReceiver interface

+ Ack func(msgID MessageID) ErrorInfo

+ Destination func() (destination string, durable bool, errorInfo ErrorInfo)

+ Destroy func(freeMemory bool) ErrorInfo

+ Start func() ErrorInfo

+ Stop func() ErrorInfo

+ Subscribe func(topic string) (SubscriptionCorrelationID, <-chan SubscriptionEvent, ErrorInfo)

+ Unsubscribe func(topic string) (SubscriptionCorrelationID, <-chan SubscriptionEvent, ErrorInfo)

+ type Publishable = ccsmp.SolClientMessagePt

+ type Publisher interface

+ Acknowledgements func() Acknowledgements

+ AwaitWritable func(terminateSignal chan struct{}) error

+ Events func() Events

+ IncrementMetric func(metric NextGenMetric, amount uint64)

+ IsRunning func() bool

+ Publish func(message Publishable) ErrorInfo

+ TaskQueue func() chan SendTask

+ type Receivable = ccsmp.SolClientMessagePt

+ type Receiver interface

+ ClearSubscriptionCorrelation func(id SubscriptionCorrelationID)

+ EndpointUnsubscribe func(queueName string, topic string) (SubscriptionCorrelationID, <-chan SubscriptionEvent, ErrorInfo)

+ Events func() Events

+ IncrementMetric func(metric NextGenMetric, amount uint64)

+ IsRunning func() bool

+ NewPersistentReceiver func(properties []string, callback RxCallback, ...) (PersistentReceiver, ErrorInfo)

+ ProvisionEndpoint func(queueName string, isExclusive bool) ErrorInfo

+ RegisterRXCallback func(msgCallback RxCallback) uintptr

+ Subscribe func(topic string, ptr uintptr) (SubscriptionCorrelationID, <-chan SubscriptionEvent, ErrorInfo)

+ UnregisterRXCallback func(ptr uintptr)

+ Unsubscribe func(topic string, ptr uintptr) (SubscriptionCorrelationID, <-chan SubscriptionEvent, ErrorInfo)

+ type RxCallback func(msg Receivable) bool

+ type SendTask func()

+ type SessionEventInfo interface

+ GetCorrelationPointer func() unsafe.Pointer

+ type SubscriptionCorrelationID = uintptr

+ type SubscriptionEvent interface

+ GetError func() error

+ GetID func() SubscriptionCorrelationID

+ type Transport interface

+ Close func() error

+ Connect func() error

+ Disconnect func() error

+ Events func() Events

+ Host func() string

+ ID func() string

+ Metrics func() Metrics

+ Publisher func() Publisher

+ Receiver func() Receiver

+ func NewTransport(host string, properties []string) (Transport, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL