endpoint

Documentation

Index

• Constants
• type DataEndpoint
  • func (e *DataEndpoint) Keyspaces() ([]string, error)
  • func (e *DataEndpoint) RoutesGraphQL(pattern string) ([]types.Route, error)
  • func (e *DataEndpoint) RoutesKeyspaceGraphQL(pattern string, ksName string) ([]types.Route, error)
  • func (e *DataEndpoint) RoutesRest(pattern string, operations config.SchemaOperations, singleKs string) []types.Route
  • func (e *DataEndpoint) RoutesSchemaManagementGraphQL(pattern string, ops config.SchemaOperations) ([]types.Route, error)
  • func (e *DataEndpoint) RoutesSchemaManagementKeyspaceGraphQL(pattern string, ksName string, ops config.SchemaOperations) ([]types.Route, error)
• type DataEndpointConfig
  • func NewEndpointConfig(hosts ...string) (*DataEndpointConfig, error)
  • func NewEndpointConfigWithLogger(logger log.Logger, hosts ...string) *DataEndpointConfig
  • func (cfg DataEndpointConfig) DbConfig() db.Config
  • func (cfg DataEndpointConfig) ExcludedKeyspaces() []string
  • func (cfg DataEndpointConfig) Logger() log.Logger
  • func (cfg DataEndpointConfig) Naming() config.NamingConventionFn
  • func (cfg DataEndpointConfig) NewEndpoint() (*DataEndpoint, error)
  • func (cfg DataEndpointConfig) RouterInfo() config.HttpRouterInfo
  • func (cfg DataEndpointConfig) SchemaUpdateInterval() time.Duration
  • func (cfg DataEndpointConfig) UseUserOrRoleAuth() bool
  • func (cfg *DataEndpointConfig) WithDbConfig(dbConfig db.Config) *DataEndpointConfig
  • func (cfg *DataEndpointConfig) WithExcludedKeyspaces(ksExcluded []string) *DataEndpointConfig
  • func (cfg *DataEndpointConfig) WithNaming(naming config.NamingConventionFn) *DataEndpointConfig
  • func (cfg *DataEndpointConfig) WithRouterInfo(routerInfo config.HttpRouterInfo) *DataEndpointConfig
  • func (cfg *DataEndpointConfig) WithSchemaUpdateInterval(updateInterval time.Duration) *DataEndpointConfig
  • func (cfg *DataEndpointConfig) WithUseUserOrRoleAuth(useUserOrRowAuth bool) *DataEndpointConfig

Constants

const DefaultSchemaUpdateDuration = 10 * time.Second

Types

type DataEndpoint

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

func (*DataEndpoint) Keyspaces

func (e *DataEndpoint) Keyspaces() ([]string, error)

Keyspaces gets a slice of keyspace names that are considered by the endpoint when used in multi-keyspace mode.

func (*DataEndpoint) RoutesGraphQL

func (e *DataEndpoint) RoutesGraphQL(pattern string) ([]types.Route, error)

func (*DataEndpoint) RoutesKeyspaceGraphQL

func (e *DataEndpoint) RoutesKeyspaceGraphQL(pattern string, ksName string) ([]types.Route, error)

func (*DataEndpoint) RoutesRest

func (e *DataEndpoint) RoutesRest(pattern string, operations config.SchemaOperations, singleKs string) []types.Route

func (*DataEndpoint) RoutesSchemaManagementGraphQL

func (e *DataEndpoint) RoutesSchemaManagementGraphQL(pattern string, ops config.SchemaOperations) ([]types.Route, error)

func (*DataEndpoint) RoutesSchemaManagementKeyspaceGraphQL

func (e *DataEndpoint) RoutesSchemaManagementKeyspaceGraphQL(pattern string, ksName string, ops config.SchemaOperations) ([]types.Route, error)

type DataEndpointConfig

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

func NewEndpointConfig

func NewEndpointConfig(hosts ...string) (*DataEndpointConfig, error)

func NewEndpointConfigWithLogger

func NewEndpointConfigWithLogger(logger log.Logger, hosts ...string) *DataEndpointConfig

func (DataEndpointConfig) DbConfig

func (cfg DataEndpointConfig) DbConfig() db.Config

func (DataEndpointConfig) ExcludedKeyspaces

func (cfg DataEndpointConfig) ExcludedKeyspaces() []string

func (DataEndpointConfig) Logger

func (cfg DataEndpointConfig) Logger() log.Logger

func (DataEndpointConfig) Naming

func (cfg DataEndpointConfig) Naming() config.NamingConventionFn

func (DataEndpointConfig) NewEndpoint

func (cfg DataEndpointConfig) NewEndpoint() (*DataEndpoint, error)

func (DataEndpointConfig) RouterInfo

func (cfg DataEndpointConfig) RouterInfo() config.HttpRouterInfo

func (DataEndpointConfig) SchemaUpdateInterval

func (cfg DataEndpointConfig) SchemaUpdateInterval() time.Duration

func (DataEndpointConfig) UseUserOrRoleAuth

func (cfg DataEndpointConfig) UseUserOrRoleAuth() bool

func (*DataEndpointConfig) WithDbConfig

func (cfg *DataEndpointConfig) WithDbConfig(dbConfig db.Config) *DataEndpointConfig

func (*DataEndpointConfig) WithExcludedKeyspaces

func (cfg *DataEndpointConfig) WithExcludedKeyspaces(ksExcluded []string) *DataEndpointConfig

func (*DataEndpointConfig) WithNaming

func (cfg *DataEndpointConfig) WithNaming(naming config.NamingConventionFn) *DataEndpointConfig

func (*DataEndpointConfig) WithRouterInfo

func (cfg *DataEndpointConfig) WithRouterInfo(routerInfo config.HttpRouterInfo) *DataEndpointConfig

WithRouterInfo sets the http router information to be used for url parameters

func (*DataEndpointConfig) WithSchemaUpdateInterval

func (cfg *DataEndpointConfig) WithSchemaUpdateInterval(updateInterval time.Duration) *DataEndpointConfig

func (*DataEndpointConfig) WithUseUserOrRoleAuth

func (cfg *DataEndpointConfig) WithUseUserOrRoleAuth(useUserOrRowAuth bool) *DataEndpointConfig