microserver

package

v1.0.2 Latest Latest Go to latest Published: Oct 9, 2024 License: MIT Imports: 27 Imported by: 0

Details

This section is empty.

View Source

var ProviderSetRPCConn = wire.NewSet(
	NewHouYiConn,
	NewRabbitRPCConn,
)

ProviderSetRPCConn wire set

This section is empty.

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

HouYiConn HouYi服务连接

func NewHouYiConn(c *palaceconf.Bootstrap) (*HouYiConn, func(), error)

NewHouYiConn 创建一个HouYi rpc连接

func (l *HouYiConn) Health(ctx context.Context, req *api.CheckRequest) (*api.CheckReply, error)

Health 健康检查

func (l *HouYiConn) PushStrategy(ctx context.Context, in *strategyapi.PushStrategyRequest, opts ...Option) (*strategyapi.PushStrategyReply, error)

PushStrategy 推送策略

func (l *HouYiConn) Query(ctx context.Context, in *metadataapi.QueryRequest, opts ...Option) (*metadataapi.QueryReply, error)

Query 查询数据

func (l *HouYiConn) Sync(ctx context.Context, in *metadataapi.SyncMetadataRequest, opts ...Option) (*metadataapi.SyncMetadataReply, error)

Sync 同步数据

func (l *HouYiConn) SyncV2(ctx context.Context, in *metadataapi.SyncMetadataV2Request, opts ...Option) (*metadataapi.SyncMetadataV2Reply, error)

SyncV2 同步数据

type Option struct {
	RPCOpts  []grpc.CallOption
	HTTPOpts []http.CallOption
}

Option http/grpc option

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

RabbitConn rabbit服务连接

func NewRabbitRPCConn(c *palaceconf.Bootstrap) (*RabbitConn, func(), error)

NewRabbitRPCConn 创建一个rabbit rpc连接

func (l *RabbitConn) NotifyObject(ctx context.Context, in *pushapi.NotifyObjectRequest, opts ...Option) (*pushapi.NotifyObjectReply, error)

NotifyObject 发送通道配置

func (l *RabbitConn) SendMsg(ctx context.Context, in *hookapi.SendMsgRequest, opts ...Option) (*hookapi.SendMsgReply, error)

SendMsg 发送消息

Path	Synopsis
microserverrepoimpl