subscriber

type ApplicationConfig struct {
	Database config.DatabaseInfo   `json:"database,omitempty"`
	Sdk      sdkConfig.SdkInfo     `json:"sdk,omitempty"`
	Stream   config.PubSubInfo     `json:"stream,omitempty"`
	Logging  sdkConfig.LoggingInfo `json:"logging,omitempty"`
	Key      string                `json:"preSharedKey,omitempty"` // Key is for IOTA support, shared key. Needs to be moved into SDK IotaStreamConfig
}

type Publisher struct {
	// contains filtered or unexported fields
}

type Subscriber interface {
	Subscribe(ctx context.Context, wg *sync.WaitGroup) bool
	Close()
}