provision

Documentation

Overview

Package provision contains utilities for obtaining runtime provision, information -- such as pipeline options.

Deprecated: Use github.com/apache/beam/sdks/v2/go/container/tools package instead.

Index

• func Info(ctx context.Context, endpoint string) (*fnpb.ProvisionInfo, error)
• func JSONToProto(data string) (*google_pb.Struct, error)
• func OptionsToProto(v any) (*google_pb.Struct, error)
• func ProtoToJSON(opt *google_pb.Struct) (string, error)
• func ProtoToOptions(opt *google_pb.Struct, v any) error

Functions

func Info

func Info(ctx context.Context, endpoint string) (*fnpb.ProvisionInfo, error)

Info returns the runtime provisioning info for the worker.

Deprecated: Use github.com/apache/beam/sdks/v2/go/container/tools instead.

func JSONToProto

func JSONToProto(data string) (*google_pb.Struct, error)

JSONToProto converts JSON-encoded pipeline options to a proto struct.

Deprecated: Use github.com/apache/beam/sdks/v2/go/container/tools.JSONToProto instead.

func OptionsToProto

func OptionsToProto(v any) (*google_pb.Struct, error)

OptionsToProto converts pipeline options to a proto struct via JSON.

Deprecated: Use github.com/apache/beam/sdks/v2/go/container/tools.OptionsToProto instead.

func ProtoToJSON

func ProtoToJSON(opt *google_pb.Struct) (string, error)

ProtoToJSON converts pipeline options from a proto struct to JSON.

Deprecated: Use github.com/apache/beam/sdks/v2/go/container/tools.ProtoToJSON instead.

func ProtoToOptions

func ProtoToOptions(opt *google_pb.Struct, v any) error

ProtoToOptions converts pipeline options from a proto struct via JSON.

Deprecated: Use github.com/apache/beam/sdks/v2/go/container/tools.ProtoToOptions instead.