graphql

Documentation

Index

• Constants
• func HasuraApiRequest(host string, token string, body string) error
• func HasuraCreateView(host string, token string, viewName string, viewAs string, materialized bool) error
• func HasuraTrackTable(host string, token string, table string) error
• func RefreshMaterializedView(host string, token string, viewName string) error
• type GraphqlClient
  • func NewGraphqlQueryClient(host string, token string) *GraphqlClient
  • func (c *GraphqlClient) Connect() error
• type GraphqlSubscriptionClient
  • func NewGraphqlSubscriptionClient(host string, token string) (error, *GraphqlSubscriptionClient)
  • func (c *GraphqlSubscriptionClient) GetState() bool
  • func (c *GraphqlSubscriptionClient) Start() error
  • func (c *GraphqlSubscriptionClient) Stop() error
  • func (c *GraphqlSubscriptionClient) Subscribe(query interface{}, handler func(message []byte, err error) error) error
  • func (c *GraphqlSubscriptionClient) Unsubscribe() error

Constants

const ConnectTimeout = 10 * time.Second

Functions

func HasuraApiRequest

func HasuraApiRequest(host string, token string, body string) error

func HasuraCreateView

func HasuraCreateView(host string, token string, viewName string, viewAs string, materialized bool) error

func HasuraTrackTable

func HasuraTrackTable(host string, token string, table string) error

func RefreshMaterializedView

func RefreshMaterializedView(host string, token string, viewName string) error

Types

type GraphqlClient

type GraphqlClient struct {
	Host   string
	Client *graphql.Client
}

func NewGraphqlQueryClient

func NewGraphqlQueryClient(host string, token string) *GraphqlClient

func (*GraphqlClient) Connect

func (c *GraphqlClient) Connect() error

type GraphqlSubscriptionClient

type GraphqlSubscriptionClient struct {
	Client *graphql.SubscriptionClient
	Id     string
	// contains filtered or unexported fields
}

func NewGraphqlSubscriptionClient

func NewGraphqlSubscriptionClient(host string, token string) (error, *GraphqlSubscriptionClient)

func (*GraphqlSubscriptionClient) GetState

func (c *GraphqlSubscriptionClient) GetState() bool

func (*GraphqlSubscriptionClient) Start

func (c *GraphqlSubscriptionClient) Start() error

func (*GraphqlSubscriptionClient) Stop

func (c *GraphqlSubscriptionClient) Stop() error

func (*GraphqlSubscriptionClient) Subscribe

func (c *GraphqlSubscriptionClient) Subscribe(query interface{}, handler func(message []byte, err error) error) error

func (*GraphqlSubscriptionClient) Unsubscribe

func (c *GraphqlSubscriptionClient) Unsubscribe() error