channel

Documentation

Index

• type ChannelBuilder
  • func NewBuilder(connection string) (*ChannelBuilder, error)
  • func (cb *ChannelBuilder) Build() (*grpc.ClientConn, error)

Types

type ChannelBuilder

type ChannelBuilder struct {
	Host    string
	Port    int
	Token   string
	User    string
	Headers map[string]string
}

The ChannelBuilder is used to parse the different parameters of the connection string according to the specification documented here:

https://github.com/apache/spark/blob/master/connector/connect/docs/client-connection-string.md

func NewBuilder

func NewBuilder(connection string) (*ChannelBuilder, error)

Creates a new instance of the ChannelBuilder. This constructor effectively parses the connection string and extracts the relevant parameters directly.

func (*ChannelBuilder) Build

func (cb *ChannelBuilder) Build() (*grpc.ClientConn, error)

Finalizes the creation of the gprc.ClientConn by creating a GRPC channel with the necessary options extracted from the connection string. For TLS connections, this function will load the system certificates.