// Code generated by protoc-gen-go. DO NOT EDIT.
// source: logic.int.proto

package pb

import (
	context "context"
	fmt "fmt"
	proto "github.com/golang/protobuf/proto"
	grpc "google.golang.org/grpc"
	codes "google.golang.org/grpc/codes"
	status "google.golang.org/grpc/status"
	math "math"
)

// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf

// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package

type SignInReq struct {
	AppId                int64    `protobuf:"varint,1,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	DeviceId             int64    `protobuf:"varint,2,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	UserId               int64    `protobuf:"varint,3,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Token                string   `protobuf:"bytes,4,opt,name=token,proto3" json:"token,omitempty"`
	ConnAddr             string   `protobuf:"bytes,5,opt,name=conn_addr,json=connAddr,proto3" json:"conn_addr,omitempty"`
	ConnFd               int64    `protobuf:"varint,6,opt,name=conn_fd,json=connFd,proto3" json:"conn_fd,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *SignInReq) Reset()         { *m = SignInReq{} }
func (m *SignInReq) String() string { return proto.CompactTextString(m) }
func (*SignInReq) ProtoMessage()    {}
func (*SignInReq) Descriptor() ([]byte, []int) {
	return fileDescriptor_aa14331f3fd0015e, []int{0}
}

func (m *SignInReq) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_SignInReq.Unmarshal(m, b)
}
func (m *SignInReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_SignInReq.Marshal(b, m, deterministic)
}
func (m *SignInReq) XXX_Merge(src proto.Message) {
	xxx_messageInfo_SignInReq.Merge(m, src)
}
func (m *SignInReq) XXX_Size() int {
	return xxx_messageInfo_SignInReq.Size(m)
}
func (m *SignInReq) XXX_DiscardUnknown() {
	xxx_messageInfo_SignInReq.DiscardUnknown(m)
}

var xxx_messageInfo_SignInReq proto.InternalMessageInfo

func (m *SignInReq) GetAppId() int64 {
	if m != nil {
		return m.AppId
	}
	return 0
}

func (m *SignInReq) GetDeviceId() int64 {
	if m != nil {
		return m.DeviceId
	}
	return 0
}

func (m *SignInReq) GetUserId() int64 {
	if m != nil {
		return m.UserId
	}
	return 0
}

func (m *SignInReq) GetToken() string {
	if m != nil {
		return m.Token
	}
	return ""
}

func (m *SignInReq) GetConnAddr() string {
	if m != nil {
		return m.ConnAddr
	}
	return ""
}

func (m *SignInReq) GetConnFd() int64 {
	if m != nil {
		return m.ConnFd
	}
	return 0
}

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

func (m *SignInResp) Reset()         { *m = SignInResp{} }
func (m *SignInResp) String() string { return proto.CompactTextString(m) }
func (*SignInResp) ProtoMessage()    {}
func (*SignInResp) Descriptor() ([]byte, []int) {
	return fileDescriptor_aa14331f3fd0015e, []int{1}
}

func (m *SignInResp) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_SignInResp.Unmarshal(m, b)
}
func (m *SignInResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_SignInResp.Marshal(b, m, deterministic)
}
func (m *SignInResp) XXX_Merge(src proto.Message) {
	xxx_messageInfo_SignInResp.Merge(m, src)
}
func (m *SignInResp) XXX_Size() int {
	return xxx_messageInfo_SignInResp.Size(m)
}
func (m *SignInResp) XXX_DiscardUnknown() {
	xxx_messageInfo_SignInResp.DiscardUnknown(m)
}

var xxx_messageInfo_SignInResp proto.InternalMessageInfo

type SyncReq struct {
	AppId                int64    `protobuf:"varint,2,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	UserId               int64    `protobuf:"varint,3,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	DeviceId             int64    `protobuf:"varint,4,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	Seq                  int64    `protobuf:"varint,5,opt,name=seq,proto3" json:"seq,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *SyncReq) Reset()         { *m = SyncReq{} }
func (m *SyncReq) String() string { return proto.CompactTextString(m) }
func (*SyncReq) ProtoMessage()    {}
func (*SyncReq) Descriptor() ([]byte, []int) {
	return fileDescriptor_aa14331f3fd0015e, []int{2}
}

func (m *SyncReq) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_SyncReq.Unmarshal(m, b)
}
func (m *SyncReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_SyncReq.Marshal(b, m, deterministic)
}
func (m *SyncReq) XXX_Merge(src proto.Message) {
	xxx_messageInfo_SyncReq.Merge(m, src)
}
func (m *SyncReq) XXX_Size() int {
	return xxx_messageInfo_SyncReq.Size(m)
}
func (m *SyncReq) XXX_DiscardUnknown() {
	xxx_messageInfo_SyncReq.DiscardUnknown(m)
}

