Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewProducer ¶
func NewProducer(cfg *config.GitWatchConfig) (events.Producer, error)
NewProducer receives a config to build a new EventProducer.
Types ¶
type EventProducer ¶
type EventProducer struct {
// contains filtered or unexported fields
}
EventProducer implements events.Producer with an attached GRPC connection and a configuration.
func (*EventProducer) Connect ¶
func (e *EventProducer) Connect(ctx context.Context, conn *grpc.ClientConn) error
Connect initializes the producer.
Click to show internal directories.
Click to hide internal directories.