message

Documentation

Index

• type IdentityClient
• type Reply
• type ReplyFn
• type Request

Types

type IdentityClient

type IdentityClient interface {
	Get(int64) (*identity.Identity, error)
	GetByIdentity(*pubsub.IdentityReq) (*identity.Identity, error)
	Delete(int64) (bool, error)
	Exist(int64) (bool, error)
	ExistIdentity(*pubsub.IdentityReq) (bool, error)
}

type Reply

type Reply interface {
	Publish(string, *pubsub.IdentityReply)
	Start(string, IdentityClient, ReplyFn) error
	Stop() error
}

type ReplyFn

type ReplyFn func(string, IdentityClient, *pubsub.IdentityReq) *pubsub.IdentityReply

type Request

type Request interface {
	UserRequest(string, *pubsub.IdRequest, time.Duration) (*pubsub.UserReply, error)
	UserRequestWithContext(context.Context, string, *pubsub.IdRequest) (*pubsub.UserReply, error)
	IsActive() bool
}