topic

package
v0.0.0-...-9745057 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 1, 2020 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	WILDCARD         = "*"
	DB_URL           = "127.0.0.1:27017"
	TOPIC_COLLECTION = "TOPIC"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Command 

type Command interface {
	Connect(name string) error
	Close()
	CreateTopic(map[string]interface{}) error
	ReadTopicAll() ([]map[string]interface{}, error)
	ReadTopic(name string, hierarchical bool) ([]map[string]interface{}, error)
	DeleteTopic(name string) error
}

type Executor 

type Executor struct{}

func (Executor) Close 

func (m Executor) Close()

func (Executor) Connect 

func (m Executor) Connect(name string) error

func (Executor) CreateTopic 

func (m Executor) CreateTopic(properties map[string]interface{}) error

func (Executor) DeleteTopic 

func (m Executor) DeleteTopic(name string) error

func (Executor) ReadTopic 

func (m Executor) ReadTopic(name string, hierarchical bool) ([]map[string]interface{}, error)

func (Executor) ReadTopicAll 

func (m Executor) ReadTopicAll() ([]map[string]interface{}, error)

type Topic 

type Topic struct {
	//ID            bson.ObjectId    `bson:"_id,omitempty"`
	Name      string `bson:"name"`
	Endpoint  string `bson:"endpoint"`
	Datamodel string `bson:"datamodel"`
	Secured   bool   `bson:"secured"`
}

Source Files

View all Source files

Directories

Path Synopsis
Package mock_topic is a generated GoMock package.
 Package mock_topic is a generated GoMock package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.