grpc_client

package

v0.0.0-...-ec16f60 Latest Latest Go to latest Published: Apr 15, 2021 License: Apache-2.0 Imports: 24 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/streamsets/datacollector-edge

Documentation ¶

Overview ¶

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Constants ¶

View Source

const (
	Library            = "streamsets-datacollector-basic-lib"
	StageName          = "com_streamsets_pipeline_stage_origin_grpcclient_GrpcClientDSource"
	UnaryRPC           = "UNARY_RPC"
	ServerStreamingRPC = "SERVER_STREAMING_RPC"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ClientConfig ¶

type ClientConfig struct {
	ResourceUrl      string                            `ConfigDef:"type=STRING,required=true"`
	ServiceMethod    string                            `ConfigDef:"type=STRING,required=true"`
	RequestData      string                            `ConfigDef:"type=STRING,required=true"`
	GRPCMode         string                            `ConfigDef:"type=STRING,required=true"`
	PollingInterval  float64                           `ConfigDef:"type=NUMBER,required=true"`
	ConnectTimeout   float64                           `ConfigDef:"type=NUMBER,required=true"`
	KeepaliveTime    float64                           `ConfigDef:"type=NUMBER,required=true"`
	AddlHeaders      map[string]string                 `ConfigDef:"type=MAP,required=true"`
	EmitDefaults     bool                              `ConfigDef:"type=BOOLEAN,required=true"`
	TlsConfig        TlsConfigBean                     `ConfigDefBean:"tlsConfig"`
	Insecure         bool                              `ConfigDef:"type=BOOLEAN,required=true"`
	Authority        string                            `ConfigDef:"type=STRING,required=true"`
	ServerName       string                            `ConfigDef:"type=STRING,required=true"`
	DataFormat       string                            `ConfigDef:"type=STRING,required=true"`
	DataFormatConfig dataparser.DataParserFormatConfig `ConfigDefBean:"dataFormatConfig"`
}

type Origin ¶

type Origin struct {
	*common.BaseStage
	Conf ClientConfig `ConfigDefBean:"conf"`
	// contains filtered or unexported fields
}

func (*Origin) Destroy ¶

func (o *Origin) Destroy() error

func (*Origin) Init ¶

func (o *Origin) Init(stageContext api.StageContext) []validation.Issue

func (*Origin) OnReceiveHeaders ¶

func (o *Origin) OnReceiveHeaders(md metadata.MD)

func (*Origin) OnReceiveResponse ¶

func (o *Origin) OnReceiveResponse(resp proto.Message)

func (*Origin) OnReceiveTrailers ¶

func (o *Origin) OnReceiveTrailers(stat *status.Status, md metadata.MD)

func (*Origin) OnResolveMethod ¶

func (o *Origin) OnResolveMethod(md *desc.MethodDescriptor)

func (*Origin) OnSendHeaders ¶

func (o *Origin) OnSendHeaders(md metadata.MD)

func (*Origin) Produce ¶

func (o *Origin) Produce(lastSourceOffset *string, maxBatchSize int, batchMaker api.BatchMaker) (*string, error)

type TlsConfigBean ¶

type TlsConfigBean struct {
	TlsEnabled         bool   `ConfigDef:"type=BOOLEAN,required=true"`
	TrustStoreFilePath string `ConfigDef:"type=STRING,required=true"`
	KeyStoreFilePath   string `ConfigDef:"type=STRING,required=true"`
}

Source Files ¶

View all Source files

grpc_client.go

Directories ¶

Path	Synopsis
testing
simple
simple_client
simple_server

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL