Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

communications

package

Go to main page

Versions in this module

v1

v1.7.2

Sep 2, 2021

Changes in this version

+ var Store storage.Storage

+ func ActivateObjects()

+ func IsTransportError(pResp *http.Response, err error) bool

+ func PrepareDeleteNotifications(metaData common.MetaData) ([]common.NotificationInfo, common.SyncServiceError)

+ func PrepareNotificationsForDestinations(metaData common.MetaData, destinations []common.StoreDestinationStatus, ...) ([]common.NotificationInfo, common.SyncServiceError)

+ func PrepareObjectNotifications(metaData common.MetaData) ([]common.NotificationInfo, common.SyncServiceError)

+ func PrepareObjectStatusNotification(metaData common.MetaData, status string) ([]common.NotificationInfo, common.SyncServiceError)

+ func PrepareUpdateNotification(metaData common.MetaData, destinations []common.Destination) ([]common.NotificationInfo, common.SyncServiceError)

+ func ResendNotifications() common.SyncServiceError

+ func ResendObjects() common.SyncServiceError

+ func SendErrorResponse(writer http.ResponseWriter, err error, message string, statusCode int)

+ func SendNotifications(notifications []common.NotificationInfo) common.SyncServiceError

+ type Communicator interface

+ DeleteOrganization func(orgID string) common.SyncServiceError

+ GetData func(metaData common.MetaData, offset int64) common.SyncServiceError

+ HandleRegAck func()

+ LockDataChunks func(index uint32, metadata *common.MetaData)

+ Register func() common.SyncServiceError

+ RegisterAck func(destination common.Destination) common.SyncServiceError

+ RegisterAsNew func(destination common.Destination) common.SyncServiceError

+ RegisterNew func() common.SyncServiceError

+ ResendObjects func() common.SyncServiceError

+ SendAckResendObjects func(destination common.Destination) common.SyncServiceError

+ SendData func(orgID string, destType string, destID string, message []byte, chunked bool) common.SyncServiceError

+ SendErrorMessage func(err common.SyncServiceError, metaData *common.MetaData, sendToOrigin bool) common.SyncServiceError

+ SendFeedbackMessage func(code int, retryInterval int32, reason string, metaData *common.MetaData, ...) common.SyncServiceError

+ SendNotificationMessage func(notificationTopic string, destType string, destID string, instanceID int64, ...) common.SyncServiceError

+ SendPing func() common.SyncServiceError

+ StartCommunication func() common.SyncServiceError

+ StopCommunication func() common.SyncServiceError

+ UnlockDataChunks func(index uint32, metadata *common.MetaData)

+ Unregister func() common.SyncServiceError

+ UpdateOrganization func(org common.Organization, timestamp time.Time) common.SyncServiceError

+ var Comm Communicator

+ type DestinationRequestQueue struct

+ var DestReqQueue *DestinationRequestQueue

+ func NewDestinationRequestQueue(bufferSize uint64) *DestinationRequestQueue

+ func (q *DestinationRequestQueue) Close()

+ func (q *DestinationRequestQueue) SendDestReqToQueue(destReqInQueue common.DestinationRequestInQueue)

+ type Error struct

+ func (e *Error) Error() string

+ type HTTP struct

+ func (communication *HTTP) ChangeLeadership(isLeader bool) common.SyncServiceError

+ func (communication *HTTP) DeleteOrganization(orgID string) common.SyncServiceError

+ func (communication *HTTP) GetData(metaData common.MetaData, offset int64) common.SyncServiceError

+ func (communication *HTTP) HandleRegAck()

+ func (communication *HTTP) LockDataChunks(index uint32, metadata *common.MetaData)

+ func (communication *HTTP) Poll() bool

+ func (communication *HTTP) Register() common.SyncServiceError

+ func (communication *HTTP) RegisterAck(destination common.Destination) common.SyncServiceError