var xxx_messageInfo_SyncReq proto.InternalMessageInfo

func (m *SyncReq) GetAppId() int64 {
	if m != nil {
		return m.AppId
	}
	return 0
}

func (m *SyncReq) GetUserId() int64 {
	if m != nil {
		return m.UserId
	}
	return 0
}

func (m *SyncReq) GetDeviceId() int64 {
	if m != nil {
		return m.DeviceId
	}
	return 0
}

func (m *SyncReq) GetSeq() int64 {
	if m != nil {
		return m.Seq
	}
	return 0
}

type SyncResp struct {
	Messages             []*MessageItem `protobuf:"bytes,3,rep,name=messages,proto3" json:"messages,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (m *SyncResp) Reset()         { *m = SyncResp{} }
func (m *SyncResp) String() string { return proto.CompactTextString(m) }
func (*SyncResp) ProtoMessage()    {}
func (*SyncResp) Descriptor() ([]byte, []int) {
	return fileDescriptor_aa14331f3fd0015e, []int{3}
}

func (m *SyncResp) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_SyncResp.Unmarshal(m, b)
}
func (m *SyncResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_SyncResp.Marshal(b, m, deterministic)
}
func (m *SyncResp) XXX_Merge(src proto.Message) {
	xxx_messageInfo_SyncResp.Merge(m, src)
}
func (m *SyncResp) XXX_Size() int {
	return xxx_messageInfo_SyncResp.Size(m)
}
func (m *SyncResp) XXX_DiscardUnknown() {
	xxx_messageInfo_SyncResp.DiscardUnknown(m)
}

var xxx_messageInfo_SyncResp proto.InternalMessageInfo

func (m *SyncResp) GetMessages() []*MessageItem {
	if m != nil {
		return m.Messages
	}
	return nil
}

type MessageACKReq struct {
	AppId                int64    `protobuf:"varint,1,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	UserId               int64    `protobuf:"varint,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	DeviceId             int64    `protobuf:"varint,3,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	MessageId            string   `protobuf:"bytes,4,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	DeviceAck            int64    `protobuf:"varint,5,opt,name=device_ack,json=deviceAck,proto3" json:"device_ack,omitempty"`
	ReceiveTime          int64    `protobuf:"varint,6,opt,name=receive_time,json=receiveTime,proto3" json:"receive_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *MessageACKReq) Reset()         { *m = MessageACKReq{} }
func (m *MessageACKReq) String() string { return proto.CompactTextString(m) }
func (*MessageACKReq) ProtoMessage()    {}
func (*MessageACKReq) Descriptor() ([]byte, []int) {
	return fileDescriptor_aa14331f3fd0015e, []int{4}
}

func (m *MessageACKReq) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_MessageACKReq.Unmarshal(m, b)
}
func (m *MessageACKReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_MessageACKReq.Marshal(b, m, deterministic)
}
func (m *MessageACKReq) XXX_Merge(src proto.Message) {
	xxx_messageInfo_MessageACKReq.Merge(m, src)
}
func (m *MessageACKReq) XXX_Size() int {
	return xxx_messageInfo_MessageACKReq.Size(m)
}
func (m *MessageACKReq) XXX_DiscardUnknown() {
	xxx_messageInfo_MessageACKReq.DiscardUnknown(m)
}

var xxx_messageInfo_MessageACKReq proto.InternalMessageInfo

func (m *MessageACKReq) GetAppId() int64 {
	if m != nil {
		return m.AppId
	}
	return 0
}

func (m *MessageACKReq) GetUserId() int64 {
	if m != nil {
		return m.UserId
	}
	return 0
}

func (m *MessageACKReq) GetDeviceId() int64 {
	if m != nil {
		return m.DeviceId
	}
	return 0
}

func (m *MessageACKReq) GetMessageId() string {
	if m != nil {
		return m.MessageId
	}
	return ""
}

func (m *MessageACKReq) GetDeviceAck() int64 {
	if m != nil {
		return m.DeviceAck
	}
	return 0
}

func (m *MessageACKReq) GetReceiveTime() int64 {
	if m != nil {
		return m.ReceiveTime
	}
	return 0
}

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

func (m *MessageACKResp) Reset()         { *m = MessageACKResp{} }
func (m *MessageACKResp) String() string { return proto.CompactTextString(m) }
func (*MessageACKResp) ProtoMessage()    {}
func (*MessageACKResp) Descriptor() ([]byte, []int) {
	return fileDescriptor_aa14331f3fd0015e, []int{5}
}

func (m *MessageACKResp) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_MessageACKResp.Unmarshal(m, b)
}
func (m *MessageACKResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_MessageACKResp.Marshal(b, m, deterministic)
}
func (m *MessageACKResp) XXX_Merge(src proto.Message) {
	xxx_messageInfo_MessageACKResp.Merge(m, src)
}
func (m *MessageACKResp) XXX_Size() int {
	return xxx_messageInfo_MessageACKResp.Size(m)
}
func (m *MessageACKResp) XXX_DiscardUnknown() {
	xxx_messageInfo_MessageACKResp.DiscardUnknown(m)
}

var xxx_messageInfo_MessageACKResp proto.InternalMessageInfo

type OfflineReq struct {
	AppId                int64    `protobuf:"varint,2,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	UserId               int64    `protobuf:"varint,3,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	DeviceId             int64    `protobuf:"varint,4,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (m *OfflineReq) Reset()         { *m = OfflineReq{} }
func (m *OfflineReq) String() string { return proto.CompactTextString(m) }
func (*OfflineReq) ProtoMessage()    {}
func (*OfflineReq) Descriptor() ([]byte, []int) {
	return fileDescriptor_aa14331f3fd0015e, []int{6}
}

func (m *OfflineReq) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_OfflineReq.Unmarshal(m, b)
}
func (m *OfflineReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_OfflineReq.Marshal(b, m, deterministic)
}
func (m *OfflineReq) XXX_Merge(src proto.Message) {
	xxx_messageInfo_OfflineReq.Merge(m, src)
}
func (m *OfflineReq) XXX_Size() int {
	return xxx_messageInfo_OfflineReq.Size(m)
}
func (m *OfflineReq) XXX_DiscardUnknown() {
	xxx_messageInfo_OfflineReq.DiscardUnknown(m)
}

var xxx_messageInfo_OfflineReq proto.InternalMessageInfo

func (m *OfflineReq) GetAppId() int64 {
	if m != nil {
		return m.AppId
	}
	return 0
}

func (m *OfflineReq) GetUserId() int64 {
	if m != nil {
		return m.UserId
	}
	return 0
}

func (m *OfflineReq) GetDeviceId() int64 {
	if m != nil {
		return m.DeviceId
	}
	return 0
}

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

func (m *OfflineResp) Reset()         { *m = OfflineResp{} }
func (m *OfflineResp) String() string { return proto.CompactTextString(m) }
func (*OfflineResp) ProtoMessage()    {}
func (*OfflineResp) Descriptor() ([]byte, []int) {
	return fileDescriptor_aa14331f3fd0015e, []int{7}
}

func (m *OfflineResp) XXX_Unmarshal(b []byte) error {
	return xxx_messageInfo_OfflineResp.Unmarshal(m, b)
}
func (m *OfflineResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
	return xxx_messageInfo_OfflineResp.Marshal(b, m, deterministic)
}
func (m *OfflineResp) XXX_Merge(src proto.Message) {
	xxx_messageInfo_OfflineResp.Merge(m, src)
}
func (m *OfflineResp) XXX_Size() int {
	return xxx_messageInfo_OfflineResp.Size(m)
}
func (m *OfflineResp) XXX_DiscardUnknown() {
	xxx_messageInfo_OfflineResp.DiscardUnknown(m)
}

var xxx_messageInfo_OfflineResp proto.InternalMessageInfo

func init() {
	proto.RegisterType((*SignInReq)(nil), "pb.SignInReq")
	proto.RegisterType((*SignInResp)(nil), "pb.SignInResp")
	proto.RegisterType((*SyncReq)(nil), "pb.SyncReq")
	proto.RegisterType((*SyncResp)(nil), "pb.SyncResp")
	proto.RegisterType((*MessageACKReq)(nil), "pb.MessageACKReq")
	proto.RegisterType((*MessageACKResp)(nil), "pb.MessageACKResp")
	proto.RegisterType((*OfflineReq)(nil), "pb.OfflineReq")
	proto.RegisterType((*OfflineResp)(nil), "pb.OfflineResp")
}

func init() { proto.RegisterFile("logic.int.proto", fileDescriptor_aa14331f3fd0015e) }

var fileDescriptor_aa14331f3fd0015e = []byte{
	// 428 bytes of a gzipped FileDescriptorProto
	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x53, 0x4d, 0x8b, 0xd3, 0x50,
	0x14, 0x25, 0x4d, 0x9b, 0x26, 0xb7, 0xed, 0x74, 0xbc, 0x28, 0x86, 0x88, 0xd0, 0xc9, 0xc6, 0xa2,
	0xd0, 0xc5, 0xcc, 0xc2, 0x75, 0x11, 0x84, 0xa0, 0x22, 0x64, 0xdc, 0xb8, 0x2a, 0x69, 0xde, 0x6b,
	0x7d, 0x74, 0xf2, 0x72, 0x27, 0x2f, 0x0e, 0xf8, 0x7f, 0xfc, 0x0f, 0xae, 0xfc, 0x6f, 0xf2, 0x3e,
	0xa6, 0x4d, 0x0b, 0x75, 0x35, 0xbb, 0x9c, 0x73, 0x92, 0x7b, 0xcf, 0x3d, 0xf7, 0x06, 0xa6, 0x77,
	0xf5, 0x56, 0x94, 0x0b, 0x21, 0xdb, 0x05, 0x35, 0x75, 0x5b, 0x63, 0x8f, 0xd6, 0x49, 0xd4, 0x96,
	0x64, 0x61, 0xfa, 0xdb, 0x83, 0xe8, 0x56, 0x6c, 0x65, 0x26, 0x73, 0x7e, 0x8f, 0x2f, 0x20, 0x28,
	0x88, 0x56, 0x82, 0xc5, 0xde, 0xcc, 0x9b, 0xfb, 0xf9, 0xa0, 0x20, 0xca, 0x18, 0xbe, 0x82, 0x88,
	0xf1, 0x07, 0x51, 0x72, 0xad, 0xf4, 0x8c, 0x12, 0x5a, 0x22, 0x63, 0xf8, 0x12, 0x86, 0x3f, 0x15,
	0x6f, 0xb4, 0xe4, 0x1b, 0x29, 0xd0, 0x30, 0x63, 0xf8, 0x1c, 0x06, 0x6d, 0xbd, 0xe3, 0x32, 0xee,
	0xcf, 0xbc, 0x79, 0x94, 0x5b, 0xa0, 0x6b, 0x95, 0xb5, 0x94, 0xab, 0x82, 0xb1, 0x26, 0x1e, 0x18,
	0x25, 0xd4, 0xc4, 0x92, 0xb1, 0x46, 0xd7, 0x32, 0xe2, 0x86, 0xc5, 0x81, 0xad, 0xa5, 0xe1, 0x47,
	0x96, 0x8e, 0x01, 0x1e, 0x5d, 0x2a, 0x4a, 0x7f, 0xc0, 0xf0, 0xf6, 0x97, 0x2c, 0x8f, 0x1d, 0xf7,
	0xba, 0x8e, 0xcf, 0x9a, 0x3a, 0x1a, 0xa5, 0x7f, 0x32, 0xca, 0x25, 0xf8, 0x8a, 0xdf, 0x1b, 0x57,
	0x7e, 0xae, 0x1f, 0xd3, 0xf7, 0x10, 0xda, 0x4e, 0x8a, 0xf0, 0x1d, 0x84, 0x15, 0x57, 0xaa, 0xd8,
	0x72, 0x15, 0xfb, 0x33, 0x7f, 0x3e, 0xba, 0x9e, 0x2e, 0x68, 0xbd, 0xf8, 0x62, 0xb9, 0xac, 0xe5,
	0x55, 0xbe, 0x7f, 0x21, 0xfd, 0xeb, 0xc1, 0xc4, 0x29, 0xcb, 0x0f, 0x9f, 0xfe, 0x93, 0x6d, 0xc7,
	0x69, 0xef, 0xbc, 0x53, 0xff, 0xc4, 0xe9, 0x6b, 0x00, 0xd7, 0xea, 0x71, 0x8e, 0x28, 0x8f, 0x1c,
	0x63, 0x65, 0xf7, 0x6d, 0x51, 0xee, 0xdc, 0x3c, 0xae, 0xda, 0xb2, 0xdc, 0xe1, 0x15, 0x8c, 0x1b,
	0x5e, 0x72, 0xf1, 0xc0, 0x57, 0xad, 0xa8, 0xb8, 0xcb, 0x7a, 0xe4, 0xb8, 0x6f, 0xa2, 0xe2, 0xe9,
	0x25, 0x5c, 0x74, 0xed, 0x2b, 0x4a, 0xbf, 0x03, 0x7c, 0xdd, 0x6c, 0xee, 0x84, 0xe4, 0x4f, 0x9d,
	0x7b, 0x3a, 0x81, 0xd1, 0xbe, 0xb4, 0xa2, 0xeb, 0x3f, 0x1e, 0x84, 0x9f, 0xf5, 0xd9, 0x66, 0xb2,
	0xc5, 0x37, 0x10, 0xd8, 0xcd, 0xe3, 0x44, 0xa7, 0xbd, 0xbf, 0xd5, 0xe4, 0xa2, 0x0b, 0x15, 0xe1,
	0x15, 0xf4, 0xf5, 0xaa, 0x70, 0x64, 0x78, 0x7b, 0x1e, 0xc9, 0xf8, 0x00, 0x14, 0xe1, 0x0d, 0xc0,
	0x61, 0x28, 0x7c, 0xd6, 0xd9, 0x9e, 0xdd, 0x51, 0x82, 0xa7, 0x94, 0x22, 0x7c, 0x0b, 0x43, 0x67,
	0x0e, 0x4d, 0xcb, 0x43, 0x08, 0xc9, 0xf4, 0x08, 0x2b, 0x5a, 0x07, 0xe6, 0xa7, 0xba, 0xf9, 0x17,
	0x00, 0x00, 0xff, 0xff, 0xa7, 0x0f, 0x34, 0xe4, 0x76, 0x03, 0x00, 0x00,
}

// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConnInterface

// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion6

// LogicIntClient is the client API for LogicInt service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type LogicIntClient interface {
	//  登录
	SignIn(ctx context.Context, in *SignInReq, opts ...grpc.CallOption) (*SignInResp, error)
	//  消息同步
	Sync(ctx context.Context, in *SyncReq, opts ...grpc.CallOption) (*SyncResp, error)
	//  设备收到消息回执
	MessageACK(ctx context.Context, in *MessageACKReq, opts ...grpc.CallOption) (*MessageACKResp, error)
	//  设备离线
	Offline(ctx context.Context, in *OfflineReq, opts ...grpc.CallOption) (*OfflineResp, error)
}

type logicIntClient struct {
	cc grpc.ClientConnInterface
}

func NewLogicIntClient(cc grpc.ClientConnInterface) LogicIntClient {
	return &logicIntClient{cc}
}

func (c *logicIntClient) SignIn(ctx context.Context, in *SignInReq, opts ...grpc.CallOption) (*SignInResp, error) {
	out := new(SignInResp)
	err := c.cc.Invoke(ctx, "/pb.LogicInt/SignIn", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *logicIntClient) Sync(ctx context.Context, in *SyncReq, opts ...grpc.CallOption) (*SyncResp, error) {
	out := new(SyncResp)
	err := c.cc.Invoke(ctx, "/pb.LogicInt/Sync", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *logicIntClient) MessageACK(ctx context.Context, in *MessageACKReq, opts ...grpc.CallOption) (*MessageACKResp, error) {
	out := new(MessageACKResp)
	err := c.cc.Invoke(ctx, "/pb.LogicInt/MessageACK", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *logicIntClient) Offline(ctx context.Context, in *OfflineReq, opts ...grpc.CallOption) (*OfflineResp, error) {
	out := new(OfflineResp)
	err := c.cc.Invoke(ctx, "/pb.LogicInt/Offline", in, out, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// LogicIntServer is the server API for LogicInt service.
type LogicIntServer interface {
	//  登录
	SignIn(context.Context, *SignInReq) (*SignInResp, error)
	//  消息同步
	Sync(context.Context, *SyncReq) (*SyncResp, error)
	//  设备收到消息回执
	MessageACK(context.Context, *MessageACKReq) (*MessageACKResp, error)
	//  设备离线
	Offline(context.Context, *OfflineReq) (*OfflineResp, error)
}

// UnimplementedLogicIntServer can be embedded to have forward compatible implementations.
type UnimplementedLogicIntServer struct {
}

func (*UnimplementedLogicIntServer) SignIn(ctx context.Context, req *SignInReq) (*SignInResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method SignIn not implemented")
}
func (*UnimplementedLogicIntServer) Sync(ctx context.Context, req *SyncReq) (*SyncResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Sync not implemented")
}
func (*UnimplementedLogicIntServer) MessageACK(ctx context.Context, req *MessageACKReq) (*MessageACKResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method MessageACK not implemented")
}
func (*UnimplementedLogicIntServer) Offline(ctx context.Context, req *OfflineReq) (*OfflineResp, error) {
	return nil, status.Errorf(codes.Unimplemented, "method Offline not implemented")
}

func RegisterLogicIntServer(s *grpc.Server, srv LogicIntServer) {
	s.RegisterService(&_LogicInt_serviceDesc, srv)
}

func _LogicInt_SignIn_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SignInReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(LogicIntServer).SignIn(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pb.LogicInt/SignIn",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(LogicIntServer).SignIn(ctx, req.(*SignInReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _LogicInt_Sync_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(SyncReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(LogicIntServer).Sync(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pb.LogicInt/Sync",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(LogicIntServer).Sync(ctx, req.(*SyncReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _LogicInt_MessageACK_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(MessageACKReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(LogicIntServer).MessageACK(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pb.LogicInt/MessageACK",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(LogicIntServer).MessageACK(ctx, req.(*MessageACKReq))
	}
	return interceptor(ctx, in, info, handler)
}

func _LogicInt_Offline_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(OfflineReq)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(LogicIntServer).Offline(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/pb.LogicInt/Offline",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(LogicIntServer).Offline(ctx, req.(*OfflineReq))
	}
	return interceptor(ctx, in, info, handler)
}

var _LogicInt_serviceDesc = grpc.ServiceDesc{
	ServiceName: "pb.LogicInt",
	HandlerType: (*LogicIntServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SignIn",
			Handler:    _LogicInt_SignIn_Handler,
		},
		{
			MethodName: "Sync",
			Handler:    _LogicInt_Sync_Handler,
		},
		{
			MethodName: "MessageACK",
			Handler:    _LogicInt_MessageACK_Handler,
		},
		{
			MethodName: "Offline",
			Handler:    _LogicInt_Offline_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "logic.int.proto",
}
