util

package
v0.6.1 Latest Latest
Warning

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

Go to latest
Published: Nov 8, 2022 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Validate = validator.New()

Functions

This section is empty.

Types

type AsyncJetStreamClient

type AsyncJetStreamClient struct {
	nats.KeyValue
	// contains filtered or unexported fields
}

func NewAsyncJetStreamClient

func NewAsyncJetStreamClient() *AsyncJetStreamClient

func (*AsyncJetStreamClient) SetClient

func (c *AsyncJetStreamClient) SetClient(setter func() nats.KeyValue)

func (*AsyncJetStreamClient) WaitForInit

func (c *AsyncJetStreamClient) WaitForInit()

type AsyncOpensearchClient

type AsyncOpensearchClient struct {
	*osclient.Client
	// contains filtered or unexported fields
}

func NewAsyncOpensearchClient

func NewAsyncOpensearchClient() *AsyncOpensearchClient

func (*AsyncOpensearchClient) IsInitilized

func (c *AsyncOpensearchClient) IsInitilized() bool

func (*AsyncOpensearchClient) Lock

func (c *AsyncOpensearchClient) Lock()

func (*AsyncOpensearchClient) SetClient

func (c *AsyncOpensearchClient) SetClient(setter func() *osclient.Client)

func (*AsyncOpensearchClient) Unlock

func (c *AsyncOpensearchClient) Unlock()

func (*AsyncOpensearchClient) UnsetClient

func (c *AsyncOpensearchClient) UnsetClient()

func (*AsyncOpensearchClient) WaitForInit

func (c *AsyncOpensearchClient) WaitForInit()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL