pipecoupler

package module

v0.0.0-...-5f34eba Latest Latest Go to latest Published: Aug 11, 2022 License: BSD-3-Clause Imports: 12 Imported by: 0

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/TIBCOSoftware/labs-lightcrane-contrib

Links

Open Source Insights

Documentation ¶

Overview ¶

Index ¶

Constants
func New(ctx activity.InitContext) (activity.Activity, error)
func RegisterPipeCouplerServer(s *grpc.Server, srv PipeCouplerServer)
type Activity
- func (a *Activity) Eval(context activity.Context) (done bool, err error)
- func (a *Activity) Metadata() *activity.Metadata
type Data
type Input
- func (i *Input) FromMap(values map[string]interface{}) error
- func (i *Input) ToMap() map[string]interface{}
type Output
- func (o *Output) FromMap(values map[string]interface{}) error
- func (o *Output) ToMap() map[string]interface{}
type PipeCouplerClient
- func NewPipeCouplerClient(cc grpc.ClientConnInterface) PipeCouplerClient
type PipeCouplerServer
type Reply
type Settings
type UnimplementedPipeCouplerServer
- func (*UnimplementedPipeCouplerServer) HandleData(ctx context.Context, req *Data) (*Reply, error)

Constants ¶

View Source

const (
	DownstreamHost = "DownstreamHost"
	Port           = "Port"
)

Variables ¶

This section is empty.

Functions ¶

func New ¶

func New(ctx activity.InitContext) (activity.Activity, error)

func RegisterPipeCouplerServer ¶

func RegisterPipeCouplerServer(s *grpc.Server, srv PipeCouplerServer)

Types ¶

type Activity ¶

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

func (*Activity) Eval ¶

func (a *Activity) Eval(context activity.Context) (done bool, err error)

func (*Activity) Metadata ¶

func (a *Activity) Metadata() *activity.Metadata

type Data ¶

type Data struct {
	Sender               string   `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	ID                   string   `protobuf:"bytes,2,opt,name=ID,proto3" json:"ID,omitempty"`
	Content              string   `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Data) Descriptor ¶

func (*Data) Descriptor() ([]byte, []int)

func (*Data) GetContent ¶

func (m *Data) GetContent() string

func (*Data) GetID ¶

func (m *Data) GetID() string

func (*Data) GetSender ¶

func (m *Data) GetSender() string

func (*Data) ProtoMessage ¶

func (*Data) ProtoMessage()

func (*Data) Reset ¶

func (m *Data) Reset()

func (*Data) String ¶

func (m *Data) String() string

func (*Data) XXX_DiscardUnknown ¶

func (m *Data) XXX_DiscardUnknown()

func (*Data) XXX_Marshal ¶

func (m *Data) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Data) XXX_Merge ¶

func (m *Data) XXX_Merge(src proto.Message)

func (*Data) XXX_Size ¶

func (m *Data) XXX_Size() int

func (*Data) XXX_Unmarshal ¶

func (m *Data) XXX_Unmarshal(b []byte) error

type Input ¶

type Input struct {
	Timeout int                    `md:"Timeout"`
	Data    map[string]interface{} `md:"Data"`
}

func (*Input) FromMap ¶

func (i *Input) FromMap(values map[string]interface{}) error

func (*Input) ToMap ¶

func (i *Input) ToMap() map[string]interface{}

type Output ¶

type Output struct {
	Reply map[string]interface{} `md:"Reply"`
}

func (*Output) FromMap ¶

func (o *Output) FromMap(values map[string]interface{}) error

func (*Output) ToMap ¶

func (o *Output) ToMap() map[string]interface{}

type PipeCouplerClient ¶

type PipeCouplerClient interface {
	HandleData(ctx context.Context, in *Data, opts ...grpc.CallOption) (*Reply, error)
}

PipeCouplerClient is the client API for PipeCoupler service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPipeCouplerClient ¶

func NewPipeCouplerClient(cc grpc.ClientConnInterface) PipeCouplerClient

type PipeCouplerServer ¶

type PipeCouplerServer interface {
	HandleData(context.Context, *Data) (*Reply, error)
}

PipeCouplerServer is the server API for PipeCoupler service.

type Reply ¶

type Reply struct {
	Sender               string   `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	ID                   string   `protobuf:"bytes,2,opt,name=ID,proto3" json:"ID,omitempty"`
	Content              string   `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	Status               bool     `protobuf:"varint,4,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Reply) Descriptor ¶

func (*Reply) Descriptor() ([]byte, []int)

func (*Reply) GetContent ¶

func (m *Reply) GetContent() string

func (*Reply) GetID ¶

func (m *Reply) GetID() string

func (*Reply) GetSender ¶

func (m *Reply) GetSender() string

func (*Reply) GetStatus ¶

func (m *Reply) GetStatus() bool

func (*Reply) ProtoMessage ¶

func (*Reply) ProtoMessage()

func (*Reply) Reset ¶

func (m *Reply) Reset()

func (*Reply) String ¶

func (m *Reply) String() string

func (*Reply) XXX_DiscardUnknown ¶

func (m *Reply) XXX_DiscardUnknown()

func (*Reply) XXX_Marshal ¶

func (m *Reply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Reply) XXX_Merge ¶

func (m *Reply) XXX_Merge(src proto.Message)

func (*Reply) XXX_Size ¶

func (m *Reply) XXX_Size() int

func (*Reply) XXX_Unmarshal ¶

func (m *Reply) XXX_Unmarshal(b []byte) error

type Settings ¶

type Settings struct {
	DownstreamHost string `md:"DownstreamHost"`
	Port           int    `md:"Port"`
}

type UnimplementedPipeCouplerServer ¶

type UnimplementedPipeCouplerServer struct {
}

UnimplementedPipeCouplerServer can be embedded to have forward compatible implementations.

func (*UnimplementedPipeCouplerServer) HandleData ¶

func (*UnimplementedPipeCouplerServer) HandleData(ctx context.Context, req *Data) (*Reply, error)

Source Files ¶

View all Source files

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