servers

Documentation

Index

• func NewStarConfigServer(configs domain.ConfigStore) (api.StarConfigServer, error)
• type AppConfigAsyncServer
  • func NewAppConfigAsyncServer(client *meridianapi.MeridianAsyncClient, serf *services.SerfAgent, ...) (*AppConfigAsyncServer, error)
  • func (c *AppConfigAsyncServer) GracefulStop()
  • func (c *AppConfigAsyncServer) Serve()
• type ConfigAsyncServer
  • func NewConfigAsyncServer(client *kuiperapi.KuiperAsyncClient, configs domain.ConfigStore, ...) (*ConfigAsyncServer, error)
  • func (c *ConfigAsyncServer) GracefulStop()
  • func (c *ConfigAsyncServer) Serve()

Functions

func NewStarConfigServer

func NewStarConfigServer(configs domain.ConfigStore) (api.StarConfigServer, error)

Types

type AppConfigAsyncServer

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

func NewAppConfigAsyncServer

func NewAppConfigAsyncServer(client *meridianapi.MeridianAsyncClient, serf *services.SerfAgent, nodeId string) (*AppConfigAsyncServer, error)

func (*AppConfigAsyncServer) GracefulStop

func (c *AppConfigAsyncServer) GracefulStop()

func (*AppConfigAsyncServer) Serve

func (c *AppConfigAsyncServer) Serve()

type ConfigAsyncServer

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

func NewConfigAsyncServer

func NewConfigAsyncServer(client *kuiperapi.KuiperAsyncClient, configs domain.ConfigStore, serf *services.SerfAgent, nodeId string) (*ConfigAsyncServer, error)

func (*ConfigAsyncServer) GracefulStop

func (c *ConfigAsyncServer) GracefulStop()

func (*ConfigAsyncServer) Serve

func (c *ConfigAsyncServer) Serve()