Documentation
¶
Index ¶
- func Initialize(brokers []string, topic string, source string) (*kafka_sarama.Sender, error)
- func SendEvent(etype string, message proto.Message) error
- func SendRoleUpdateEvent(role *pb.Role, action pb.RoleUpdateEvent_Action)
- func SendUserPermUpdateEvent(user *pb.User, action pb.UserPermissionUpdateEvent_Action)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Initialize ¶
func SendRoleUpdateEvent ¶
func SendRoleUpdateEvent(role *pb.Role, action pb.RoleUpdateEvent_Action)
func SendUserPermUpdateEvent ¶
func SendUserPermUpdateEvent(user *pb.User, action pb.UserPermissionUpdateEvent_Action)
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.