Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IngestorClient ¶
type IngestorClient struct {
// contains filtered or unexported fields
}
func NewIngestorClient ¶
func NewIngestorClient(opts ...IngestorOption) *IngestorClient
func (*IngestorClient) Close ¶
func (i *IngestorClient) Close()
func (*IngestorClient) SendDataEvent ¶
func (i *IngestorClient) SendDataEvent(d ingenium.DataEvent) error
type IngestorOption ¶
type IngestorOption func(*IngestorClient)
func WithNatsServer ¶
func WithNatsServer(server string) IngestorOption
WithNatsServer sets the nats-server address. Default is http://0.0.0.0:4022
Source Files
Click to show internal directories.
Click to hide internal directories.