data_protocol

Documentation

Index

• Constants
• type CloudEvent
  • func NewCloudEvent(eventID string, eventType string, source string, dataContentType string, ...) *CloudEvent
  • func NewCloudEventJson(eventID string, eventType string, source string, obj any) (*CloudEvent, error)
  • func UnmarshalJsonCloudEvent(cloudEventJsonBytes []byte) (*CloudEvent, error)
  • func (event *CloudEvent) MarshalJson() ([]byte, error)

Constants

const (
	DataContentTypeJson = "application/json"
)

Types

type CloudEvent

type CloudEvent struct {
	SpecVersion     string `json:"specversion"`
	ID              string `json:"id"`
	Type            string `json:"type"`
	Source          string `json:"source"`
	DataContentType string `json:"datacontenttype"`
	Time            string `json:"time"`
	Data            []byte `json:"data"`
}

func NewCloudEvent

func NewCloudEvent(eventID string, eventType string, source string, dataContentType string, data []byte) *CloudEvent

NewCloudEvent 创建CloudEvent 参数: - eventID: 事件ID - eventType: 事件类型 - source: 事件源，如foo.com - dataContentType: 事件数据类型，可以是任何mime类型，如application/json，application/text - data: 要发送的数据 返回值: - CloudEvent

func NewCloudEventJson

func NewCloudEventJson(eventID string, eventType string, source string, obj any) (*CloudEvent, error)

NewCloudEventJson 创建数据是Json类型的CloudEvent 参数: - eventID: 事件ID - eventType: 事件类型 - source: 事件源，如foo.com - obj: 需要转为json的对象 返回值: - CloudEvent - 错误

func UnmarshalJsonCloudEvent

func UnmarshalJsonCloudEvent(cloudEventJsonBytes []byte) (*CloudEvent, error)

UnmarshalJsonCloudEvent Unmarshal格式为Json的CloudEvent 参数: - cloudEventJsonBytes: CloudEvent的Json字节 返回值: - CloudEvent - 错误

func (*CloudEvent) MarshalJson

func (event *CloudEvent) MarshalJson() ([]byte, error)

MarshalJson Marshal格式为Json的CloudEvent 参数: 无 返回值: - CloudEvent的Json字节 - 错误