endpoint

Documentation

Index

• Constants
• type DataEndpoint
  • func (e *DataEndpoint) Keyspaces() ([]string, error)
  • func (e *DataEndpoint) RoutesGraphQL(pattern string) ([]graphql.Route, error)
  • func (e *DataEndpoint) RoutesKeyspaceGraphQL(pattern string, ksName string) ([]graphql.Route, error)
  • func (e *DataEndpoint) RoutesSchemaManagementGraphQL(pattern string, ops config.SchemaOperations) ([]graphql.Route, error)
  • func (e *DataEndpoint) RoutesSchemaManagementKeyspaceGraphQL(pattern string, ksName string, ops config.SchemaOperations) ([]graphql.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) SchemaUpdateInterval() time.Duration
  • func (cfg DataEndpointConfig) UrlPattern() config.UrlPattern
  • 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) WithSchemaUpdateInterval(updateInterval time.Duration) *DataEndpointConfig
  • func (cfg *DataEndpointConfig) WithUrlPattern(pattern config.UrlPattern) *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) ([]graphql.Route, error)

func (*DataEndpoint) RoutesKeyspaceGraphQL

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

func (*DataEndpoint) RoutesSchemaManagementGraphQL

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

func (*DataEndpoint) RoutesSchemaManagementKeyspaceGraphQL

func (e *DataEndpoint) RoutesSchemaManagementKeyspaceGraphQL(pattern string, ksName string, ops config.SchemaOperations) ([]graphql.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) SchemaUpdateInterval

func (cfg DataEndpointConfig) SchemaUpdateInterval() time.Duration

func (DataEndpointConfig) UrlPattern

func (cfg DataEndpointConfig) UrlPattern() config.UrlPattern

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

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

func (*DataEndpointConfig) WithUrlPattern

func (cfg *DataEndpointConfig) WithUrlPattern(pattern config.UrlPattern) *DataEndpointConfig

WithUrlPattern sets the url pattern to be use to separate url parameters For example: "/graphql/:param1" (colon, default) or "/graphql/{param1}" (brackets)

func (*DataEndpointConfig) WithUseUserOrRoleAuth

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