+ func (communication *HTTP) RegisterAsNew(destination common.Destination) common.SyncServiceError

+ func (communication *HTTP) RegisterNew() common.SyncServiceError

+ func (communication *HTTP) ResendObjects() common.SyncServiceError

+ func (communication *HTTP) SendAckResendObjects(destination common.Destination) common.SyncServiceError

+ func (communication *HTTP) SendData(orgID string, destType string, destID string, message []byte, chunked bool) common.SyncServiceError

+ func (communication *HTTP) SendErrorMessage(err common.SyncServiceError, metaData *common.MetaData, sendToOrigin bool) common.SyncServiceError

+ func (communication *HTTP) SendFeedbackMessage(code int, retryInterval int32, reason string, metaData *common.MetaData, ...) common.SyncServiceError

+ func (communication *HTTP) SendNotificationMessage(notificationTopic string, destType string, destID string, instanceID int64, ...) common.SyncServiceError

+ func (communication *HTTP) SendPing() common.SyncServiceError

+ func (communication *HTTP) StartCommunication() common.SyncServiceError

+ func (communication *HTTP) StopCommunication() common.SyncServiceError

+ func (communication *HTTP) UnlockDataChunks(index uint32, metadata *common.MetaData)

+ func (communication *HTTP) Unregister() common.SyncServiceError

+ func (communication *HTTP) Unsubscribe() common.SyncServiceError

+ func (communication *HTTP) UpdateOrganization(org common.Organization, timestamp time.Time) common.SyncServiceError

+ type MQTT struct

+ func (communication *MQTT) DeleteOrganization(orgID string) common.SyncServiceError

+ func (communication *MQTT) GetData(metaData common.MetaData, offset int64) common.SyncServiceError

+ func (communication *MQTT) HandleRegAck()

+ func (communication *MQTT) LockDataChunks(index uint32, metadata *common.MetaData)

+ func (communication *MQTT) Register() common.SyncServiceError

+ func (communication *MQTT) RegisterAck(destination common.Destination) common.SyncServiceError

+ func (communication *MQTT) RegisterAsNew(destination common.Destination) common.SyncServiceError

+ func (communication *MQTT) RegisterNew() common.SyncServiceError

+ func (communication *MQTT) ResendObjects() common.SyncServiceError

+ func (communication *MQTT) SendAckResendObjects(destination common.Destination) common.SyncServiceError

+ func (communication *MQTT) SendData(orgID string, destType string, destID string, message []byte, chunked bool) common.SyncServiceError

+ func (communication *MQTT) SendErrorMessage(err common.SyncServiceError, metaData *common.MetaData, sendToOrigin bool) common.SyncServiceError

+ func (communication *MQTT) SendFeedbackMessage(code int, retryInterval int32, reason string, metaData *common.MetaData, ...) common.SyncServiceError

+ func (communication *MQTT) SendNotificationMessage(notificationTopic string, destType string, destID string, instanceID int64, ...) common.SyncServiceError

+ func (communication *MQTT) SendPing() common.SyncServiceError

+ func (communication *MQTT) StartCommunication() common.SyncServiceError

+ func (communication *MQTT) StopCommunication() common.SyncServiceError

+ func (communication *MQTT) UnlockDataChunks(index uint32, metadata *common.MetaData)

+ func (communication *MQTT) Unregister() common.SyncServiceError

+ func (communication *MQTT) UpdateOrganization(org common.Organization, timestamp time.Time) common.SyncServiceError

+ type ObjectWorkQueue struct

+ func NewObjectWorkQueue(bufferSize uint64) *ObjectWorkQueue

+ func (q *ObjectWorkQueue) Close()

+ func (q *ObjectWorkQueue) SendObjectToQueue(objectInQueue common.ObjectInQueue)

+ type TestComm struct

+ func (communication *TestComm) DeleteOrganization(orgID string) common.SyncServiceError

