sse

README

Perkakas SSE Library

This library helps you to send message to SSE server

How To Send Message

type Donation struct {
    DonationID int64 `json:"donation_id"`
    UserID     int64 `json:"user_id"`
    Amount     int64 `json:"amount"` 
}

donationData := Donation{
    DonationID: 334534,
    UserID:     2463,
    Amount:     50000,
}

sseClient := NewSseClient("your-sse-host", "username", "password")

err := sseClient.SendEvent(context.Background(), "/notification/donation-created", donationData)
if err != nil {
    panic(err)
}

Documentation

Index

• type Client
  • func (s *Client) SendEvent(ctx context.Context, eventPath string, payload interface{}) (err error)
• type ISseClient
  • func NewSseClient(host, username, password string) ISseClient

Types

type Client

type Client struct {
	Host       string
	Username   string
	Password   string
	HTTPClient *httpclient.HttpClient
}

Client defines object for SSE instance client

func (*Client) SendEvent

func (s *Client) SendEvent(ctx context.Context, eventPath string, payload interface{}) (err error)

SendEvent will send event request to kitabisa SSE server

type ISseClient

type ISseClient interface {
	SendEvent(ctx context.Context, eventPath string, payload interface{}) (err error)
}

ISseClient defines interface of SSE client

func NewSseClient

func NewSseClient(host, username, password string) ISseClient

NewSseClient initializes new instance of SSE client