Documentation
¶
Overview ¶
Package streamlayer contains the Raft stream layer implementation.
Index ¶
Constants ¶
View Source
const (
ListenAddressEnvVar = "STORE_STREAM_LAYER_LISTEN_ADDRESS"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Options ¶
type Options struct {
// ListenAddress is the address to listen on.
ListenAddress string `yaml:"listen-address,omitempty" json:"listen-address,omitempty" toml:"listen-address,omitempty"`
}
Options are the StreamLayer options.
func NewOptions ¶
func NewOptions() *Options
NewOptions returns new StreamLayerOptions with sensible defaults.
type StreamLayer ¶
type StreamLayer interface {
raft.StreamLayer
// ListenPort returns the port the transport is listening on.
ListenPort() int
}
StreamLayer is the StreamLayer interface.
func New ¶
func New(opts *Options) (StreamLayer, error)
New creates a new stream layer with the given options.
Source Files
Click to show internal directories.
Click to hide internal directories.