ncstreams

Documentation

Index

• func Open(ctx context.Context, url string, pubFnk getPublisherFnk, ...) (eventstream.Storager, error)
• type PublishStorage
  • func (m *PublishStorage) Close() (err error)
  • func (m *PublishStorage) Stream(options ...any) (streamObj eventstream.Streamer, err error)

Functions

func Open

func Open(ctx context.Context, url string, pubFnk getPublisherFnk, options ...storage.Option) (eventstream.Storager, error)

Open new storage connection

Types

type PublishStorage

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

PublishStorage processor

func (*PublishStorage) Close

func (m *PublishStorage) Close() (err error)

Close vertica connection

func (*PublishStorage) Stream

func (m *PublishStorage) Stream(options ...any) (streamObj eventstream.Streamer, err error)

Stream metrics processor