Documentation
¶
Index ¶
- type Provider
- func (p *Provider) Close() error
- func (p *Provider) CloseWebSocket(ctx context.Context, request *types.WebSocketRequest) error
- func (p *Provider) Configure(config map[string]interface{}) error
- func (p *Provider) Connect(ctx context.Context) error
- func (p *Provider) ConnectWebSocket(ctx context.Context, request *types.WebSocketRequest) (*types.WebSocketResponse, error)
- func (p *Provider) Disconnect(ctx context.Context) error
- func (p *Provider) GetConnectionInfo() *types.ConnectionInfo
- func (p *Provider) GetName() string
- func (p *Provider) GetStats(ctx context.Context) (*types.APIStats, error)
- func (p *Provider) GetSupportedFeatures() []types.APIFeature
- func (p *Provider) HealthCheck(ctx context.Context) error
- func (p *Provider) IsConfigured() bool
- func (p *Provider) IsConnected() bool
- func (p *Provider) Ping(ctx context.Context) error
- func (p *Provider) SendBatch(ctx context.Context, request *types.BatchRequest) (*types.BatchResponse, error)
- func (p *Provider) SendGraphQLRequest(ctx context.Context, request *types.GraphQLRequest) (*types.GraphQLResponse, error)
- func (p *Provider) SendRequest(ctx context.Context, request *types.APIRequest) (*types.APIResponse, error)
- func (p *Provider) SendWebSocketMessage(ctx context.Context, request *types.WebSocketRequest, message interface{}) (*types.WebSocketResponse, error)
- func (p *Provider) SendgRPCRequest(ctx context.Context, request *types.GRPCRequest) (*types.GRPCResponse, error)
- func (p *Provider) StreamRequest(ctx context.Context, request *types.APIRequest, handler types.APIHandler) error
- func (p *Provider) WebSocketStream(ctx context.Context, request *types.WebSocketRequest, ...) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Provider ¶
type Provider struct {
// contains filtered or unexported fields
}
Provider implements APIProvider for HTTP
func NewProvider ¶
NewProvider creates a new HTTP API provider
func (*Provider) CloseWebSocket ¶
CloseWebSocket is not supported by HTTP provider
func (*Provider) ConnectWebSocket ¶
func (p *Provider) ConnectWebSocket(ctx context.Context, request *types.WebSocketRequest) (*types.WebSocketResponse, error)
ConnectWebSocket connects to a WebSocket
func (*Provider) Disconnect ¶
Disconnect disconnects from HTTP service
func (*Provider) GetConnectionInfo ¶
func (p *Provider) GetConnectionInfo() *types.ConnectionInfo
GetConnectionInfo returns connection information
func (*Provider) GetSupportedFeatures ¶
func (p *Provider) GetSupportedFeatures() []types.APIFeature
GetSupportedFeatures returns supported features
func (*Provider) HealthCheck ¶
HealthCheck performs a health check on HTTP
func (*Provider) IsConfigured ¶
IsConfigured checks if the provider is configured
func (*Provider) IsConnected ¶
IsConnected checks if HTTP is connected
func (*Provider) SendBatch ¶
func (p *Provider) SendBatch(ctx context.Context, request *types.BatchRequest) (*types.BatchResponse, error)
SendBatch sends multiple HTTP requests
func (*Provider) SendGraphQLRequest ¶
func (p *Provider) SendGraphQLRequest(ctx context.Context, request *types.GraphQLRequest) (*types.GraphQLResponse, error)
SendGraphQLRequest sends a GraphQL request
func (*Provider) SendRequest ¶
func (p *Provider) SendRequest(ctx context.Context, request *types.APIRequest) (*types.APIResponse, error)
SendRequest sends an HTTP request
func (*Provider) SendWebSocketMessage ¶
func (p *Provider) SendWebSocketMessage(ctx context.Context, request *types.WebSocketRequest, message interface{}) (*types.WebSocketResponse, error)
SendWebSocketMessage is not supported by HTTP provider
func (*Provider) SendgRPCRequest ¶
func (p *Provider) SendgRPCRequest(ctx context.Context, request *types.GRPCRequest) (*types.GRPCResponse, error)
SendgRPCRequest is not supported by HTTP provider
func (*Provider) StreamRequest ¶
func (p *Provider) StreamRequest(ctx context.Context, request *types.APIRequest, handler types.APIHandler) error
StreamRequest streams an HTTP request
func (*Provider) WebSocketStream ¶
func (p *Provider) WebSocketStream(ctx context.Context, request *types.WebSocketRequest, handler types.WebSocketHandler) error
WebSocketStream is not supported by HTTP provider
Source Files
Click to show internal directories.
Click to hide internal directories.