Documentation
¶
Index ¶
- Constants
- Variables
- func AddStoreLog(data commonEntity.Data, operation string)
- func AddTableRecord(data commonEntity.Data)
- func ChangeTableRecord(data commonEntity.Data)
- func CreateStoteLogTable(data commonEntity.Data)
- func DropStoteLogTable(data commonEntity.Data)
- func GetPubSub() PS.PubSub
- func InitDiscovery(peerId string) string
- func InitLogPublisher(libpubsubTpoic *libpubsub.Topic)
- func InitPubSub() string
- func InitStore(instanceId string)
- func Publish(topic string, data interface{})
- func RenameStoteLogTable(data commonEntity.Data)
- func StartNewService()
Constants ¶
View Source
const Address string = "/ip4/0.0.0.0/tcp/0"
Variables ¶
View Source
var PubSub PS.PubSub
Functions ¶
func AddStoreLog ¶ added in v0.0.13
func AddStoreLog(data commonEntity.Data, operation string)
func AddTableRecord ¶ added in v0.0.12
func AddTableRecord(data commonEntity.Data)
func ChangeTableRecord ¶ added in v0.0.13
func ChangeTableRecord(data commonEntity.Data)
func CreateStoteLogTable ¶ added in v0.0.12
func CreateStoteLogTable(data commonEntity.Data)
func DropStoteLogTable ¶ added in v0.0.12
func DropStoteLogTable(data commonEntity.Data)
func InitDiscovery ¶ added in v0.0.4
func InitLogPublisher ¶ added in v0.0.6
func InitPubSub ¶ added in v0.0.12
func InitPubSub() string
func RenameStoteLogTable ¶ added in v0.0.13
func RenameStoteLogTable(data commonEntity.Data)
func StartNewService ¶
func StartNewService()
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.