+ func (communication *TestComm) GetData(metaData common.MetaData, offset int64) common.SyncServiceError

+ func (communication *TestComm) HandleRegAck()

+ func (communication *TestComm) LockDataChunks(index uint32, metadata *common.MetaData)

+ func (communication *TestComm) Register() common.SyncServiceError

+ func (communication *TestComm) RegisterAck(destination common.Destination) common.SyncServiceError

+ func (communication *TestComm) RegisterAsNew(destination common.Destination) common.SyncServiceError

+ func (communication *TestComm) RegisterNew() common.SyncServiceError

+ func (communication *TestComm) ResendObjects() common.SyncServiceError

+ func (communication *TestComm) SendAckResendObjects(destination common.Destination) common.SyncServiceError

+ func (communication *TestComm) SendData(orgID string, destType string, destID string, message []byte, chunked bool) common.SyncServiceError

+ func (communication *TestComm) SendErrorMessage(err common.SyncServiceError, metaData *common.MetaData, sendToOrigin bool) common.SyncServiceError

+ func (communication *TestComm) SendFeedbackMessage(code int, retryInterval int32, reason string, metaData *common.MetaData, ...) common.SyncServiceError

+ func (communication *TestComm) SendNotificationMessage(notificationTopic string, destType string, destID string, instanceID int64, ...) common.SyncServiceError

+ func (communication *TestComm) SendPing() common.SyncServiceError

+ func (communication *TestComm) StartCommunication() common.SyncServiceError

+ func (communication *TestComm) StopCommunication() common.SyncServiceError

+ func (communication *TestComm) UnlockDataChunks(index uint32, metadata *common.MetaData)

+ func (communication *TestComm) Unregister() common.SyncServiceError

+ func (communication *TestComm) UpdateOrganization(org common.Organization, timestamp time.Time) common.SyncServiceError

+ type Wrapper struct

+ func NewWrapper(httpComm *HTTP, mqttComm *MQTT) *Wrapper

+ func (communication *Wrapper) DeleteOrganization(orgID string) common.SyncServiceError

+ func (communication *Wrapper) GetData(metaData common.MetaData, offset int64) common.SyncServiceError

+ func (communication *Wrapper) HandleRegAck()

+ func (communication *Wrapper) LockDataChunks(index uint32, metadata *common.MetaData)

+ func (communication *Wrapper) Register() common.SyncServiceError

+ func (communication *Wrapper) RegisterAck(destination common.Destination) common.SyncServiceError

+ func (communication *Wrapper) RegisterAsNew(destination common.Destination) common.SyncServiceError

+ func (communication *Wrapper) RegisterNew() common.SyncServiceError

+ func (communication *Wrapper) ResendObjects() common.SyncServiceError

+ func (communication *Wrapper) SendAckResendObjects(destination common.Destination) common.SyncServiceError

+ func (communication *Wrapper) SendData(orgID string, destType string, destID string, message []byte, chunked bool) common.SyncServiceError

+ func (communication *Wrapper) SendErrorMessage(err common.SyncServiceError, metaData *common.MetaData, sendToOrigin bool) common.SyncServiceError

+ func (communication *Wrapper) SendFeedbackMessage(code int, retryInterval int32, reason string, metaData *common.MetaData, ...) common.SyncServiceError

+ func (communication *Wrapper) SendNotificationMessage(notificationTopic string, destType string, destID string, instanceID int64, ...) common.SyncServiceError

+ func (communication *Wrapper) SendPing() common.SyncServiceError

+ func (communication *Wrapper) StartCommunication() common.SyncServiceError

+ func (communication *Wrapper) StopCommunication() common.SyncServiceError

+ func (communication *Wrapper) UnlockDataChunks(index uint32, metadata *common.MetaData)

+ func (communication *Wrapper) Unregister() common.SyncServiceError

+ func (communication *Wrapper) UpdateOrganization(org common.Organization, timestamp time.Time) common.SyncServiceError