gmunch

package module
v0.0.0-...-7c53e23 Latest Latest
Warning

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

Go to latest
Published: Feb 3, 2017 License: MIT Imports: 7 Imported by: 2

README

gmunch

gmunch can run in standalone worker mode (no server), or in full server mode with a grpc endpoint and client for sending events. No docs yet, but check out the example server or the example worker for how to set up a gmunch. The example client shows how to send events to a gmunch server.

Documentation

Overview

Package gmunch is a generated protocol buffer package.

It is generated from these files:

events.proto

It has these top-level messages:

Event
Response

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterEventsServer

func RegisterEventsServer(s *grpc.Server, srv EventsServer)

Types

type Decoder

type Decoder interface {
	Decode(interface{}) error
}

type Event

type Event struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
}

func (*Event) Decoder

func (event *Event) Decoder() Decoder

func (*Event) Descriptor

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

func (*Event) EncodeData

func (event *Event) EncodeData(data interface{}) error

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) Reset

func (m *Event) Reset()

func (*Event) String

func (m *Event) String() string

type EventsClient

type EventsClient interface {
	Publish(ctx context.Context, in *Event, opts ...grpc.CallOption) (*Response, error)
}

func NewEventsClient

func NewEventsClient(cc *grpc.ClientConn) EventsClient

type EventsServer

type EventsServer interface {
	Publish(context.Context, *Event) (*Response, error)
}

type Response

type Response struct {
	Ok bool `protobuf:"varint,1,opt,name=ok" json:"ok,omitempty"`
}

func (*Response) Descriptor

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

func (*Response) ProtoMessage

func (*Response) ProtoMessage()

func (*Response) Reset

func (m *Response) Reset()

func (*Response) String

func (m *Response) String() string

Directories

Path Synopsis
consumer
nsq
examples

Jump to

Keyboard shortcuts

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