Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewFirehoseClient ¶
func NewFirehoseClient(endpoint, jwt, apiKey string, useInsecureTSLConnection, usePlainTextConnection bool) (cli pbfirehose.StreamClient, closeFunc func() error, callOpts []grpc.CallOption, err error)
firehoseClient, closeFunc, grpcCallOpts, err := NewFirehoseClient(endpoint, jwt, insecure, plaintext) defer closeFunc() stream, err := firehoseClient.Blocks(context.Background(), request, grpcCallOpts...)
func NewFirehoseFetchClient ¶
func NewFirehoseFetchClient(endpoint, jwt, apiKey string, useInsecureTSLConnection, usePlainTextConnection bool) (cli pbfirehose.FetchClient, closeFunc func() error, callOpts []grpc.CallOption, err error)
Types ¶
type ApiKeyAuth ¶ added in v1.2.1
type ApiKeyAuth struct {
ApiKey string
}
func (*ApiKeyAuth) GetRequestMetadata ¶ added in v1.2.1
func (*ApiKeyAuth) RequireTransportSecurity ¶ added in v1.2.1
func (a *ApiKeyAuth) RequireTransportSecurity() bool
Source Files
Click to show internal directories.
Click to hide internal directories.