dfx

README

Deploy from X

Deploy simple Text content from X.... where X is

• Twitter

More to come?

Usage

queue

Receives and redistributes events

• PORT (default: 3185) - Port to listen on

twitter-streamer

Listens for Tweets as configured and sends them to the queue

• QUEUE_ADDR (default: queue:3185) - Address of the queue service
• CONSUMER_KEY, CONSUMER_SECRET, ACCESS_TOKEN, ACCESS_TOKEN_SECRET - obtain from https://developer.twitter.com/en/apps
• FILTER - Only tweets matchin the filter will be watched (example: @appuioli #deployme). See "track" on https://developer.twitter.com/en/docs/tweets/filter-realtime/guides/basic-stream-parameters

Development

make dev-twitter-streamer
make dev-queue

License

MIT (see LICENSE)

---

Manuel Hutter - GitHub @mhutter - Twitter @dratir

Documentation

Index

• func RegisterQueueServer(s *grpc.Server, srv QueueServer)
• type Deployable
  • func (*Deployable) Descriptor() ([]byte, []int)
  • func (m *Deployable) GetContent() string
  • func (m *Deployable) GetFrom() string
  • func (m *Deployable) GetSource() string
  • func (m *Deployable) GetSourceUrl() string
  • func (m *Deployable) GetTitle() string
  • func (*Deployable) ProtoMessage()
  • func (m *Deployable) Reset()
  • func (m *Deployable) String() string
  • func (m *Deployable) XXX_DiscardUnknown()
  • func (m *Deployable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Deployable) XXX_Merge(src proto.Message)
  • func (m *Deployable) XXX_Size() int
  • func (m *Deployable) XXX_Unmarshal(b []byte) error
• type QueueClient
  • func NewQueueClient(cc *grpc.ClientConn) QueueClient
• type QueueServer
• type UnimplementedQueueServer
  • func (*UnimplementedQueueServer) PostEvent(ctx context.Context, req *Deployable) (*Void, error)
• type Void
  • func (*Void) Descriptor() ([]byte, []int)
  • func (*Void) ProtoMessage()
  • func (m *Void) Reset()
  • func (m *Void) String() string
  • func (m *Void) XXX_DiscardUnknown()
  • func (m *Void) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Void) XXX_Merge(src proto.Message)
  • func (m *Void) XXX_Size() int
  • func (m *Void) XXX_Unmarshal(b []byte) error

Functions

func RegisterQueueServer

func RegisterQueueServer(s *grpc.Server, srv QueueServer)

Types

type Deployable

type Deployable struct {
	Title                string   `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Content              string   `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	From                 string   `protobuf:"bytes,3,opt,name=from,proto3" json:"from,omitempty"`
	SourceUrl            string   `protobuf:"bytes,4,opt,name=source_url,json=sourceUrl,proto3" json:"source_url,omitempty"`
	Source               string   `protobuf:"bytes,5,opt,name=source,proto3" json:"source,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Deployable) Descriptor

func (*Deployable) Descriptor() ([]byte, []int)

func (*Deployable) GetContent

func (m *Deployable) GetContent() string

func (*Deployable) GetFrom

func (m *Deployable) GetFrom() string

func (*Deployable) GetSource

func (m *Deployable) GetSource() string

func (*Deployable) GetSourceUrl

func (m *Deployable) GetSourceUrl() string

func (*Deployable) GetTitle

func (m *Deployable) GetTitle() string

func (*Deployable) ProtoMessage

func (*Deployable) ProtoMessage()

func (*Deployable) Reset

func (m *Deployable) Reset()

func (*Deployable) String

func (m *Deployable) String() string

func (*Deployable) XXX_DiscardUnknown

func (m *Deployable) XXX_DiscardUnknown()

func (*Deployable) XXX_Marshal

func (m *Deployable) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Deployable) XXX_Merge

func (m *Deployable) XXX_Merge(src proto.Message)

func (*Deployable) XXX_Size

func (m *Deployable) XXX_Size() int

func (*Deployable) XXX_Unmarshal

func (m *Deployable) XXX_Unmarshal(b []byte) error

type QueueClient

type QueueClient interface {
	PostEvent(ctx context.Context, in *Deployable, opts ...grpc.CallOption) (*Void, error)
}

QueueClient is the client API for Queue service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQueueClient

func NewQueueClient(cc *grpc.ClientConn) QueueClient

type QueueServer

type QueueServer interface {
	PostEvent(context.Context, *Deployable) (*Void, error)
}

QueueServer is the server API for Queue service.

type UnimplementedQueueServer

type UnimplementedQueueServer struct {
}

UnimplementedQueueServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueueServer) PostEvent

func (*UnimplementedQueueServer) PostEvent(ctx context.Context, req *Deployable) (*Void, error)

type Void

type Void struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Void) Descriptor

func (*Void) Descriptor() ([]byte, []int)

func (*Void) ProtoMessage

func (*Void) ProtoMessage()

func (*Void) Reset

func (m *Void) Reset()

func (*Void) String

func (m *Void) String() string

func (*Void) XXX_DiscardUnknown

func (m *Void) XXX_DiscardUnknown()

func (*Void) XXX_Marshal

func (m *Void) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Void) XXX_Merge

func (m *Void) XXX_Merge(src proto.Message)

func (*Void) XXX_Size

func (m *Void) XXX_Size() int

func (*Void) XXX_Unmarshal

func (m *Void) XXX_Unmarshal(b []byte) error