util

Documentation

Index

• Variables
• type AsyncJetStreamClient
  • func NewAsyncJetStreamClient() *AsyncJetStreamClient
  • func (c *AsyncJetStreamClient) SetClient(setter func() nats.KeyValue)
  • func (c *AsyncJetStreamClient) WaitForInit()
• type AsyncOpensearchClient
  • func NewAsyncOpensearchClient() *AsyncOpensearchClient
  • func (c *AsyncOpensearchClient) IsInitilized() bool
  • func (c *AsyncOpensearchClient) Lock()
  • func (c *AsyncOpensearchClient) SetClient(setter func() *osclient.Client)
  • func (c *AsyncOpensearchClient) Unlock()
  • func (c *AsyncOpensearchClient) UnsetClient()
  • func (c *AsyncOpensearchClient) WaitForInit()

Variables

var Validate = validator.New()

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()