mastermsg

Documentation

Overview

Package mastermsg is a generated protocol buffer package.

It is generated from these files:

mastermsg.proto

It has these top-level messages:

EventRequest
EventResponse

Index

• func AcceptMsgServiceClient(lis net.Listener, x MsgService)
• func ListenAndServeMsgService(network, addr string, x MsgService) error
• func NewMsgServiceServer(x MsgService) *rpc.Server
• func RegisterMsgService(srv *rpc.Server, x MsgService) error
• func SendEventMsg(site_id, domainname, _type, memo string, data map[string]string, url ...string) (string, error)
• type EventRequest
  • func (m *EventRequest) GetData() string
  • func (m *EventRequest) GetDomainname() string
  • func (m *EventRequest) GetMemo() string
  • func (m *EventRequest) GetSiteId() string
  • func (m *EventRequest) GetType() string
  • func (*EventRequest) ProtoMessage()
  • func (m *EventRequest) Reset()
  • func (m *EventRequest) String() string
• type EventResponse
  • func (m *EventResponse) GetEventId() string
  • func (*EventResponse) ProtoMessage()
  • func (m *EventResponse) Reset()
  • func (m *EventResponse) String() string
• type MsgService
• type MsgServiceClient
  • func DialMsgService(network, addr string) (*MsgServiceClient, *rpc.Client, error)
  • func DialMsgServiceTimeout(network, addr string, timeout time.Duration) (*MsgServiceClient, *rpc.Client, error)
  • func NewMsgServiceClient(conn io.ReadWriteCloser) (*MsgServiceClient, *rpc.Client)
  • func (c *MsgServiceClient) SendEvent(in *EventRequest, out *EventResponse) error

Functions

func AcceptMsgServiceClient

func AcceptMsgServiceClient(lis net.Listener, x MsgService)

AcceptMsgServiceClient accepts connections on the listener and serves requests for each incoming connection. Accept blocks; the caller typically invokes it in a go statement.

func ListenAndServeMsgService

func ListenAndServeMsgService(network, addr string, x MsgService) error

ListenAndServeMsgService listen announces on the local network address laddr and serves the given MsgService implementation.

func NewMsgServiceServer

func NewMsgServiceServer(x MsgService) *rpc.Server

NewMsgServiceServer returns a new MsgService Server.

func RegisterMsgService

func RegisterMsgService(srv *rpc.Server, x MsgService) error

RegisterMsgService publish the given MsgService implementation on the server.

func SendEventMsg

func SendEventMsg(site_id, domainname, _type, memo string, data map[string]string, url ...string) (string, error)

Types

type EventRequest

type EventRequest struct {
	SiteId           *string `protobuf:"bytes,1,opt,name=site_id" json:"site_id,omitempty"`
	Domainname       *string `protobuf:"bytes,2,opt,name=domainname" json:"domainname,omitempty"`
	Type             *string `protobuf:"bytes,3,opt,name=type" json:"type,omitempty"`
	Memo             *string `protobuf:"bytes,4,opt,name=memo" json:"memo,omitempty"`
	Data             *string `protobuf:"bytes,5,opt,name=data" json:"data,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

算术运算请求结构

func (*EventRequest) GetData

func (m *EventRequest) GetData() string

func (*EventRequest) GetDomainname

func (m *EventRequest) GetDomainname() string

func (*EventRequest) GetMemo

func (m *EventRequest) GetMemo() string

func (*EventRequest) GetSiteId

func (m *EventRequest) GetSiteId() string

func (*EventRequest) GetType

func (m *EventRequest) GetType() string

func (*EventRequest) ProtoMessage

func (*EventRequest) ProtoMessage()

func (*EventRequest) Reset

func (m *EventRequest) Reset()

func (*EventRequest) String

func (m *EventRequest) String() string

type EventResponse

type EventResponse struct {
	EventId          *string `protobuf:"bytes,1,opt,name=event_id" json:"event_id,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

算术运算响应结构

func (*EventResponse) GetEventId

func (m *EventResponse) GetEventId() string

func (*EventResponse) ProtoMessage

func (*EventResponse) ProtoMessage()

func (*EventResponse) Reset

func (m *EventResponse) Reset()

func (*EventResponse) String

func (m *EventResponse) String() string

type MsgService

type MsgService interface {
	SendEvent(in *EventRequest, out *EventResponse) error
}

type MsgServiceClient

type MsgServiceClient struct {
	*rpc.Client
}

func DialMsgService

func DialMsgService(network, addr string) (*MsgServiceClient, *rpc.Client, error)

DialMsgService connects to an MsgService at the specified network address.

func DialMsgServiceTimeout

func DialMsgServiceTimeout(network, addr string,
	timeout time.Duration) (*MsgServiceClient, *rpc.Client, error)

DialMsgServiceTimeout connects to an MsgService at the specified network address.

func NewMsgServiceClient

func NewMsgServiceClient(conn io.ReadWriteCloser) (*MsgServiceClient, *rpc.Client)

NewMsgServiceClient returns a MsgService rpc.Client and stub to handle requests to the set of MsgService at the other end of the connection.

func (*MsgServiceClient) SendEvent

func (c *MsgServiceClient) SendEvent(in *EventRequest, out *EventResponse) error