http

Documentation

Index

• type HttpInput
  • func New() (*HttpInput, error)
  • func (h *HttpInput) CreateMessage(ctx context.Context, request *pb.CreateMessageRequest, vars map[string]string) error
  • func (h *HttpInput) Name() string
  • func (h *HttpInput) Start(handler input.Handler) error
  • func (h *HttpInput) Stop() error

Types

type HttpInput

type HttpInput struct {
	InputName string
	// contains filtered or unexported fields
}

func New

func New() (*HttpInput, error)

func (*HttpInput) CreateMessage

func (h *HttpInput) CreateMessage(ctx context.Context, request *pb.CreateMessageRequest, vars map[string]string) error

func (*HttpInput) Name

func (h *HttpInput) Name() string

func (*HttpInput) Start

func (h *HttpInput) Start(handler input.Handler) error

func (*HttpInput) Stop

func (h *HttpInput) Stop() error