api

Documentation

Index

• type AppendEntriesArgs
• type AppendEntriesReply
• type AppendTopicArgs
• type AppendTopicReply
• type FetchMessage
• type Message
  • func (m *Message) String() string
• type MessageRequest
• type Response
• type TopicPartition

Types

type AppendEntriesArgs

type AppendEntriesArgs struct {
	Messages []Message `json:"messages"`
}

type AppendEntriesReply

type AppendEntriesReply struct {
	Message string `json:"message"`
	Success bool   `json:"success"`
}

type AppendTopicArgs

type AppendTopicArgs struct {
	TopicName         string `json:"name"`
	ReplicationFactor int    `json:"replicationFactor"`
	PartitionCount    int    `json:"partitionCount"`
}

type AppendTopicReply

type AppendTopicReply struct {
	Message string `json:"message"`
	Success bool   `json:"success"`
}

type FetchMessage

type FetchMessage struct {
	Offset         int            `json:"offset"`
	TopicPartition TopicPartition `json:"topic_Partition"`
}

type Message

type Message struct {
	TopicPartition TopicPartition `json:"topic_partition"`
	Value          []byte         `json:"value"`
	Key            []byte         `json:"key"`
	Timestap       time.Time      `json:"timestamp"`
}

func (*Message) String

func (m *Message) String() string

type MessageRequest

type MessageRequest struct {
	TopicPartition TopicPartition `json:"topic_partition"`
	Value          string         `json:"value"`
	Key            string         `json:"key"`
}

type Response

type Response struct {
	Message string `json:"message"`
}

type TopicPartition

type TopicPartition struct {
	Topic     string `json:"topic"`
	Partition int    `json:"partition"`
	Metadata  string `json:"metadata"`
}