pipecoupler

Documentation

Overview

* Copyright © 2020. TIBCO Software Inc. * This file is subject to the license terms contained * in the license file that is distributed with this file.

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
  • func (*Data) Descriptor() ([]byte, []int)
  • func (m *Data) GetContent() string
  • func (m *Data) GetID() string
  • func (m *Data) GetSender() string
  • func (*Data) ProtoMessage()
  • func (m *Data) Reset()
  • func (m *Data) String() string
  • func (m *Data) XXX_DiscardUnknown()
  • func (m *Data) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Data) XXX_Merge(src proto.Message)
  • func (m *Data) XXX_Size() int
  • func (m *Data) XXX_Unmarshal(b []byte) error
• 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
  • func (*Reply) Descriptor() ([]byte, []int)
  • func (m *Reply) GetContent() string
  • func (m *Reply) GetID() string
  • func (m *Reply) GetSender() string
  • func (m *Reply) GetStatus() bool
  • func (*Reply) ProtoMessage()
  • func (m *Reply) Reset()
  • func (m *Reply) String() string
  • func (m *Reply) XXX_DiscardUnknown()
  • func (m *Reply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Reply) XXX_Merge(src proto.Message)
  • func (m *Reply) XXX_Size() int
  • func (m *Reply) XXX_Unmarshal(b []byte) error
• type Settings
• type UnimplementedPipeCouplerServer
  • func (*UnimplementedPipeCouplerServer) HandleData(ctx context.Context, req *Data) (*Reply, error)

Constants

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

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)