client

Documentation

Index

• func NewSubstreamsClient(config *SubstreamsClientConfig) (cli pbsubstreamsrpc.StreamClient, closeFunc func() error, ...)
• func NewSubstreamsInternalClient(config *SubstreamsClientConfig) (cli pbssinternal.SubstreamsClient, closeFunc func() error, ...)
• type InternalClientFactory
  • func NewInternalClientFactory(config *SubstreamsClientConfig) InternalClientFactory
• type SubstreamsClientConfig
  • func NewSubstreamsClientConfig(endpoint string, jwt string, insecure bool, plaintext bool) *SubstreamsClientConfig
  • func (c *SubstreamsClientConfig) Endpoint() string
  • func (c *SubstreamsClientConfig) Insecure() bool
  • func (c *SubstreamsClientConfig) JWT() string
  • func (c *SubstreamsClientConfig) PlainText() bool

Functions

func NewSubstreamsClient

func NewSubstreamsClient(config *SubstreamsClientConfig) (cli pbsubstreamsrpc.StreamClient, closeFunc func() error, callOpts []grpc.CallOption, err error)

func NewSubstreamsInternalClient

func NewSubstreamsInternalClient(config *SubstreamsClientConfig) (cli pbssinternal.SubstreamsClient, closeFunc func() error, callOpts []grpc.CallOption, err error)

Types

type InternalClientFactory

type InternalClientFactory = func() (cli pbssinternal.SubstreamsClient, closeFunc func() error, callOpts []grpc.CallOption, err error)

func NewInternalClientFactory

func NewInternalClientFactory(config *SubstreamsClientConfig) InternalClientFactory

type SubstreamsClientConfig

type SubstreamsClientConfig struct {
	// contains filtered or unexported fields
}

func NewSubstreamsClientConfig

func NewSubstreamsClientConfig(endpoint string, jwt string, insecure bool, plaintext bool) *SubstreamsClientConfig

func (*SubstreamsClientConfig) Endpoint

func (c *SubstreamsClientConfig) Endpoint() string

func (*SubstreamsClientConfig) Insecure

func (c *SubstreamsClientConfig) Insecure() bool

func (*SubstreamsClientConfig) JWT

func (c *SubstreamsClientConfig) JWT() string

func (*SubstreamsClientConfig) PlainText

func (c *SubstreamsClientConfig) PlainText() bool