DeforaNetworks/corteza
3
0
Fork 0
Code Activity

Fix typo (Streammer) in pkg/envoy

Browse Source
This commit is contained in:
Denis Arh
2021-04-02 10:56:01 +02:00
parent 109e23fc6a
commit b72ccd8a8a
4 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/envoy/builder.go
View File

@@ -29,8 +29,8 @@ type (
Encode(ctx context.Context, p Provider) error
}
// Streammer provides a set of streams of encoded documents
Streammer interface {
// Streamer provides a set of streams of encoded documents
Streamer interface {
Stream() []*Stream
}
@@ -38,10 +38,10 @@ type (
Preparer
Encoder
}
PrepareEncodeStreammer interface {
PrepareEncodeStreamer interface {
Preparer
Encoder
Streammer
Streamer
}
)

2
pkg/envoy/csv/encoder.go
View File

@@ -53,7 +53,7 @@ var (
ErrResourceStateUndefined = errors.New("undefined resource state")
)
func NewBulkRecordEncoder(cfg *EncoderConfig) envoy.PrepareEncodeStreammer {
func NewBulkRecordEncoder(cfg *EncoderConfig) envoy.PrepareEncodeStreamer {
if cfg == nil {
cfg = &EncoderConfig{}
}

2
pkg/envoy/json/encoder.go
View File

@@ -53,7 +53,7 @@ var (
ErrResourceStateUndefined = errors.New("undefined resource state")
)
func NewBulkRecordEncoder(cfg *EncoderConfig) envoy.PrepareEncodeStreammer {
func NewBulkRecordEncoder(cfg *EncoderConfig) envoy.PrepareEncodeStreamer {
if cfg == nil {
cfg = &EncoderConfig{}
}

2
pkg/envoy/yaml/encoder.go
View File

@@ -80,7 +80,7 @@ var (
)
// NewYamlEncoder initializes a fresh yaml encoder
func NewYamlEncoder(cfg *EncoderConfig) envoy.PrepareEncodeStreammer {
func NewYamlEncoder(cfg *EncoderConfig) envoy.PrepareEncodeStreamer {
if cfg == nil {
cfg = &EncoderConfig{}
}