processer

package
v0.0.0-...-b2ad979 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 4, 2020 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterProcessorServer 

func RegisterProcessorServer(s *grpc.Server, srv ProcessorServer)

Types

type Notification 

type Notification struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Notification) Descriptor 

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

func (*Notification) GetMessage 

func (m *Notification) GetMessage() string

func (*Notification) ProtoMessage 

func (*Notification) ProtoMessage()

func (*Notification) Reset 

func (m *Notification) Reset()

func (*Notification) String 

func (m *Notification) String() string

func (*Notification) XXX_DiscardUnknown 

func (m *Notification) XXX_DiscardUnknown()

func (*Notification) XXX_Marshal 

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

func (*Notification) XXX_Merge 

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

func (*Notification) XXX_Size 

func (m *Notification) XXX_Size() int

func (*Notification) XXX_Unmarshal 

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

type NotificationRequest 

type NotificationRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NotificationRequest) Descriptor 

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

func (*NotificationRequest) ProtoMessage 

func (*NotificationRequest) ProtoMessage()

func (*NotificationRequest) Reset 

func (m *NotificationRequest) Reset()

func (*NotificationRequest) String 

func (m *NotificationRequest) String() string

func (*NotificationRequest) XXX_DiscardUnknown 

func (m *NotificationRequest) XXX_DiscardUnknown()

func (*NotificationRequest) XXX_Marshal 

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

func (*NotificationRequest) XXX_Merge 

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

func (*NotificationRequest) XXX_Size 

func (m *NotificationRequest) XXX_Size() int

func (*NotificationRequest) XXX_Unmarshal 

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

type Process 

type Process struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Process) Descriptor 

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

func (*Process) ProtoMessage 

func (*Process) ProtoMessage()

func (*Process) Reset 

func (m *Process) Reset()

func (*Process) String 

func (m *Process) String() string

func (*Process) XXX_DiscardUnknown 

func (m *Process) XXX_DiscardUnknown()

func (*Process) XXX_Marshal 

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

func (*Process) XXX_Merge 

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

func (*Process) XXX_Size 

func (m *Process) XXX_Size() int

func (*Process) XXX_Unmarshal 

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

type ProcessorClient 

type ProcessorClient interface {
	RequestNotification(ctx context.Context, in *NotificationRequest, opts ...grpc.CallOption) (Processor_RequestNotificationClient, error)
	RegisterProcess(ctx context.Context, in *Process, opts ...grpc.CallOption) (*RegisteredMessage, error)
	RegisterStreamProcess(ctx context.Context, opts ...grpc.CallOption) (Processor_RegisterStreamProcessClient, error)
}

ProcessorClient is the client API for Processor service.

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

func NewProcessorClient 

func NewProcessorClient(cc *grpc.ClientConn) ProcessorClient

type ProcessorServer 

type ProcessorServer interface {
	RequestNotification(*NotificationRequest, Processor_RequestNotificationServer) error
	RegisterProcess(context.Context, *Process) (*RegisteredMessage, error)
	RegisterStreamProcess(Processor_RegisterStreamProcessServer) error
}

ProcessorServer is the server API for Processor service.

type Processor_RegisterStreamProcessClient 

type Processor_RegisterStreamProcessClient interface {
	Send(*Process) error
	Recv() (*RegisteredMessage, error)
	grpc.ClientStream
}

type Processor_RegisterStreamProcessServer 

type Processor_RegisterStreamProcessServer interface {
	Send(*RegisteredMessage) error
	Recv() (*Process, error)
	grpc.ServerStream
}

type Processor_RequestNotificationClient 

type Processor_RequestNotificationClient interface {
	Recv() (*Notification, error)
	grpc.ClientStream
}

type Processor_RequestNotificationServer 

type Processor_RequestNotificationServer interface {
	Send(*Notification) error
	grpc.ServerStream
}

type RegisteredMessage 

type RegisteredMessage struct {
	RecievedAt           *timestamp.Timestamp `protobuf:"bytes,1,opt,name=recievedAt,proto3" json:"recievedAt,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*RegisteredMessage) Descriptor 

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

func (*RegisteredMessage) GetRecievedAt 

func (m *RegisteredMessage) GetRecievedAt() *timestamp.Timestamp

func (*RegisteredMessage) ProtoMessage 

func (*RegisteredMessage) ProtoMessage()

func (*RegisteredMessage) Reset 

func (m *RegisteredMessage) Reset()

func (*RegisteredMessage) String 

func (m *RegisteredMessage) String() string

func (*RegisteredMessage) XXX_DiscardUnknown 

func (m *RegisteredMessage) XXX_DiscardUnknown()

func (*RegisteredMessage) XXX_Marshal 

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

func (*RegisteredMessage) XXX_Merge 

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

func (*RegisteredMessage) XXX_Size 

func (m *RegisteredMessage) XXX_Size() int

func (*RegisteredMessage) XXX_Unmarshal 

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

type UnimplementedProcessorServer 

type UnimplementedProcessorServer struct {
}

UnimplementedProcessorServer can be embedded to have forward compatible implementations.

func (*UnimplementedProcessorServer) RegisterProcess 

func (*UnimplementedProcessorServer) RegisterProcess(ctx context.Context, req *Process) (*RegisteredMessage, error)

func (*UnimplementedProcessorServer) RegisterStreamProcess 

func (*UnimplementedProcessorServer) RegisterStreamProcess(srv Processor_RegisterStreamProcessServer) error

func (*UnimplementedProcessorServer) RequestNotification 

func (*UnimplementedProcessorServer) RequestNotification(req *NotificationRequest, srv Processor_RequestNotificationServer) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.