function

Documentation

Overview

Package function is a generated protocol buffer package.

It is generated from these files:

function.proto

It has these top-level messages:

Message

Index

• func RegisterMessageFunctionServer(s *grpc.Server, srv MessageFunctionServer)
• type Message
  • func (*Message) Descriptor() ([]byte, []int)
  • func (m *Message) GetHeaders() map[string]*Message_HeaderValue
  • func (m *Message) GetPayload() []byte
  • func (*Message) ProtoMessage()
  • func (m *Message) Reset()
  • func (m *Message) String() string
• type MessageFunctionClient
  • func NewMessageFunctionClient(cc *grpc.ClientConn) MessageFunctionClient
• type MessageFunctionServer
• type MessageFunction_CallClient
• type MessageFunction_CallServer
• type Message_HeaderValue
  • func (*Message_HeaderValue) Descriptor() ([]byte, []int)
  • func (m *Message_HeaderValue) GetValues() []string
  • func (*Message_HeaderValue) ProtoMessage()
  • func (m *Message_HeaderValue) Reset()
  • func (m *Message_HeaderValue) String() string

Functions

func RegisterMessageFunctionServer

func RegisterMessageFunctionServer(s *grpc.Server, srv MessageFunctionServer)

Types

type Message

type Message struct {
	Payload []byte                          `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Headers map[string]*Message_HeaderValue `` /* 134-byte string literal not displayed */
}

func (*Message) Descriptor

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

func (*Message) GetHeaders

func (m *Message) GetHeaders() map[string]*Message_HeaderValue

func (*Message) GetPayload

func (m *Message) GetPayload() []byte

func (*Message) ProtoMessage

func (*Message) ProtoMessage()

func (*Message) Reset

func (m *Message) Reset()

func (*Message) String

func (m *Message) String() string

type MessageFunctionClient

type MessageFunctionClient interface {
	Call(ctx context.Context, opts ...grpc.CallOption) (MessageFunction_CallClient, error)
}

func NewMessageFunctionClient

func NewMessageFunctionClient(cc *grpc.ClientConn) MessageFunctionClient

type MessageFunctionServer

type MessageFunctionServer interface {
	Call(MessageFunction_CallServer) error
}

type MessageFunction_CallClient

type MessageFunction_CallClient interface {
	Send(*Message) error
	Recv() (*Message, error)
	grpc.ClientStream
}

type MessageFunction_CallServer

type MessageFunction_CallServer interface {
	Send(*Message) error
	Recv() (*Message, error)
	grpc.ServerStream
}

type Message_HeaderValue

type Message_HeaderValue struct {
	Values []string `protobuf:"bytes,1,rep,name=values" json:"values,omitempty"`
}

func (*Message_HeaderValue) Descriptor

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

func (*Message_HeaderValue) GetValues

func (m *Message_HeaderValue) GetValues() []string

func (*Message_HeaderValue) ProtoMessage

func (*Message_HeaderValue) ProtoMessage()

func (*Message_HeaderValue) Reset

func (m *Message_HeaderValue) Reset()

func (*Message_HeaderValue) String

func (m *Message_HeaderValue) String() string