chatbothub

package
v0.0.0-...-d22cea1 Latest Latest
Warning

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

 Go to latest Published: Apr 7, 2020 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterChatBotHubServer 

func RegisterChatBotHubServer(s *grpc.Server, srv ChatBotHubServer)

Types

type BotActionReply 

type BotActionReply struct {
	ActionRequestId      string          `protobuf:"bytes,1,opt,name=actionRequestId,proto3" json:"actionRequestId,omitempty"`
	Success              bool            `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	Msg                  string          `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	Body                 string          `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	ClientError          *OperationReply `protobuf:"bytes,5,opt,name=clientError,proto3" json:"clientError,omitempty"`
	ClientType           string          `protobuf:"bytes,6,opt,name=clientType,proto3" json:"clientType,omitempty"`
	ClientId             string          `protobuf:"bytes,7,opt,name=clientId,proto3" json:"clientId,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*BotActionReply) Descriptor 

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

func (*BotActionReply) GetActionRequestId 

func (m *BotActionReply) GetActionRequestId() string

func (*BotActionReply) GetBody 

func (m *BotActionReply) GetBody() string

func (*BotActionReply) GetClientError 

func (m *BotActionReply) GetClientError() *OperationReply

func (*BotActionReply) GetClientId 

func (m *BotActionReply) GetClientId() string

func (*BotActionReply) GetClientType 

func (m *BotActionReply) GetClientType() string

func (*BotActionReply) GetMsg 

func (m *BotActionReply) GetMsg() string

func (*BotActionReply) GetSuccess 

func (m *BotActionReply) GetSuccess() bool

func (*BotActionReply) ProtoMessage 

func (*BotActionReply) ProtoMessage()

func (*BotActionReply) Reset 

func (m *BotActionReply) Reset()

func (*BotActionReply) String 

func (m *BotActionReply) String() string

func (*BotActionReply) XXX_DiscardUnknown 

func (m *BotActionReply) XXX_DiscardUnknown()

func (*BotActionReply) XXX_Marshal 

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

func (*BotActionReply) XXX_Merge 

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

func (*BotActionReply) XXX_Size 

func (m *BotActionReply) XXX_Size() int

func (*BotActionReply) XXX_Unmarshal 

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

type BotActionRequest 

type BotActionRequest struct {
	ActionRequestId      string   `protobuf:"bytes,1,opt,name=actionRequestId,proto3" json:"actionRequestId,omitempty"`
	Login                string   `protobuf:"bytes,2,opt,name=login,proto3" json:"login,omitempty"`
	ActionType           string   `protobuf:"bytes,3,opt,name=actionType,proto3" json:"actionType,omitempty"`
	ActionBody           string   `protobuf:"bytes,4,opt,name=actionBody,proto3" json:"actionBody,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BotActionRequest) Descriptor 

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

func (*BotActionRequest) GetActionBody 

func (m *BotActionRequest) GetActionBody() string

func (*BotActionRequest) GetActionRequestId 

func (m *BotActionRequest) GetActionRequestId() string

func (*BotActionRequest) GetActionType 

func (m *BotActionRequest) GetActionType() string

func (*BotActionRequest) GetLogin 

func (m *BotActionRequest) GetLogin() string

func (*BotActionRequest) ProtoMessage 

func (*BotActionRequest) ProtoMessage()

func (*BotActionRequest) Reset 

func (m *BotActionRequest) Reset()

func (*BotActionRequest) String 

func (m *BotActionRequest) String() string

func (*BotActionRequest) XXX_DiscardUnknown 

func (m *BotActionRequest) XXX_DiscardUnknown()

func (*BotActionRequest) XXX_Marshal 

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

func (*BotActionRequest) XXX_Merge 

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

func (*BotActionRequest) XXX_Size 

func (m *BotActionRequest) XXX_Size() int

func (*BotActionRequest) XXX_Unmarshal 

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

type BotFilterRequest 

type BotFilterRequest struct {
	BotId                string   `protobuf:"bytes,1,opt,name=botId,proto3" json:"botId,omitempty"`
	FilterId             string   `protobuf:"bytes,2,opt,name=filterId,proto3" json:"filterId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BotFilterRequest) Descriptor 

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

func (*BotFilterRequest) GetBotId 

func (m *BotFilterRequest) GetBotId() string

func (*BotFilterRequest) GetFilterId 

func (m *BotFilterRequest) GetFilterId() string

func (*BotFilterRequest) ProtoMessage 

func (*BotFilterRequest) ProtoMessage()

func (*BotFilterRequest) Reset 

func (m *BotFilterRequest) Reset()

func (*BotFilterRequest) String 

func (m *BotFilterRequest) String() string

func (*BotFilterRequest) XXX_DiscardUnknown 

func (m *BotFilterRequest) XXX_DiscardUnknown()

func (*BotFilterRequest) XXX_Marshal 

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

func (*BotFilterRequest) XXX_Merge 

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

func (*BotFilterRequest) XXX_Size 

func (m *BotFilterRequest) XXX_Size() int

func (*BotFilterRequest) XXX_Unmarshal 

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

type BotLoginReply 

type BotLoginReply struct {
	Msg                  string          `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	ClientError          *OperationReply `protobuf:"bytes,2,opt,name=clientError,proto3" json:"clientError,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*BotLoginReply) Descriptor 

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

func (*BotLoginReply) GetClientError 

func (m *BotLoginReply) GetClientError() *OperationReply

func (*BotLoginReply) GetMsg 

func (m *BotLoginReply) GetMsg() string

func (*BotLoginReply) ProtoMessage 

func (*BotLoginReply) ProtoMessage()

func (*BotLoginReply) Reset 

func (m *BotLoginReply) Reset()

func (*BotLoginReply) String 

func (m *BotLoginReply) String() string

func (*BotLoginReply) XXX_DiscardUnknown 

func (m *BotLoginReply) XXX_DiscardUnknown()

func (*BotLoginReply) XXX_Marshal 

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

func (*BotLoginReply) XXX_Merge 

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

func (*BotLoginReply) XXX_Size 

func (m *BotLoginReply) XXX_Size() int

func (*BotLoginReply) XXX_Unmarshal 

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

type BotLoginRequest 

type BotLoginRequest struct {
	ClientId             string   `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId,omitempty"`
	ClientType           string   `protobuf:"bytes,2,opt,name=clientType,proto3" json:"clientType,omitempty"`
	Login                string   `protobuf:"bytes,3,opt,name=login,proto3" json:"login,omitempty"`
	Password             string   `protobuf:"bytes,4,opt,name=password,proto3" json:"password,omitempty"`
	NotifyUrl            string   `protobuf:"bytes,5,opt,name=notifyUrl,proto3" json:"notifyUrl,omitempty"`
	LoginInfo            string   `protobuf:"bytes,6,opt,name=loginInfo,proto3" json:"loginInfo,omitempty"`
	BotId                string   `protobuf:"bytes,7,opt,name=botId,proto3" json:"botId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BotLoginRequest) Descriptor 

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

func (*BotLoginRequest) GetBotId 

func (m *BotLoginRequest) GetBotId() string

func (*BotLoginRequest) GetClientId 

func (m *BotLoginRequest) GetClientId() string

func (*BotLoginRequest) GetClientType 

func (m *BotLoginRequest) GetClientType() string

func (*BotLoginRequest) GetLogin 

func (m *BotLoginRequest) GetLogin() string

func (*BotLoginRequest) GetLoginInfo 

func (m *BotLoginRequest) GetLoginInfo() string

func (*BotLoginRequest) GetNotifyUrl 

func (m *BotLoginRequest) GetNotifyUrl() string

func (*BotLoginRequest) GetPassword 

func (m *BotLoginRequest) GetPassword() string

func (*BotLoginRequest) ProtoMessage 

func (*BotLoginRequest) ProtoMessage()

func (*BotLoginRequest) Reset 

func (m *BotLoginRequest) Reset()

func (*BotLoginRequest) String 

func (m *BotLoginRequest) String() string

func (*BotLoginRequest) XXX_DiscardUnknown 

func (m *BotLoginRequest) XXX_DiscardUnknown()

func (*BotLoginRequest) XXX_Marshal 

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

func (*BotLoginRequest) XXX_Merge 

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

func (*BotLoginRequest) XXX_Size 

func (m *BotLoginRequest) XXX_Size() int

func (*BotLoginRequest) XXX_Unmarshal 

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

type BotLogoutRequest 

type BotLogoutRequest struct {
	BotId                string   `protobuf:"bytes,1,opt,name=botId,proto3" json:"botId,omitempty"`
	ClientId             string   `protobuf:"bytes,2,opt,name=clientId,proto3" json:"clientId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BotLogoutRequest) Descriptor 

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

func (*BotLogoutRequest) GetBotId 

func (m *BotLogoutRequest) GetBotId() string

func (*BotLogoutRequest) GetClientId 

func (m *BotLogoutRequest) GetClientId() string

func (*BotLogoutRequest) ProtoMessage 

func (*BotLogoutRequest) ProtoMessage()

func (*BotLogoutRequest) Reset 

func (m *BotLogoutRequest) Reset()

func (*BotLogoutRequest) String 

func (m *BotLogoutRequest) String() string

func (*BotLogoutRequest) XXX_DiscardUnknown 

func (m *BotLogoutRequest) XXX_DiscardUnknown()

func (*BotLogoutRequest) XXX_Marshal 

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

func (*BotLogoutRequest) XXX_Merge 

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

func (*BotLogoutRequest) XXX_Size 

func (m *BotLogoutRequest) XXX_Size() int

func (*BotLogoutRequest) XXX_Unmarshal 

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

type BotsInfo 

type BotsInfo struct {
	ClientId             string   `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId,omitempty"`
	ClientType           string   `protobuf:"bytes,2,opt,name=clientType,proto3" json:"clientType,omitempty"`
	Name                 string   `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	StartAt              int64    `protobuf:"varint,4,opt,name=startAt,proto3" json:"startAt,omitempty"`
	LastPing             int64    `protobuf:"varint,5,opt,name=lastPing,proto3" json:"lastPing,omitempty"`
	Login                string   `protobuf:"bytes,6,opt,name=login,proto3" json:"login,omitempty"`
	LoginInfo            string   `protobuf:"bytes,7,opt,name=loginInfo,proto3" json:"loginInfo,omitempty"`
	Status               int32    `protobuf:"varint,8,opt,name=status,proto3" json:"status,omitempty"`
	FilterInfo           string   `protobuf:"bytes,9,opt,name=filterInfo,proto3" json:"filterInfo,omitempty"`
	MomentFilterInfo     string   `protobuf:"bytes,10,opt,name=momentFilterInfo,proto3" json:"momentFilterInfo,omitempty"`
	BotId                string   `protobuf:"bytes,11,opt,name=botId,proto3" json:"botId,omitempty"`
	ScanUrl              string   `protobuf:"bytes,12,opt,name=scanUrl,proto3" json:"scanUrl,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BotsInfo) Descriptor 

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

func (*BotsInfo) GetBotId 

func (m *BotsInfo) GetBotId() string

func (*BotsInfo) GetClientId 

func (m *BotsInfo) GetClientId() string

func (*BotsInfo) GetClientType 

func (m *BotsInfo) GetClientType() string

func (*BotsInfo) GetFilterInfo 

func (m *BotsInfo) GetFilterInfo() string

func (*BotsInfo) GetLastPing 

func (m *BotsInfo) GetLastPing() int64

func (*BotsInfo) GetLogin 

func (m *BotsInfo) GetLogin() string

func (*BotsInfo) GetLoginInfo 

func (m *BotsInfo) GetLoginInfo() string

func (*BotsInfo) GetMomentFilterInfo 

func (m *BotsInfo) GetMomentFilterInfo() string

func (*BotsInfo) GetName 

func (m *BotsInfo) GetName() string

func (*BotsInfo) GetScanUrl 

func (m *BotsInfo) GetScanUrl() string

func (*BotsInfo) GetStartAt 

func (m *BotsInfo) GetStartAt() int64

func (*BotsInfo) GetStatus 

func (m *BotsInfo) GetStatus() int32

func (*BotsInfo) ProtoMessage 

func (*BotsInfo) ProtoMessage()

func (*BotsInfo) Reset 

func (m *BotsInfo) Reset()

func (*BotsInfo) String 

func (m *BotsInfo) String() string

func (*BotsInfo) XXX_DiscardUnknown 

func (m *BotsInfo) XXX_DiscardUnknown()

func (*BotsInfo) XXX_Marshal 

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

func (*BotsInfo) XXX_Merge 

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

func (*BotsInfo) XXX_Size 

func (m *BotsInfo) XXX_Size() int

func (*BotsInfo) XXX_Unmarshal 

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

type BotsReply 

type BotsReply struct {
	BotsInfo             []*BotsInfo `protobuf:"bytes,1,rep,name=botsInfo,proto3" json:"botsInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*BotsReply) Descriptor 

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

func (*BotsReply) GetBotsInfo 

func (m *BotsReply) GetBotsInfo() []*BotsInfo

func (*BotsReply) ProtoMessage 

func (*BotsReply) ProtoMessage()

func (*BotsReply) Reset 

func (m *BotsReply) Reset()

func (*BotsReply) String 

func (m *BotsReply) String() string

func (*BotsReply) XXX_DiscardUnknown 

func (m *BotsReply) XXX_DiscardUnknown()

func (*BotsReply) XXX_Marshal 

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

func (*BotsReply) XXX_Merge 

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

func (*BotsReply) XXX_Size 

func (m *BotsReply) XXX_Size() int

func (*BotsReply) XXX_Unmarshal 

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

type BotsRequest 

type BotsRequest struct {
	Logins               []string `protobuf:"bytes,1,rep,name=logins,proto3" json:"logins,omitempty"`
	BotIds               []string `protobuf:"bytes,2,rep,name=botIds,proto3" json:"botIds,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BotsRequest) Descriptor 

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

func (*BotsRequest) GetBotIds 

func (m *BotsRequest) GetBotIds() []string

func (*BotsRequest) GetLogins 

func (m *BotsRequest) GetLogins() []string

func (*BotsRequest) ProtoMessage 

func (*BotsRequest) ProtoMessage()

func (*BotsRequest) Reset 

func (m *BotsRequest) Reset()

func (*BotsRequest) String 

func (m *BotsRequest) String() string

func (*BotsRequest) XXX_DiscardUnknown 

func (m *BotsRequest) XXX_DiscardUnknown()

func (*BotsRequest) XXX_Marshal 

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

func (*BotsRequest) XXX_Merge 

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

func (*BotsRequest) XXX_Size 

func (m *BotsRequest) XXX_Size() int

func (*BotsRequest) XXX_Unmarshal 

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

type BranchTag 

type BranchTag struct {
	Key                  string   `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BranchTag) Descriptor 

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

func (*BranchTag) GetKey 

func (m *BranchTag) GetKey() string

func (*BranchTag) GetValue 

func (m *BranchTag) GetValue() string

func (*BranchTag) ProtoMessage 

func (*BranchTag) ProtoMessage()

func (*BranchTag) Reset 

func (m *BranchTag) Reset()

func (*BranchTag) String 

func (m *BranchTag) String() string

func (*BranchTag) XXX_DiscardUnknown 

func (m *BranchTag) XXX_DiscardUnknown()

func (*BranchTag) XXX_Marshal 

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

func (*BranchTag) XXX_Merge 

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

func (*BranchTag) XXX_Size 

func (m *BranchTag) XXX_Size() int

func (*BranchTag) XXX_Unmarshal 

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

type ChatBotHubClient 

type ChatBotHubClient interface {
	// bots only use eventtunnel to communicate
	EventTunnel(ctx context.Context, opts ...grpc.CallOption) (ChatBotHub_EventTunnelClient, error)
	// below are for internal web api
	GetBots(ctx context.Context, in *BotsRequest, opts ...grpc.CallOption) (*BotsReply, error)
	BotLogin(ctx context.Context, in *BotLoginRequest, opts ...grpc.CallOption) (*BotLoginReply, error)
	BotLogout(ctx context.Context, in *BotLogoutRequest, opts ...grpc.CallOption) (*OperationReply, error)
	BotShutdown(ctx context.Context, in *BotLogoutRequest, opts ...grpc.CallOption) (*OperationReply, error)
	BotAction(ctx context.Context, in *BotActionRequest, opts ...grpc.CallOption) (*BotActionReply, error)
	BotFilter(ctx context.Context, in *BotFilterRequest, opts ...grpc.CallOption) (*OperationReply, error)
	BotMomentFilter(ctx context.Context, in *BotFilterRequest, opts ...grpc.CallOption) (*OperationReply, error)
	FilterCreate(ctx context.Context, in *FilterCreateRequest, opts ...grpc.CallOption) (*OperationReply, error)
	FilterNext(ctx context.Context, in *FilterNextRequest, opts ...grpc.CallOption) (*OperationReply, error)
	RouterBranch(ctx context.Context, in *RouterBranchRequest, opts ...grpc.CallOption) (*OperationReply, error)
	FilterFill(ctx context.Context, in *FilterFillRequest, opts ...grpc.CallOption) (*FilterFillReply, error)
	WebShortCallResponse(ctx context.Context, in *EventReply, opts ...grpc.CallOption) (*OperationReply, error)
	// tunnel that connect streaming server and chathub server
	StreamingTunnel(ctx context.Context, opts ...grpc.CallOption) (ChatBotHub_StreamingTunnelClient, error)
	// streaming rpc
	StreamingCtrl(ctx context.Context, in *StreamingCtrlRequest, opts ...grpc.CallOption) (*OperationReply, error)
}

ChatBotHubClient is the client API for ChatBotHub service.

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

func NewChatBotHubClient 

func NewChatBotHubClient(cc *grpc.ClientConn) ChatBotHubClient

type ChatBotHubServer 

type ChatBotHubServer interface {
	// bots only use eventtunnel to communicate
	EventTunnel(ChatBotHub_EventTunnelServer) error
	// below are for internal web api
	GetBots(context.Context, *BotsRequest) (*BotsReply, error)
	BotLogin(context.Context, *BotLoginRequest) (*BotLoginReply, error)
	BotLogout(context.Context, *BotLogoutRequest) (*OperationReply, error)
	BotShutdown(context.Context, *BotLogoutRequest) (*OperationReply, error)
	BotAction(context.Context, *BotActionRequest) (*BotActionReply, error)
	BotFilter(context.Context, *BotFilterRequest) (*OperationReply, error)
	BotMomentFilter(context.Context, *BotFilterRequest) (*OperationReply, error)
	FilterCreate(context.Context, *FilterCreateRequest) (*OperationReply, error)
	FilterNext(context.Context, *FilterNextRequest) (*OperationReply, error)
	RouterBranch(context.Context, *RouterBranchRequest) (*OperationReply, error)
	FilterFill(context.Context, *FilterFillRequest) (*FilterFillReply, error)
	WebShortCallResponse(context.Context, *EventReply) (*OperationReply, error)
	// tunnel that connect streaming server and chathub server
	StreamingTunnel(ChatBotHub_StreamingTunnelServer) error
	// streaming rpc
	StreamingCtrl(context.Context, *StreamingCtrlRequest) (*OperationReply, error)
}

ChatBotHubServer is the server API for ChatBotHub service.

type ChatBotHub_EventTunnelClient 

type ChatBotHub_EventTunnelClient interface {
	Send(*EventRequest) error
	Recv() (*EventReply, error)
	grpc.ClientStream
}

type ChatBotHub_EventTunnelServer 

type ChatBotHub_EventTunnelServer interface {
	Send(*EventReply) error
	Recv() (*EventRequest, error)
	grpc.ServerStream
}

type ChatBotHub_StreamingTunnelClient 

type ChatBotHub_StreamingTunnelClient interface {
	Send(*EventRequest) error
	Recv() (*EventReply, error)
	grpc.ClientStream
}

type ChatBotHub_StreamingTunnelServer 

type ChatBotHub_StreamingTunnelServer interface {
	Send(*EventReply) error
	Recv() (*EventRequest, error)
	grpc.ServerStream
}

type EventReply 

type EventReply struct {
	EventType            string   `protobuf:"bytes,1,opt,name=eventType,proto3" json:"eventType,omitempty"`
	Body                 string   `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	BotClientId          string   `protobuf:"bytes,3,opt,name=botClientId,proto3" json:"botClientId,omitempty"`
	BotClientType        string   `protobuf:"bytes,4,opt,name=botClientType,proto3" json:"botClientType,omitempty"`
	BotId                string   `protobuf:"bytes,5,opt,name=botId,proto3" json:"botId,omitempty"`
	ClientId             string   `protobuf:"bytes,6,opt,name=clientId,proto3" json:"clientId,omitempty"`
	ClientType           string   `protobuf:"bytes,7,opt,name=clientType,proto3" json:"clientType,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EventReply) Descriptor 

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

func (*EventReply) GetBody 

func (m *EventReply) GetBody() string

func (*EventReply) GetBotClientId 

func (m *EventReply) GetBotClientId() string

func (*EventReply) GetBotClientType 

func (m *EventReply) GetBotClientType() string

func (*EventReply) GetBotId 

func (m *EventReply) GetBotId() string

func (*EventReply) GetClientId 

func (m *EventReply) GetClientId() string

func (*EventReply) GetClientType 

func (m *EventReply) GetClientType() string

func (*EventReply) GetEventType 

func (m *EventReply) GetEventType() string

func (*EventReply) ProtoMessage 

func (*EventReply) ProtoMessage()

func (*EventReply) Reset 

func (m *EventReply) Reset()

func (*EventReply) String 

func (m *EventReply) String() string

func (*EventReply) XXX_DiscardUnknown 

func (m *EventReply) XXX_DiscardUnknown()

func (*EventReply) XXX_Marshal 

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

func (*EventReply) XXX_Merge 

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

func (*EventReply) XXX_Size 

func (m *EventReply) XXX_Size() int

func (*EventReply) XXX_Unmarshal 

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

type EventRequest 

type EventRequest struct {
	EventType            string   `protobuf:"bytes,1,opt,name=eventType,proto3" json:"eventType,omitempty"`
	Body                 string   `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"`
	ClientId             string   `protobuf:"bytes,3,opt,name=clientId,proto3" json:"clientId,omitempty"`
	ClientType           string   `protobuf:"bytes,4,opt,name=clientType,proto3" json:"clientType,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EventRequest) Descriptor 

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

func (*EventRequest) GetBody 

func (m *EventRequest) GetBody() string

func (*EventRequest) GetClientId 

func (m *EventRequest) GetClientId() string

func (*EventRequest) GetClientType 

func (m *EventRequest) GetClientType() string

func (*EventRequest) GetEventType 

func (m *EventRequest) GetEventType() string

func (*EventRequest) ProtoMessage 

func (*EventRequest) ProtoMessage()

func (*EventRequest) Reset 

func (m *EventRequest) Reset()

func (*EventRequest) String 

func (m *EventRequest) String() string

func (*EventRequest) XXX_DiscardUnknown 

func (m *EventRequest) XXX_DiscardUnknown()

func (*EventRequest) XXX_Marshal 

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

func (*EventRequest) XXX_Merge 

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

func (*EventRequest) XXX_Size 

func (m *EventRequest) XXX_Size() int

func (*EventRequest) XXX_Unmarshal 

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

type FilterCreateRequest 

type FilterCreateRequest struct {
	FilterId             string   `protobuf:"bytes,1,opt,name=filterId,proto3" json:"filterId,omitempty"`
	FilterType           string   `protobuf:"bytes,2,opt,name=filterType,proto3" json:"filterType,omitempty"`
	FilterName           string   `protobuf:"bytes,3,opt,name=filterName,proto3" json:"filterName,omitempty"`
	Body                 string   `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FilterCreateRequest) Descriptor 

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

func (*FilterCreateRequest) GetBody 

func (m *FilterCreateRequest) GetBody() string

func (*FilterCreateRequest) GetFilterId 

func (m *FilterCreateRequest) GetFilterId() string

func (*FilterCreateRequest) GetFilterName 

func (m *FilterCreateRequest) GetFilterName() string

func (*FilterCreateRequest) GetFilterType 

func (m *FilterCreateRequest) GetFilterType() string

func (*FilterCreateRequest) ProtoMessage 

func (*FilterCreateRequest) ProtoMessage()

func (*FilterCreateRequest) Reset 

func (m *FilterCreateRequest) Reset()

func (*FilterCreateRequest) String 

func (m *FilterCreateRequest) String() string

func (*FilterCreateRequest) XXX_DiscardUnknown 

func (m *FilterCreateRequest) XXX_DiscardUnknown()

func (*FilterCreateRequest) XXX_Marshal 

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

func (*FilterCreateRequest) XXX_Merge 

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

func (*FilterCreateRequest) XXX_Size 

func (m *FilterCreateRequest) XXX_Size() int

func (*FilterCreateRequest) XXX_Unmarshal 

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

type FilterFillReply 

type FilterFillReply struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FilterFillReply) Descriptor 

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

func (*FilterFillReply) GetSuccess 

func (m *FilterFillReply) GetSuccess() bool

func (*FilterFillReply) ProtoMessage 

func (*FilterFillReply) ProtoMessage()

func (*FilterFillReply) Reset 

func (m *FilterFillReply) Reset()

func (*FilterFillReply) String 

func (m *FilterFillReply) String() string

func (*FilterFillReply) XXX_DiscardUnknown 

func (m *FilterFillReply) XXX_DiscardUnknown()

func (*FilterFillReply) XXX_Marshal 

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

func (*FilterFillReply) XXX_Merge 

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

func (*FilterFillReply) XXX_Size 

func (m *FilterFillReply) XXX_Size() int

func (*FilterFillReply) XXX_Unmarshal 

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

type FilterFillRequest 

type FilterFillRequest struct {
	BotId                string   `protobuf:"bytes,1,opt,name=botId,proto3" json:"botId,omitempty"`
	Source               string   `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	Body                 string   `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FilterFillRequest) Descriptor 

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

func (*FilterFillRequest) GetBody 

func (m *FilterFillRequest) GetBody() string

func (*FilterFillRequest) GetBotId 

func (m *FilterFillRequest) GetBotId() string

func (*FilterFillRequest) GetSource 

func (m *FilterFillRequest) GetSource() string

func (*FilterFillRequest) ProtoMessage 

func (*FilterFillRequest) ProtoMessage()

func (*FilterFillRequest) Reset 

func (m *FilterFillRequest) Reset()

func (*FilterFillRequest) String 

func (m *FilterFillRequest) String() string

func (*FilterFillRequest) XXX_DiscardUnknown 

func (m *FilterFillRequest) XXX_DiscardUnknown()

func (*FilterFillRequest) XXX_Marshal 

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

func (*FilterFillRequest) XXX_Merge 

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

func (*FilterFillRequest) XXX_Size 

func (m *FilterFillRequest) XXX_Size() int

func (*FilterFillRequest) XXX_Unmarshal 

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

type FilterNextRequest 

type FilterNextRequest struct {
	FilterId             string   `protobuf:"bytes,1,opt,name=filterId,proto3" json:"filterId,omitempty"`
	NextFilterId         string   `protobuf:"bytes,2,opt,name=nextFilterId,proto3" json:"nextFilterId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FilterNextRequest) Descriptor 

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

func (*FilterNextRequest) GetFilterId 

func (m *FilterNextRequest) GetFilterId() string

func (*FilterNextRequest) GetNextFilterId 

func (m *FilterNextRequest) GetNextFilterId() string

func (*FilterNextRequest) ProtoMessage 

func (*FilterNextRequest) ProtoMessage()

func (*FilterNextRequest) Reset 

func (m *FilterNextRequest) Reset()

func (*FilterNextRequest) String 

func (m *FilterNextRequest) String() string

func (*FilterNextRequest) XXX_DiscardUnknown 

func (m *FilterNextRequest) XXX_DiscardUnknown()

func (*FilterNextRequest) XXX_Marshal 

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

func (*FilterNextRequest) XXX_Merge 

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

func (*FilterNextRequest) XXX_Size 

func (m *FilterNextRequest) XXX_Size() int

func (*FilterNextRequest) XXX_Unmarshal 

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

type OperationReply 

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

func (*OperationReply) Descriptor 

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

func (*OperationReply) GetCode 

func (m *OperationReply) GetCode() int32

func (*OperationReply) GetMessage 

func (m *OperationReply) GetMessage() string

func (*OperationReply) ProtoMessage 

func (*OperationReply) ProtoMessage()

func (*OperationReply) Reset 

func (m *OperationReply) Reset()

func (*OperationReply) String 

func (m *OperationReply) String() string

func (*OperationReply) XXX_DiscardUnknown 

func (m *OperationReply) XXX_DiscardUnknown()

func (*OperationReply) XXX_Marshal 

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

func (*OperationReply) XXX_Merge 

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

func (*OperationReply) XXX_Size 

func (m *OperationReply) XXX_Size() int

func (*OperationReply) XXX_Unmarshal 

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

type RouterBranchRequest 

type RouterBranchRequest struct {
	Tag                  *BranchTag `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
	RouterId             string     `protobuf:"bytes,2,opt,name=routerId,proto3" json:"routerId,omitempty"`
	FilterId             string     `protobuf:"bytes,3,opt,name=filterId,proto3" json:"filterId,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*RouterBranchRequest) Descriptor 

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

func (*RouterBranchRequest) GetFilterId 

func (m *RouterBranchRequest) GetFilterId() string

func (*RouterBranchRequest) GetRouterId 

func (m *RouterBranchRequest) GetRouterId() string

func (*RouterBranchRequest) GetTag 

func (m *RouterBranchRequest) GetTag() *BranchTag

func (*RouterBranchRequest) ProtoMessage 

func (*RouterBranchRequest) ProtoMessage()

func (*RouterBranchRequest) Reset 

func (m *RouterBranchRequest) Reset()

func (*RouterBranchRequest) String 

func (m *RouterBranchRequest) String() string

func (*RouterBranchRequest) XXX_DiscardUnknown 

func (m *RouterBranchRequest) XXX_DiscardUnknown()

func (*RouterBranchRequest) XXX_Marshal 

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

func (*RouterBranchRequest) XXX_Merge 

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

func (*RouterBranchRequest) XXX_Size 

func (m *RouterBranchRequest) XXX_Size() int

func (*RouterBranchRequest) XXX_Unmarshal 

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

type StreamingCtrlRequest 

type StreamingCtrlRequest struct {
	ClientId             string               `protobuf:"bytes,1,opt,name=clientId,proto3" json:"clientId,omitempty"`
	ClientType           string               `protobuf:"bytes,2,opt,name=clientType,proto3" json:"clientType,omitempty"`
	Resources            []*StreamingResource `protobuf:"bytes,3,rep,name=resources,proto3" json:"resources,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*StreamingCtrlRequest) Descriptor 

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

func (*StreamingCtrlRequest) GetClientId 

func (m *StreamingCtrlRequest) GetClientId() string

func (*StreamingCtrlRequest) GetClientType 

func (m *StreamingCtrlRequest) GetClientType() string

func (*StreamingCtrlRequest) GetResources 

func (m *StreamingCtrlRequest) GetResources() []*StreamingResource

func (*StreamingCtrlRequest) ProtoMessage 

func (*StreamingCtrlRequest) ProtoMessage()

func (*StreamingCtrlRequest) Reset 

func (m *StreamingCtrlRequest) Reset()

func (*StreamingCtrlRequest) String 

func (m *StreamingCtrlRequest) String() string

func (*StreamingCtrlRequest) XXX_DiscardUnknown 

func (m *StreamingCtrlRequest) XXX_DiscardUnknown()

func (*StreamingCtrlRequest) XXX_Marshal 

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

func (*StreamingCtrlRequest) XXX_Merge 

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

func (*StreamingCtrlRequest) XXX_Size 

func (m *StreamingCtrlRequest) XXX_Size() int

func (*StreamingCtrlRequest) XXX_Unmarshal 

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

type StreamingResource 

type StreamingResource struct {
	BotId                string   `protobuf:"bytes,1,opt,name=botId,proto3" json:"botId,omitempty"`
	ResourceType         int32    `protobuf:"varint,2,opt,name=resourceType,proto3" json:"resourceType,omitempty"`
	ActionType           int32    `protobuf:"varint,3,opt,name=actionType,proto3" json:"actionType,omitempty"`
	Chatusers            []string `protobuf:"bytes,4,rep,name=chatusers,proto3" json:"chatusers,omitempty"`
	Chatgroups           []string `protobuf:"bytes,5,rep,name=chatgroups,proto3" json:"chatgroups,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamingResource) Descriptor 

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

func (*StreamingResource) GetActionType 

func (m *StreamingResource) GetActionType() int32

func (*StreamingResource) GetBotId 

func (m *StreamingResource) GetBotId() string

func (*StreamingResource) GetChatgroups 

func (m *StreamingResource) GetChatgroups() []string

func (*StreamingResource) GetChatusers 

func (m *StreamingResource) GetChatusers() []string

func (*StreamingResource) GetResourceType 

func (m *StreamingResource) GetResourceType() int32

func (*StreamingResource) ProtoMessage 

func (*StreamingResource) ProtoMessage()

func (*StreamingResource) Reset 

func (m *StreamingResource) Reset()

func (*StreamingResource) String 

func (m *StreamingResource) String() string

func (*StreamingResource) XXX_DiscardUnknown 

func (m *StreamingResource) XXX_DiscardUnknown()

func (*StreamingResource) XXX_Marshal 

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

func (*StreamingResource) XXX_Merge 

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

func (*StreamingResource) XXX_Size 

func (m *StreamingResource) XXX_Size() int

func (*StreamingResource) XXX_Unmarshal 

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

type UnimplementedChatBotHubServer 

type UnimplementedChatBotHubServer struct {
}

UnimplementedChatBotHubServer can be embedded to have forward compatible implementations.

func (*UnimplementedChatBotHubServer) BotAction 

func (*UnimplementedChatBotHubServer) BotAction(ctx context.Context, req *BotActionRequest) (*BotActionReply, error)

func (*UnimplementedChatBotHubServer) BotFilter 

func (*UnimplementedChatBotHubServer) BotFilter(ctx context.Context, req *BotFilterRequest) (*OperationReply, error)

func (*UnimplementedChatBotHubServer) BotLogin 

func (*UnimplementedChatBotHubServer) BotLogin(ctx context.Context, req *BotLoginRequest) (*BotLoginReply, error)

func (*UnimplementedChatBotHubServer) BotLogout 

func (*UnimplementedChatBotHubServer) BotLogout(ctx context.Context, req *BotLogoutRequest) (*OperationReply, error)

func (*UnimplementedChatBotHubServer) BotMomentFilter 

func (*UnimplementedChatBotHubServer) BotMomentFilter(ctx context.Context, req *BotFilterRequest) (*OperationReply, error)

func (*UnimplementedChatBotHubServer) BotShutdown 

func (*UnimplementedChatBotHubServer) BotShutdown(ctx context.Context, req *BotLogoutRequest) (*OperationReply, error)

func (*UnimplementedChatBotHubServer) EventTunnel 

func (*UnimplementedChatBotHubServer) EventTunnel(srv ChatBotHub_EventTunnelServer) error

func (*UnimplementedChatBotHubServer) FilterCreate 

func (*UnimplementedChatBotHubServer) FilterCreate(ctx context.Context, req *FilterCreateRequest) (*OperationReply, error)

func (*UnimplementedChatBotHubServer) FilterFill 

func (*UnimplementedChatBotHubServer) FilterFill(ctx context.Context, req *FilterFillRequest) (*FilterFillReply, error)

func (*UnimplementedChatBotHubServer) FilterNext 

func (*UnimplementedChatBotHubServer) FilterNext(ctx context.Context, req *FilterNextRequest) (*OperationReply, error)

func (*UnimplementedChatBotHubServer) GetBots 

func (*UnimplementedChatBotHubServer) GetBots(ctx context.Context, req *BotsRequest) (*BotsReply, error)

func (*UnimplementedChatBotHubServer) RouterBranch 

func (*UnimplementedChatBotHubServer) RouterBranch(ctx context.Context, req *RouterBranchRequest) (*OperationReply, error)

func (*UnimplementedChatBotHubServer) StreamingCtrl 

func (*UnimplementedChatBotHubServer) StreamingCtrl(ctx context.Context, req *StreamingCtrlRequest) (*OperationReply, error)

func (*UnimplementedChatBotHubServer) StreamingTunnel 

func (*UnimplementedChatBotHubServer) StreamingTunnel(srv ChatBotHub_StreamingTunnelServer) error

func (*UnimplementedChatBotHubServer) WebShortCallResponse 

func (*UnimplementedChatBotHubServer) WebShortCallResponse(ctx context.Context, req *EventReply) (*OperationReply, 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.