ccssdk

type CcsSdk struct {
	CcsEndpoint      string
	RequestHandlers  RequestHandleFuncs
	ResponseHandlers ResponseHandleFuncs
	// contains filtered or unexported fields
}

type EchoRequest struct {
	Str string `protobuf:"bytes,1,opt,name=str,proto3" json:"str,omitempty"`
	// contains filtered or unexported fields
}

type EchoResponse struct {
	Str string `protobuf:"bytes,1,opt,name=str,proto3" json:"str,omitempty"`
	// contains filtered or unexported fields
}

type MessageQueueRepository interface {
	SubscribeRequest(topic string, funcs RequestHandleFuncs) error
	SubscribeResponse(topic string, funcs ResponseHandleFuncs) error
	Start() error
}

type MessageQueueService struct {
	Repo MessageQueueRepository
}

type MessageRequest struct {
	AppId            string     `protobuf:"bytes,1,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	ServiceId        string     `protobuf:"bytes,2,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	Token            string     `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	Timestamp        int64      `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // 最后一次被处理的时间戳
	Payload          string     `protobuf:"bytes,5,opt,name=payload,proto3" json:"payload,omitempty"`
	Referers         []*Referer `protobuf:"bytes,6,rep,name=referers,proto3" json:"referers,omitempty"`
	NeedRespReferers bool       `protobuf:"varint,7,opt,name=need_resp_referers,json=needRespReferers,proto3" json:"need_resp_referers,omitempty"`
	// contains filtered or unexported fields
}

type MessageResponse struct {
	AppId         string     `protobuf:"bytes,1,opt,name=app_id,json=appId,proto3" json:"app_id,omitempty"`
	ServiceId     string     `protobuf:"bytes,2,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	RespServiceId string     `protobuf:"bytes,3,opt,name=resp_service_id,json=respServiceId,proto3" json:"resp_service_id,omitempty"`
	Timestamp     int64      `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // 最后一次被处理的时间戳
	Payload       string     `protobuf:"bytes,5,opt,name=payload,proto3" json:"payload,omitempty"`
	Referers      []*Referer `protobuf:"bytes,6,rep,name=referers,proto3" json:"referers,omitempty"`
	Code          int32      `protobuf:"varint,7,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

type Referer struct {
	Timestamp int64  `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value     string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type RequestHandleFunc func(RequestMessageContext) error

type RequestHandleFuncs []RequestHandleFunc

type RequestMessageContext interface {
	GetAppId() string
	GetServiceId() string
	GetToken() string
	GetTimestamp() int64
	GetPayload() string
	GetReferers() []*interface{}
	GetNeedRespReferers() bool
}

type RequestMessageContextImpl struct {
	AppId            string
	ServiceId        string
	Token            string
	Timestamp        int64
	Payload          string
	Referers         []*interface{}
	NeedRespReferers bool
}

type ResponseHandleFunc func(ResponseMessageContext) error

type ResponseHandleFuncs []ResponseHandleFunc

type ResponseMessageContext interface {
	GetAppId() string
	GetServiceId() string
	GetRespServiceId() string
	GetTimestamp() int64
	GetPayload() string
	GetReferers() []*interface{}
	GetCode() int32
}

type ResponseMessageContextImpl struct {
	AppId         string
	ServiceId     string
	RespServiceId string
	Timestamp     int64
	Payload       string
	Referers      []*interface{}
	Code          int32
}

type RocketMQMessageQueueRepository struct {
	// contains filtered or unexported fields
}

type ServiceMessageClient interface {
	OnMessageRequest(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*MessageResponse, error)
	OnEcho(ctx context.Context, in *EchoRequest, opts ...grpc.CallOption) (*EchoResponse, error)
}

type ServiceMessageServer interface {
	OnMessageRequest(context.Context, *MessageRequest) (*MessageResponse, error)
	OnEcho(context.Context, *EchoRequest) (*EchoResponse, error)
}

type UnimplementedServiceMessageServer struct {
}